Documentation
¶
Overview ¶
Package fixtures is a set of test fixtures and mocks for SQL projections.
Index ¶
- type MessageHandler
- func (h *MessageHandler) Compact(ctx context.Context, db *sql.DB, s dogma.ProjectionCompactScope) error
- func (h *MessageHandler) Configure(c dogma.ProjectionConfigurer)
- func (h *MessageHandler) HandleEvent(ctx context.Context, tx *sql.Tx, s dogma.ProjectionEventScope, m dogma.Message) error
- func (h *MessageHandler) TimeoutHint(m dogma.Message) time.Duration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageHandler ¶
type MessageHandler struct {
ConfigureFunc func(dogma.ProjectionConfigurer)
HandleEventFunc func(context.Context, *sql.Tx, dogma.ProjectionEventScope, dogma.Message) error
TimeoutHintFunc func(dogma.Message) time.Duration
CompactFunc func(context.Context, *sql.DB, dogma.ProjectionCompactScope) error
}
MessageHandler is a test implementation of sql.MessageHandler.
func (*MessageHandler) Compact ¶
func (h *MessageHandler) Compact(ctx context.Context, db *sql.DB, s dogma.ProjectionCompactScope) error
Compact reduces the size of the projection's data.
If h.CompactFunc is non-nil it returns h.CompactFunc(ctx,db,s), otherwise it returns nil.
func (*MessageHandler) Configure ¶
func (h *MessageHandler) Configure(c dogma.ProjectionConfigurer)
Configure configures the behavior of the engine as it relates to this handler.
c provides access to the various configuration options, such as specifying which types of event messages are routed to this handler.
If h.ConfigureFunc is non-nil, it calls h.ConfigureFunc(c).
func (*MessageHandler) HandleEvent ¶
func (h *MessageHandler) HandleEvent( ctx context.Context, tx *sql.Tx, s dogma.ProjectionEventScope, m dogma.Message, ) error
HandleEvent handles a domain event message that has been routed to this handler.
If h.HandleEventFunc is non-nil it returns h.HandleEventFunc(ctx, tx, s, m).
func (*MessageHandler) TimeoutHint ¶
func (h *MessageHandler) TimeoutHint(m dogma.Message) time.Duration
TimeoutHint returns a duration that is suitable for computing a deadline for the handling of the given message by this handler.
If h.TimeoutHintFunc is non-nil it returns h.TimeoutHintFunc(m), otherwise it returns 0.
Source Files