Versions in this module Expand all Collapse all v0 v0.9.0 Mar 1, 2019 Changes in this version + var ErrBackgroundWorkStopped = errors.New("goengine: unable to queue notification because the processor was stopped") + func AcquireConn(ctx context.Context, db *sql.DB) (*sql.Conn, error) + type BackgroundProcessor struct + func NewBackgroundProcessor(queueProcessors, queueBuffer int, logger goengine.Logger) (*BackgroundProcessor, error) + func (b *BackgroundProcessor) Execute(ctx context.Context, handler ProcessHandler, ...) error + func (b *BackgroundProcessor) Queue(ctx context.Context, notification *sql.ProjectionNotification) error + func (b *BackgroundProcessor) Start(ctx context.Context, handler ProcessHandler) func() + type NotificationProjector struct + func NewNotificationProjector(db *sql.DB, storage driverSQL.ProjectionStorage, ...) (*NotificationProjector, error) + func (s *NotificationProjector) Execute(ctx context.Context, notification *driverSQL.ProjectionNotification) error + type ProcessHandler func(context.Context, *sql.ProjectionNotification, sql.ProjectionTrigger) error
Go to main page