Versions in this module Expand all Collapse all v0 v0.0.0 May 19, 2026 Changes in this version + var ErrAlreadyExists = errors.New("persistence: already exists") + var ErrFailedPrecondition = errors.New("persistence: failed precondition") + var ErrNotFound = errors.New("persistence: not found") + var ErrPersistenceRetry = errors.New("persistence: retry status") + type Interface interface + AcquireLock func(ctx context.Context, key string, value string, ttl time.Duration) (bool, error) + CreateActor func(ctx context.Context, actor *ateapipb.Actor) error + CreateWorker func(ctx context.Context, worker *ateapipb.Worker) error + DebugClearAll func(ctx context.Context) error + DeleteActor func(ctx context.Context, id string) error + DeleteWorker func(ctx context.Context, namespace, pool, pod string) error + GetActor func(ctx context.Context, id string) (*ateapipb.Actor, error) + GetWorker func(ctx context.Context, namespace, pool, pod string) (*ateapipb.Worker, error) + ListActors func(ctx context.Context) ([]*ateapipb.Actor, error) + ListWorkers func(ctx context.Context) ([]*ateapipb.Worker, error) + ReleaseLock func(ctx context.Context, key string, value string) error + UpdateActor func(ctx context.Context, actor *ateapipb.Actor, expectedVersion int64) error + UpdateWorker func(ctx context.Context, worker *ateapipb.Worker, expectedVersion int64) error
Go to main page