integration

Documentation

Overview

Package integration provides an adaptor that exposes Dogma integration message handlers as Verity handlers.

Index

• type Adaptor
  • func (a *Adaptor) HandleMessage(ctx context.Context, w handler.UnitOfWork, p parcel.Parcel) (err error)

Types

type Adaptor

type Adaptor struct {
	// Identity is the handler's identity.
	Identity *envelopespec.Identity

	// Handler is the integration message handler that implements the
	// application-specific message handling logic.
	Handler dogma.IntegrationMessageHandler

	// Packer is used to create new parcels for events recorded by the
	// handler.
	Packer *parcel.Packer

	// DefaultTimeout is the timeout to apply when handling the message if the
	// handler does not provide a timeout hint.
	DefaultTimeout time.Duration

	// Logger is the target for log messages produced within the handler.
	// If it is nil, logging.DefaultLogger is used.
	Logger logging.Logger
}

Adaptor exposes a dogma.IntegrationMessageHandler as a handler.Handler.

func (*Adaptor) HandleMessage

func (a *Adaptor) HandleMessage(
	ctx context.Context,
	w handler.UnitOfWork,
	p parcel.Parcel,
) (err error)

HandleMessage handles the message in p.