prod

Documentation

Index

• type Producer
  • func New() *Producer
  • func (this *Producer) NewCustomConsumer(opts ...producer.Option) error
  • func (this *Producer) NewProducer(servers []string) error
  • func (this *Producer) SendAsync(topic, json string, ...) error
  • func (this *Producer) SendSync(topic, json string) (*primitive.SendResult, error)
  • func (this *Producer) Shutdown() error
  • func (this *Producer) Start() error

Types

type Producer

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

func New

func New() *Producer

func (*Producer) NewCustomConsumer

func (this *Producer) NewCustomConsumer(opts ...producer.Option) error

func (*Producer) NewProducer

func (this *Producer) NewProducer(servers []string) error

func (*Producer) SendAsync

func (this *Producer) SendAsync(topic, json string, mq func(ctx context.Context, result *primitive.SendResult, err error)) error

SendAsync 异步方法

func (*Producer) SendSync

func (this *Producer) SendSync(topic, json string) (*primitive.SendResult, error)

SendSync 同步方法

func (*Producer) Shutdown

func (this *Producer) Shutdown() error

func (*Producer) Start

func (this *Producer) Start() error