handler

type AggregateReducer struct {
	Aggregate     eventstore.AggregateType
	EventRedusers []EventReducer
}

type Check struct {
	Executes []func(ex Executer, projectionName string) (bool, error)
}

type Column struct {
	Name         string
	Value        interface{}
	ParameterOpt func(string) string
}

type Condition Column

type EventReducer struct {
	Event  eventstore.EventType
	Reduce Reduce
}

type Executer interface {
	Exec(string, ...interface{}) (sql.Result, error)
}

type Handler struct {
	Eventstore *eventstore.Eventstore
	Sub        *eventstore.Subscription
	EventQueue chan eventstore.Event
}

type HandlerConfig struct {
	Eventstore *eventstore.Eventstore
}

type Init func(context.Context, *Check) error

type Lock func(context.Context, time.Duration, ...string) <-chan error

type ProjectionHandler struct {
	Handler
	ProjectionName string
	// contains filtered or unexported fields
}

type ProjectionHandlerConfig struct {
	HandlerConfig
	ProjectionName      string
	RequeueEvery        time.Duration
	RetryFailedAfter    time.Duration
	Retries             uint
	ConcurrentInstances uint
}

type Reduce func(eventstore.Event) (*Statement, error)

type SearchQuery func(ctx context.Context, instanceIDs []string) (query *eventstore.SearchQueryBuilder, queryLimit uint64, err error)

type Statement struct {
	AggregateType    eventstore.AggregateType
	Sequence         uint64
	PreviousSequence uint64
	InstanceID       string

	Execute func(ex Executer, projectionName string) error
}

type Statements []Statement

type Unlock func(...string) error

type Update func(context.Context, []*Statement, Reduce) (index int, err error)