projection

package

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

Details

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

This section is empty.

This section is empty.

This section is empty.

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

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

func NewController(
	c configkit.RichProjection,
) *Controller

NewController returns a new controller for the given handler.

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(
	context.Context,
	fact.Observer,
	time.Time,
) ([]*envelope.Envelope, error)

Tick does nothing.

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

Type returns configkit.ProjectionHandlerType.