transmit

Documentation

Index

• type ClientStreamWrapper
  • func NewClientStreamWrapper(stream proto.PdhService_TransmitClient) *ClientStreamWrapper
  • func (c *ClientStreamWrapper) Send(msg *proto.Message) error
• type GrpcStream
• type MessageHandler
• type ServerStreamWrapper
  • func NewServerStreamWrapper(stream proto.PdhService_TransmitServer) *ServerStreamWrapper
  • func (s *ServerStreamWrapper) Send(msg *proto.Message) error
  • func (s *ServerStreamWrapper) StartWriteToChannel()
  • func (s *ServerStreamWrapper) StopWriteToChannel()

Types

type ClientStreamWrapper

type ClientStreamWrapper struct {
	Stream proto.PdhService_TransmitClient
}

func NewClientStreamWrapper

func NewClientStreamWrapper(stream proto.PdhService_TransmitClient) *ClientStreamWrapper

func (*ClientStreamWrapper) Send

func (c *ClientStreamWrapper) Send(msg *proto.Message) error

type GrpcStream

type GrpcStream interface {
	Send(msg *proto.Message) error
}

type MessageHandler

type MessageHandler interface {
	HandleMessage(stream GrpcStream, msg *proto.Message)
}

type ServerStreamWrapper

type ServerStreamWrapper struct {
	Stream proto.PdhService_TransmitServer

	Ch        chan *proto.Message
	WriteToCh atomic.Bool
	// contains filtered or unexported fields
}

func NewServerStreamWrapper

func NewServerStreamWrapper(stream proto.PdhService_TransmitServer) *ServerStreamWrapper

func (*ServerStreamWrapper) Send

func (s *ServerStreamWrapper) Send(msg *proto.Message) error

func (*ServerStreamWrapper) StartWriteToChannel

func (s *ServerStreamWrapper) StartWriteToChannel()

func (*ServerStreamWrapper) StopWriteToChannel

func (s *ServerStreamWrapper) StopWriteToChannel()