client

Documentation

Index

• type GrpcClient
  • func NewPdhGrpcClient(target string) *GrpcClient
  • func (p *GrpcClient) AddHandler(handler transmit.MessageHandler)
  • func (p *GrpcClient) RemoveHandler(handler transmit.MessageHandler)
  • func (p *GrpcClient) Send(msg *proto.Message) error
  • func (p *GrpcClient) Start() error
  • func (p *GrpcClient) Stop()

Types

type GrpcClient

type GrpcClient struct {
	common.RWMutex
	// contains filtered or unexported fields
}

func NewPdhGrpcClient

func NewPdhGrpcClient(target string) *GrpcClient

func (*GrpcClient) AddHandler

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

AddHandler add a message handler

func (*GrpcClient) RemoveHandler

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

RemoveHandler remove a message handler

func (*GrpcClient) Send

func (p *GrpcClient) Send(msg *proto.Message) error

func (*GrpcClient) Start

func (p *GrpcClient) Start() error

func (*GrpcClient) Stop

func (p *GrpcClient) Stop()