retry

Documentation

Index

• type Config
• type Producer
  • func NewProducer(cfg *Config, p producer.Producer) *Producer
  • func (p *Producer) Publish(ctx context.Context, topic string, message *message.Message) error

Types

type Config

type Config struct {
	Timeout  time.Duration `yaml:"timeout" json:"timeout" toml:"timeout"`
	Attempts uint          `yaml:"attempts" json:"attempts" toml:"attempts"`
}

Config for retry.

type Producer

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

Producer for retry.

func NewProducer

func NewProducer(cfg *Config, p producer.Producer) *Producer

NewProducer for retry.

func (*Producer) Publish

func (p *Producer) Publish(ctx context.Context, topic string, message *message.Message) error