eventqueue

type Config struct {
	Name  string
	Kafka kafka.Config
}

type EventQueue interface {
	//publish multiple messages
	Publish(ctx context.Context, events ...models.IMessage) error

	//consume single message
	Consume(ctx context.Context) (models.IMessage, error)
	ConsumeAndCommit(ctx context.Context) (models.IMessage, error)

	// consume many messages
	ConsumeMany(ctx context.Context) ([]models.IMessage, error)
	ConsumeManyAndCommit(ctx context.Context)

	// pass the consumed messages to commit
	Commit(ctx context.Context, events ...models.IMessage) error
}