eventqueue

Jun 13, 2024

Changes in this version

+ const KAFKA

+ type Config struct

+ Kafka kafka.Config

+ Name string

+ type EventQueue interface

+ Commit func(ctx context.Context, events ...models.IMessage) error

+ Consume func(ctx context.Context) (models.IMessage, error)

+ ConsumeAndCommit func(ctx context.Context) (models.IMessage, error)

+ ConsumeMany func(ctx context.Context) ([]models.IMessage, error)

+ ConsumeManyAndCommit func(ctx context.Context)

+ Publish func(ctx context.Context, events ...models.IMessage) error

+ func NewEventQueue(ctx context.Context, cfg *Config) EventQueue