Versions in this module Expand all Collapse all v0 v0.1.0 Sep 9, 2026 Changes in this version + var ErrUnavailable = errors.New("PostgreSQL is unavailable") + type Persistence struct + func Connect(ctx context.Context, dsn, schema string) (*Persistence, error) + func NewPersistence(ctx context.Context, pool *pgxpool.Pool) (*Persistence, error) + func (p *Persistence) AcquireLease(ctx context.Context, key string) (*store.Lease, error) + func (p *Persistence) BindActorToWorker(ctx context.Context, workerName string, assignment *ateapipb.ActorAssignment, ...) error + func (p *Persistence) Close() + func (p *Persistence) CreateActor(ctx context.Context, actor *ateapipb.Actor) (*ateapipb.Actor, error) + func (p *Persistence) CreateActorTemplate(ctx context.Context, template *ateapipb.ActorTemplate) (*ateapipb.ActorTemplate, error) + func (p *Persistence) CreateAtespace(ctx context.Context, atespace *ateapipb.Atespace) (*ateapipb.Atespace, error) + func (p *Persistence) CreateEgressPolicy(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.EgressPolicy, error) + func (p *Persistence) CreateTag(ctx context.Context, tag *ateapipb.Tag) (*ateapipb.Tag, error) + func (p *Persistence) CreateWorker(ctx context.Context, worker *ateapipb.Worker) (*ateapipb.Worker, error) + func (p *Persistence) DeleteActor(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + func (p *Persistence) DeleteActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + func (p *Persistence) DeleteAtespace(ctx context.Context, name string) (*ateapipb.Atespace, error) + func (p *Persistence) DeleteEgressPolicy(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + func (p *Persistence) DeleteTag(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + func (p *Persistence) DeleteWorker(ctx context.Context, name string, pre store.DeletePreconditions) (*ateapipb.Worker, error) + func (p *Persistence) FindWorkerHostingActor(ctx context.Context, actorUID string) (string, error) + func (p *Persistence) GetActor(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + func (p *Persistence) GetActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + func (p *Persistence) GetAtespace(ctx context.Context, name string) (*ateapipb.Atespace, error) + func (p *Persistence) GetEgressPolicy(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + func (p *Persistence) GetTag(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + func (p *Persistence) GetWorker(ctx context.Context, name string) (*ateapipb.Worker, error) + func (p *Persistence) GetWorkerAssignment(ctx context.Context, workerName, actorUID string) (*ateapipb.ActorAssignment, error) + func (p *Persistence) ListActorTemplates(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.ActorTemplate], error) + func (p *Persistence) ListActors(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.Actor], error) + func (p *Persistence) ListAtespaces(ctx context.Context, opts store.ListOptions) (store.ListResponse[*ateapipb.Atespace], error) + func (p *Persistence) ListTags(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.Tag], error) + func (p *Persistence) ListWorkerAssignments(ctx context.Context, workerName string, opts store.ListOptions) (store.ListResponse[*ateapipb.ActorAssignment], error) + func (p *Persistence) ListWorkers(ctx context.Context, opts store.ListOptions) (store.ListResponse[*ateapipb.Worker], error) + func (p *Persistence) ReleaseActorFromWorker(ctx context.Context, workerName string, actorUID string) (*ateapipb.Worker, error) + func (p *Persistence) UpdateActor(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.Actor, error) + func (p *Persistence) UpdateActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef, ...) (*ateapipb.ActorTemplate, error) + func (p *Persistence) UpdateEgressPolicy(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.EgressPolicy, error) + func (p *Persistence) UpdateTag(ctx context.Context, tagRef resources.TagRef, precondition store.Precondition, ...) (*ateapipb.Tag, error) + func (p *Persistence) UpdateWorker(ctx context.Context, name string, precondition store.Precondition, ...) (*ateapipb.Worker, error) + func (p *Persistence) WatchWorkers(ctx context.Context) (*store.WorkerWatch, error)
Go to main page