pulsar

Documentation

Index

• type Op
  • func NewOp() *Op
  • func (rOp *Op) CloseConsumer()
  • func (rOp *Op) CloseProducer()
  • func (rOp *Op) InitConsumer(topicID, peerID string) error
  • func (rOp *Op) InitProducer(topicID string) error
  • func (rOp *Op) Receive() (*model.Message, error)
  • func (rOp *Op) Send(message *model.Message) error

Types

type Op

type Op struct {
	GoRealMB *mb.GoRealMB
}

Op ...

func NewOp

func NewOp() *Op

NewOp ...

func (*Op) CloseConsumer

func (rOp *Op) CloseConsumer()

CloseConsumer ...

func (*Op) CloseProducer

func (rOp *Op) CloseProducer()

CloseProducer ...

func (*Op) InitConsumer

func (rOp *Op) InitConsumer(topicID, peerID string) error

InitConsumer ...

func (*Op) InitProducer

func (rOp *Op) InitProducer(topicID string) error

InitProducer ...

func (*Op) Receive

func (rOp *Op) Receive() (*model.Message, error)

Receive ...

func (*Op) Send

func (rOp *Op) Send(message *model.Message) error

Send ...