producer

Documentation

Index

• Variables
• type P
  • func New(cluster model.Cluster) *P
  • func (p *P) Produce(topic string, key, value []byte) error
  • func (p *P) ProduceMessageSet(topic string, messageSet proto.MessageSet) error
  • func (p *P) ProduceWithPartition(topic string, partition int32, key, value []byte) error

Variables

var (
	ErrProduceFailed    = errors.New("produce failed")
	ErrNoValidPartition = errors.New("no valid partition")
)

Types

type P

type P struct {
	RequiredAcks proto.ProduceAckType
	AckTimeout   time.Duration
	Cluster      model.Cluster
	// contains filtered or unexported fields
}

func New

func New(cluster model.Cluster) *P

func (*P) Produce

func (p *P) Produce(topic string, key, value []byte) error

func (*P) ProduceMessageSet

func (p *P) ProduceMessageSet(topic string, messageSet proto.MessageSet) error

func (*P) ProduceWithPartition

func (p *P) ProduceWithPartition(topic string, partition int32, key, value []byte) error