server

Documentation

Index

• type GrpcServer
  • func NewPdhGrpcServer(opt *options.GrpcServerOptions) *GrpcServer
  • func (p *GrpcServer) AddHandler(handler transmit.MessageHandler)
  • func (p *GrpcServer) RemoveHandler(handler transmit.MessageHandler)
  • func (p *GrpcServer) Send(stream proto.PdhService_TransmitServer, message *proto.Message) error
  • func (p *GrpcServer) Start() error
  • func (p *GrpcServer) Stop()
  • func (p *GrpcServer) Transmit(stream proto.PdhService_TransmitServer) error

Types

type GrpcServer

type GrpcServer struct {
	common.RWMutex
	proto.UnimplementedPdhServiceServer
	// contains filtered or unexported fields
}

func NewPdhGrpcServer

func NewPdhGrpcServer(opt *options.GrpcServerOptions) *GrpcServer

func (*GrpcServer) AddHandler

func (p *GrpcServer) AddHandler(handler transmit.MessageHandler)

AddHandler add a message handler

func (*GrpcServer) RemoveHandler

func (p *GrpcServer) RemoveHandler(handler transmit.MessageHandler)

RemoveHandler remove a message handler

func (*GrpcServer) Send

func (p *GrpcServer) Send(stream proto.PdhService_TransmitServer, message *proto.Message) error

func (*GrpcServer) Start

func (p *GrpcServer) Start() error

func (*GrpcServer) Stop

func (p *GrpcServer) Stop()

func (*GrpcServer) Transmit

func (p *GrpcServer) Transmit(stream proto.PdhService_TransmitServer) error