streams

Documentation

Index

• func RunGRPC(port int)
• type Server
  • func NewServer() *Server
  • func (s *Server) Create(ctx context.Context, request *pb.Stream) (*pb.Stream, error)
  • func (s *Server) Delete(ctx context.Context, request *pb.Stream) (*pb.Empty, error)
  • func (s *Server) Get(ctx context.Context, request *pb.GetRequest) (*pb.Stream, error)
  • func (s *Server) List(ctx context.Context, request *pb.Empty) (*pb.StreamList, error)
  • func (s *Server) ListIds(ctx context.Context, searchRequest *pb.SearchRequest) (*pb.IdList, error)
  • func (s *Server) Update(ctx context.Context, request *pb.Stream) (*pb.Stream, error)

Functions

func RunGRPC

func RunGRPC(port int)

RunGRPC starts the GRPC server

Types

type Server

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

Server core struct

func NewServer

func NewServer() *Server

NewServer creates a new struct to interface the streams server

func (*Server) Create

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

Create stores a new stream in the DB

func (*Server) Delete

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

Delete deletes the stream

func (*Server) Get

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

Get fetches the stream from DB

func (*Server) List

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 (*Server) ListIds

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

ListIds provides a list of ids

func (*Server) Update

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