Versions in this module Expand all Collapse all v1 v1.0.0 Feb 21, 2024 Changes in this version + var ErrConsumerAlreadyRunning = errors.New("consumer.Run: consumer already running") + type Consumer interface + Close func() error + Healthy func(ctx context.Context) error + Run func(ctx context.Context) error + type DeliveryType uint8 + const AtLeastOnceDeliveryType + const AtMostOnceDeliveryType + type Processor interface + Process func(context.Context, ...Record) error + type ProcessorFunc func(context.Context, ...Record) error + func (f ProcessorFunc) Process(ctx context.Context, rs ...Record) error + type Producer interface + Close func() error + Healthy func(ctx context.Context) error + Produce func(ctx context.Context, rs ...Record) error + type Record struct + OrderingKey []byte + Topic Topic + Value []byte + type Topic string + type TopicConsumer struct + Consumer string + Regex string + Topic Topic Other modules containing this package github.com/elastic/apm-queue/v2
Go to main page