eea

Documentation

Overview

Package eea provides objects and event handlers for the EEA. EEA stands for Event Execution Aggregator. The EEA is responsible for aggregating events from the webhook and making sure we don't send too many events to the executor engine.

Index

• type EEA
  • func NewEEA(querier db.Store, evt interfaces.Publisher, cfg *serverconfig.AggregatorConfig, ...) *EEA
  • func (e *EEA) AggregateMiddleware(h message.HandlerFunc) message.HandlerFunc
  • func (e *EEA) FlushAll(ctx context.Context) error
  • func (e *EEA) FlushMessageHandler(msg *message.Message) error
  • func (e *EEA) Register(r interfaces.Registrar)

Types

type EEA

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

EEA is the Event Execution Aggregator

func NewEEA

func NewEEA(querier db.Store, evt interfaces.Publisher, cfg *serverconfig.AggregatorConfig,
	ef service.PropertiesService, provMan manager.ProviderManager) *EEA

NewEEA creates a new EEA

func (*EEA) AggregateMiddleware

func (e *EEA) AggregateMiddleware(h message.HandlerFunc) message.HandlerFunc

AggregateMiddleware will pass on the event to the executor engine if the event is ready to be executed. Else it'll cache the event until it's ready to be executed.

func (*EEA) FlushAll

func (e *EEA) FlushAll(ctx context.Context) error

FlushAll will flush all events in the cache to the executor engine

func (*EEA) FlushMessageHandler

func (e *EEA) FlushMessageHandler(msg *message.Message) error

FlushMessageHandler will flush the cache of events to the executor engine if the event is ready to be executed.

func (*EEA) Register

func (e *EEA) Register(r interfaces.Registrar)

Register implements the Consumer interface.