process

Documentation

Overview

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

Index

• type Controller
  • func NewController(n string, h dogma.ProcessMessageHandler, g *envelope.MessageIDGenerator, ...) *Controller
  • func (c *Controller) Handle(ctx context.Context, obs fact.Observer, now time.Time, env *envelope.Envelope) ([]*envelope.Envelope, error)
  • func (c *Controller) Name() string
  • func (c *Controller) Reset()
  • func (c *Controller) Tick(ctx context.Context, obs fact.Observer, now time.Time) ([]*envelope.Envelope, error)
  • func (c *Controller) Type() handler.Type

Types

type Controller

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

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

func NewController

func NewController(
	n string,
	h dogma.ProcessMessageHandler,
	g *envelope.MessageIDGenerator,
	t message.TypeContainer,
) *Controller

NewController returns a new controller for the given handler.

func (*Controller) Handle

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

Handle handles a message.

func (*Controller) Name

func (c *Controller) Name() string

Name returns the name 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(
	ctx context.Context,
	obs fact.Observer,
	now time.Time,
) ([]*envelope.Envelope, error)

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

func (*Controller) Type

func (c *Controller) Type() handler.Type

Type returns handler.ProcessType.