server

Documentation

Index

• func StartGRPCServer(address string, provider st_grpc.MessageProvider) error
• type GRPCServer
  • func NewGRPCServer(provider st_grpc.MessageProvider) *GRPCServer
  • func (s *GRPCServer) StreamMessages(req *st_grpc.StreamRequest, ...) error

Functions

func StartGRPCServer

func StartGRPCServer(address string, provider st_grpc.MessageProvider) error

Types

type GRPCServer

type GRPCServer struct {
	st_grpc.UnimplementedLiveMessageServiceServer
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(provider st_grpc.MessageProvider) *GRPCServer

func (*GRPCServer) StreamMessages

func (s *GRPCServer) StreamMessages(req *st_grpc.StreamRequest, stream st_grpc.LiveMessageService_StreamMessagesServer) error