Documentation
¶
Overview ¶
Package integration provides an adaptor that exposes Dogma integration message handlers as Verity handlers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
// Timeout is the timeout to apply when handling the message.
Timeout 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.
Source Files
Click to show internal directories.
Click to hide internal directories.