process

package

v0.20.0 Latest Latest Go to latest Published: Dec 16, 2025 License: MIT Imports: 13 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     *config.Process
	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) HandlerConfig() config.Handler

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

func (c *Controller) Reset()

Reset clears the state of the controller.

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

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