receiver

Documentation

Index

• type Receiver
  • func NewReceiver(opt *options.ReceiverOptions) *Receiver
  • func (r *Receiver) Done()
  • func (r *Receiver) HandleMessage(stream transmit.GrpcStream, msg *proto.Message)
  • func (r *Receiver) Receive()

Types

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(opt *options.ReceiverOptions) *Receiver

func (*Receiver) Done

func (r *Receiver) Done()

func (*Receiver) HandleMessage

func (r *Receiver) HandleMessage(stream transmit.GrpcStream, msg *proto.Message)

func (*Receiver) Receive

func (r *Receiver) Receive()