aws_msk_producer

Documentation

Index

• type AwsMskProducer
  • func NewAwsMskProducer(opts *options.ProducerOptions) (*AwsMskProducer, error)
  • func (p *AwsMskProducer) Publish(ctx context.Context, msg []byte, properties map[string]interface{}) error
  • func (p *AwsMskProducer) PublishWithTopic(ctx context.Context, topic string, msg []byte, ...) error

Types

type AwsMskProducer

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

func NewAwsMskProducer

func NewAwsMskProducer(opts *options.ProducerOptions) (*AwsMskProducer, error)

func (*AwsMskProducer) Publish

func (p *AwsMskProducer) Publish(ctx context.Context, msg []byte, properties map[string]interface{}) error

func (*AwsMskProducer) PublishWithTopic

func (p *AwsMskProducer) PublishWithTopic(ctx context.Context, topic string, msg []byte, properties map[string]interface{}) error