projection

package

v0.10.0 Latest Latest Go to latest Published: Nov 15, 2020 License: MIT Imports: 7 Imported by: 0

Details

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

View Source

const CompactInterval = 1 * time.Hour

CompactInterval is how frequently projections should be compacted.

This interval respects the current engine time, which may not be the same as the "real world" time. See engine.RunTimeScaled().

This section is empty.

This section is empty.

type Controller struct {
	Config                configkit.RichProjection
	CompactDuringHandling bool
	// contains filtered or unexported fields
}

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

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

Handle handles a message.

func (c *Controller) Identity() configkit.Identity

Identity returns the identity of the handler that is managed by this controller.

func (c *Controller) Reset()

Reset does nothing.

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

Tick always performs projection compaction.

func (c *Controller) Type() configkit.HandlerType

Type returns configkit.ProjectionHandlerType.