eventqueue

Documentation

Index

• Constants
• type Config
• type EventQueue
  • func NewEventQueue(ctx context.Context, cfg *Config) EventQueue

Constants

const (
	KAFKA = "kafka"
)

Types

type Config

type Config struct {
	Name  string
	Kafka kafka.Config
}

type EventQueue

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
}

func NewEventQueue

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