aggregate

Documentation

Index

• Variables
• type ServiceAggregator
  • func NewServiceAggregator(ctx context.Context, l zerolog.Logger, ent *connection.EntConnection) *ServiceAggregator
  • func (s ServiceAggregator) Aggregate(ctx context.Context) error

Variables

var (
	ErrApiKeyNotFound         = errors.New("api key not found")
	ErrMinimumPendingMessages = errors.New("minimum number of messages to aggregate is 2")
)

Types

type ServiceAggregator

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

func NewServiceAggregator

func NewServiceAggregator(ctx context.Context, l zerolog.Logger, ent *connection.EntConnection) *ServiceAggregator

func (ServiceAggregator) Aggregate

func (s ServiceAggregator) Aggregate(ctx context.Context) error