grpc

Documentation

Index

• type GrpcServer
  • func NewGrpcServer(dsn string) (*GrpcServer, error)
  • func NewGrpcServerWithContext(ctx context.Context, dsn string) (*GrpcServer, error)
  • func (s *GrpcServer) PublishMessage(ctx context.Context, msg *entities.Message) (v interface{}, err error)
  • func (s *GrpcServer) PutMessage(ctx context.Context, in *pb.MessageRequest) (*pb.MessageResponse, error)
  • func (s *GrpcServer) Run(port int) error
  • func (s *GrpcServer) RunWithContext(ctx context.Context, port int) error

Types

type GrpcServer

type GrpcServer struct {
	pb.UnimplementedMessageServiceServer
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(dsn string) (*GrpcServer, error)

func NewGrpcServerWithContext

func NewGrpcServerWithContext(ctx context.Context, dsn string) (*GrpcServer, error)

func (*GrpcServer) PublishMessage

func (s *GrpcServer) PublishMessage(ctx context.Context, msg *entities.Message) (v interface{}, err error)

func (*GrpcServer) PutMessage

func (s *GrpcServer) PutMessage(ctx context.Context, in *pb.MessageRequest) (*pb.MessageResponse, error)

func (*GrpcServer) Run

func (s *GrpcServer) Run(port int) error

func (*GrpcServer) RunWithContext

func (s *GrpcServer) RunWithContext(ctx context.Context, port int) error