producer

Documentation

Index

• type ProducerOptions
• type ResumableProducer
  • func NewResumableProducer(f factory, opts *ProducerOptions) *ResumableProducer
  • func (p *ResumableProducer) Close()
  • func (p *ResumableProducer) Produce(ctx context.Context, msg message.MutableMessage) (result *producer.ProduceResult, err error)

Types

type ProducerOptions

type ProducerOptions struct {
	PChannel string
}

ProducerOptions is the options for creating a producer.

type ResumableProducer

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

ResumableProducer is implementation for producing message to streaming service. ResumableProducer select a right streaming node to produce automatically. ResumableProducer will do automatic resume from stream broken and streaming node re-balance. All error in these package should be marked by streaming/errs package.

func NewResumableProducer

func NewResumableProducer(f factory, opts *ProducerOptions) *ResumableProducer

NewResumableProducer creates a new producer. Provide an auto resuming producer.

func (*ResumableProducer) Close

func (p *ResumableProducer) Close()

Close close the producer.

func (*ResumableProducer) Produce

func (p *ResumableProducer) Produce(ctx context.Context, msg message.MutableMessage) (result *producer.ProduceResult, err error)

Produce produce a new message to log service.