integration

package

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

Details

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

This section is empty.

This section is empty.

This section is empty.

type Controller struct {
	Config     configkit.RichIntegration
	MessageIDs *envelope.MessageIDGenerator
}

Controller is an implementation of engine.Controller for dogma.IntegrationMessageHandler 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 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.IntegrationHandlerType.