pool

Documentation

Index

• type EventPool
  • func (e *EventPool) Enqueue(event *models.Event) error
  • func (e *EventPool) Initialize(factory factory.EventPoolWorkerFactory, ctx context.Context) error
  • func (e *EventPool) PublishEvents()
• type EventPooler

Types

type EventPool

type EventPool struct {
	// contains filtered or unexported fields
}

func (*EventPool) Enqueue

func (e *EventPool) Enqueue(event *models.Event) error

Takes validated event models and enqueues them into the pool

func (*EventPool) Initialize

func (e *EventPool) Initialize(factory factory.EventPoolWorkerFactory, ctx context.Context) error

func (*EventPool) PublishEvents

func (e *EventPool) PublishEvents()

type EventPooler

type EventPooler interface {
	Enqueue(event *models.Event) error
	PublishEvents()
}