streams

package

v0.0.0-...-0172641 Latest Latest Go to latest Published: Sep 5, 2020 License: GPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func RunGRPC(port int)

RunGRPC starts the GRPC server

type Server struct {
	// contains filtered or unexported fields
}

Server core struct

func NewServer() *Server

NewServer creates a new struct to interface the streams server

func (s *Server) Create(ctx context.Context, request *pb.Stream) (*pb.Stream, error)

Create stores a new stream in the DB

func (s *Server) Delete(ctx context.Context, request *pb.Stream) (*pb.Empty, error)

Delete deletes the stream

func (s *Server) Get(ctx context.Context, request *pb.GetRequest) (*pb.Stream, error)

Get fetches the stream from DB

func (s *Server) List(ctx context.Context, request *pb.Empty) (*pb.StreamList, error)

List provides a list of streams the user is an owner of

func (s *Server) ListIds(ctx context.Context, searchRequest *pb.SearchRequest) (*pb.IdList, error)

ListIds provides a list of ids

func (s *Server) Update(ctx context.Context, request *pb.Stream) (*pb.Stream, error)

Update updates the record in the DB with the matching owner and id then returns the same stream

Path	Synopsis
cmd
protos Package evntsrc_streams is a generated protocol buffer package.	Package evntsrc_streams is a generated protocol buffer package.