aggregate

Documentation

Overview

Package aggregate provides engine components that handle messages that are routed to aggregate message handlers.

Index

• type Controller
  • func (c *Controller) Handle(_ context.Context, obs fact.Observer, now time.Time, env *envelope.Envelope) ([]*envelope.Envelope, error)
  • func (c *Controller) HandlerConfig() configkit.RichHandler
  • func (c *Controller) Reset()
  • func (c *Controller) Tick(context.Context, fact.Observer, time.Time) ([]*envelope.Envelope, error)

Types

type Controller

type Controller struct {
	Config     configkit.RichAggregate
	MessageIDs *envelope.MessageIDGenerator
	// contains filtered or unexported fields
}

Controller is an implementation of engine.Controller for dogma.AggregateMessageHandler implementations.

func (*Controller) Handle

func (c *Controller) Handle(
	_ context.Context,
	obs fact.Observer,
	now time.Time,
	env *envelope.Envelope,
) ([]*envelope.Envelope, error)

Handle handles a message.

func (*Controller) HandlerConfig

func (c *Controller) HandlerConfig() configkit.RichHandler

HandlerConfig returns the config of the handler that is managed by this controller.

func (*Controller) Reset

func (c *Controller) Reset()

Reset clears the state of the controller.

func (*Controller) Tick

func (c *Controller) Tick(
	context.Context,
	fact.Observer,
	time.Time,
) ([]*envelope.Envelope, error)

Tick does nothing.