process

package

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

Details

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

This section is empty.

This section is empty.

This section is empty.

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

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

func (c *Controller) Handle(
	ctx context.Context,
	obs fact.Observer,
	now 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 clears the state of the controller.

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

Tick returns the timeout messages that are ready to be handled.

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

Type returns configkit.ProcessHandlerType.