kafkajobs

Nov 11, 2022

Changes in this version

+ type CompressionCodec string

+ type Configurer interface

+ Has func(name string) bool

+ UnmarshalKey func(name string, out any) error

+ type Consumer struct

+ func FromPipeline(pipeline *pipeline.Pipeline, log *zap.Logger, cfg Configurer, ...) (*Consumer, error)

+ func NewKafkaConsumer(configKey string, log *zap.Logger, cfg Configurer, pq priorityqueue.Queue) (*Consumer, error)

+ func (c *Consumer) Pause(_ context.Context, p string)

+ func (c *Consumer) Push(ctx context.Context, job *jobs.Job) error

+ func (c *Consumer) Register(_ context.Context, p *pipeline.Pipeline) error

+ func (c *Consumer) Resume(_ context.Context, p string)

+ func (c *Consumer) Run(_ context.Context, p *pipeline.Pipeline) error

+ func (c *Consumer) State(context.Context) (*jobs.State, error)

+ func (c *Consumer) Stop(context.Context) error

+ type ConsumerOpts struct

+ HeartbeatInterval int

+ MaxFetchMessageSize int32

+ MinFetchMessageSize int32

+ SessionTimeout int

+ type CreateTopics struct

+ ConfigEntries map[string]*string

+ ReplicaAssignment map[int32][]int32

+ ReplicationFactor int16

+ type Item struct

+ Headers map[string][]string

+ Ident string

+ Job string

+ Options *Options

+ Payload string

+ func (i *Item) Ack() error

+ func (i *Item) Body() []byte

+ func (i *Item) Context() ([]byte, error)

+ func (i *Item) Copy() *Item

+ func (i *Item) ID() string

+ func (i *Item) Nack() error

+ func (i *Item) Priority() int64

+ func (i *Item) Requeue(headers map[string][]string, _ int64) error

+ func (i *Item) Respond(_ []byte, _ string) error

+ type JobKVEncoder struct

+ func (j JobKVEncoder) Encode() ([]byte, error)

+ func (j JobKVEncoder) Length() int

+ type Options struct

+ AutoAck bool

+ Delay int64

+ Pipeline string

+ Priority int64

+ func (o *Options) DelayDuration() time.Duration

+ type ProducerOpts struct

+ CompressionCodec CompressionCodec

+ CompressionLevel *int

+ Idempotent bool

+ MaxMessageBytes int

+ RequiredAcks *int

+ Timeout int