Versions in this module Expand all Collapse all v0 v0.1.0 Sep 9, 2026 Changes in this version + const DefaultPageSize + var ErrAlreadyExists = errors.New("persistence: already exists") + var ErrFailedPrecondition = errors.New("persistence: failed precondition") + var ErrImmutableField = errors.New("persistence: immutable field") + var ErrInvalidPageSize = errors.New("persistence: invalid page size") + var ErrInvalidPageToken = errors.New("persistence: invalid page token") + var ErrLeaseConflict = errors.New("persistence: lease conflict") + var ErrNotFound = errors.New("persistence: not found") + var ErrPreconditionRequired = errors.New("persistence: precondition required") + var ErrUIDConflict = errors.New("persistence: uid conflict") + var ErrVersionConflict = errors.New("persistence: version conflict") + type DeletePreconditions struct + UID string + Version int64 + func (p DeletePreconditions) Check(md *ateapipb.ResourceMetadata) error + type Interface interface + AcquireLease func(ctx context.Context, key string) (*Lease, error) + BindActorToWorker func(ctx context.Context, workerName string, assignment *ateapipb.ActorAssignment, ...) error + CreateActor func(ctx context.Context, actor *ateapipb.Actor) (*ateapipb.Actor, error) + CreateActorTemplate func(ctx context.Context, template *ateapipb.ActorTemplate) (*ateapipb.ActorTemplate, error) + CreateAtespace func(ctx context.Context, atespace *ateapipb.Atespace) (*ateapipb.Atespace, error) + CreateEgressPolicy func(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.EgressPolicy, error) + CreateTag func(ctx context.Context, tag *ateapipb.Tag) (*ateapipb.Tag, error) + CreateWorker func(ctx context.Context, worker *ateapipb.Worker) (*ateapipb.Worker, error) + DeleteActor func(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + DeleteActorTemplate func(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + DeleteAtespace func(ctx context.Context, name string) (*ateapipb.Atespace, error) + DeleteEgressPolicy func(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + DeleteTag func(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + DeleteWorker func(ctx context.Context, name string, pre DeletePreconditions) (*ateapipb.Worker, error) + FindWorkerHostingActor func(ctx context.Context, actorUID string) (string, error) + GetActor func(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + GetActorTemplate func(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + GetAtespace func(ctx context.Context, name string) (*ateapipb.Atespace, error) + GetEgressPolicy func(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + GetTag func(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + GetWorker func(ctx context.Context, name string) (*ateapipb.Worker, error) + GetWorkerAssignment func(ctx context.Context, workerName, actorUID string) (*ateapipb.ActorAssignment, error) + ListActorTemplates func(ctx context.Context, atespace string, opts ListOptions) (ListResponse[*ateapipb.ActorTemplate], error) + ListActors func(ctx context.Context, atespace string, opts ListOptions) (ListResponse[*ateapipb.Actor], error) + ListAtespaces func(ctx context.Context, opts ListOptions) (ListResponse[*ateapipb.Atespace], error) + ListTags func(ctx context.Context, atespace string, opts ListOptions) (ListResponse[*ateapipb.Tag], error) + ListWorkerAssignments func(ctx context.Context, workerName string, opts ListOptions) (ListResponse[*ateapipb.ActorAssignment], error) + ListWorkers func(ctx context.Context, opts ListOptions) (ListResponse[*ateapipb.Worker], error) + ReleaseActorFromWorker func(ctx context.Context, workerName string, actorUID string) (*ateapipb.Worker, error) + UpdateActor func(ctx context.Context, actorRef resources.ActorRef, precondition Precondition, ...) (*ateapipb.Actor, error) + UpdateActorTemplate func(ctx context.Context, templateRef resources.ActorTemplateRef, ...) (*ateapipb.ActorTemplate, error) + UpdateEgressPolicy func(ctx context.Context, actorRef resources.ActorRef, precondition Precondition, ...) (*ateapipb.EgressPolicy, error) + UpdateTag func(ctx context.Context, tagRef resources.TagRef, precondition Precondition, ...) (*ateapipb.Tag, error) + UpdateWorker func(ctx context.Context, name string, precondition Precondition, ...) (*ateapipb.Worker, error) + WatchWorkers func(ctx context.Context) (*WorkerWatch, error) + type Lease struct + func NewLease(ctx context.Context, closeFn func()) *Lease + func (l *Lease) Close() + func (l *Lease) Context() context.Context + type ListOptions struct + PageSize int32 + PageToken string + func NormalizeListOptions(opts ListOptions) (ListOptions, error) + type ListResponse struct + Items []T + NextPageToken string + func (r ListResponse[T]) HasNextPage() bool + type Precondition struct + UID string + Version int64 + func PreconditionFrom(observed hasResourceMetadata) Precondition + func (p Precondition) Check(md *ateapipb.ResourceMetadata) error + func (p Precondition) Validate() error + type WorkerEvent struct + Type WorkerEventType + Worker *ateapipb.Worker + type WorkerEventType int + const WorkerEventCreated + const WorkerEventDeleted + const WorkerEventUpdated + type WorkerWatch struct + Events <-chan WorkerEvent + func NewWorkerWatch(events <-chan WorkerEvent, stop context.CancelFunc) *WorkerWatch + func (w *WorkerWatch) Close()
Go to main page