Versions in this module Expand all Collapse all v0 v0.2.0 Jul 16, 2026 Changes in this version + var ErrAlreadyReplayed = errors.New("identity: execution already replayed (chain must not fork)") + var ErrCompletedNotAllowed = errors.New("identity: replaying a completed execution requires AllowCompleted") + var ErrInFlight = errors.New("identity: business key has an in-flight execution") + var ErrNotFinal = errors.New("identity: replay target not in final state") + var ErrUnknownExecution = errors.New("identity: unknown execution") + var ErrUnknownKey = errors.New("identity: unknown business key") + type Layer struct + func New(g *taskgate.Gate) *Layer + func (l *Layer) History(key string) []string + func (l *Layer) ReplayByID(ctx context.Context, execID string, opt ReplayOptions) (string, error) + func (l *Layer) ReplayByKey(ctx context.Context, key string, opt ReplayOptions) (string, error) + func (l *Layer) ReplayOf(execID string) (string, bool) + func (l *Layer) Submit(ctx context.Context, taskType string, payload json.RawMessage, key string, ...) (string, error) + type ReplayOptions struct + AllowCompleted bool + Payload json.RawMessage
Go to main page