Versions in this module Expand all Collapse all v2 v2.0.2 Jun 23, 2024 v2.0.1 Jun 6, 2024 Changes in this version + var Start = new(emptypb.Empty) + type DiscardHandler struct + func NewDiscardHandler(logger log.Logger) *DiscardHandler + func (x *DiscardHandler) EventsCount() int + func (x *DiscardHandler) Handle(_ context.Context, persistenceID string, event *anypb.Any, state *anypb.Any, ...) error + type Handler interface + Handle func(ctx context.Context, persistenceID string, event *anypb.Any, state *anypb.Any, ...) error + type Option interface + Apply func(runner *runner) + func WithLogger(logger log.Logger) Option + func WithMaxBufferSize(bufferSize int) Option + func WithRecoveryStrategy(strategy *Recovery) Option + func WithRefreshInterval(interval time.Duration) Option + func WithResetOffset(resetOffset time.Time) Option + func WithStartOffset(startOffset time.Time) Option + type OptionFunc func(*runner) + func (f OptionFunc) Apply(runner *runner) + type Projection struct + func New(name string, handler Handler, eventsStore eventstore.EventsStore, ...) *Projection + func (x *Projection) PostStop(ctx context.Context) error + func (x *Projection) PreStart(ctx context.Context) error + func (x *Projection) Receive(ctx actors.ReceiveContext) + type Recovery struct + func NewRecovery(options ...RecoveryOption) *Recovery + func (c Recovery) RecoveryPolicy() RecoveryPolicy + func (c Recovery) Retries() uint64 + func (c Recovery) RetryDelay() time.Duration + type RecoveryOption interface + Apply func(recovery *Recovery) + func WithRecoveryPolicy(policy RecoveryPolicy) RecoveryOption + func WithRetries(retries uint64) RecoveryOption + func WithRetryDelay(delay time.Duration) RecoveryOption + type RecoveryOptionFunc func(recovery *Recovery) + func (f RecoveryOptionFunc) Apply(c *Recovery) + type RecoveryPolicy int + const Fail + const RetryAndFail + const RetryAndSkip + const Skip Other modules containing this package github.com/tochemey/ego github.com/tochemey/ego/v3
Go to main page