Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(h UpstreamHandler) dogma.ProjectionMessageHandler
New adapts a projectionkit message handler that has not been bound to a specific database into a Dogma projection message handler.
Any operations that require access to the database return an error.
Types ¶
type UpstreamHandler ¶
type UpstreamHandler interface {
Configure(dogma.ProjectionConfigurer)
TimeoutHint(dogma.Message) time.Duration
}
UpstreamHandler is a handler that adheres to one of the MessageHandler interfaces within projectionkit.
Source Files
Click to show internal directories.
Click to hide internal directories.