Versions in this module Expand all Collapse all v0 v0.1.0 Sep 9, 2026 Changes in this version + var ErrNoAteletOnNode = errors.New("no atelet pod found on node") + var ErrWorkerPodNotFound = errors.New("worker pod not found") + func AteletInformer(kc kubernetes.Interface) (informers.SharedInformerFactory, cache.SharedIndexInformer) + func RegisterActorCrashes(meter metric.Meter) error + func RegisterWorkerCount(meter metric.Meter, workers func() ([]*ateapipb.Worker, error), ...) error + func ValidateCustom_Capabilities_Add(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_Capabilities_Drop(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_Container_VolumeMounts(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_CreateActorEgressPolicyRequest(_ context.Context, _ operation.Operation, p *field.Path, ...) field.ErrorList + func ValidateCustom_CreateActorTemplateRequest_ActorTemplate(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_CreateTagRequest(_ context.Context, _ operation.Operation, p *field.Path, ...) field.ErrorList + func ValidateCustom_CredentialHeaderInjection_CredentialUri(_ context.Context, _ operation.Operation, p *field.Path, uri, _ *string) field.ErrorList + func ValidateCustom_CredentialHeaderInjection_Header(_ context.Context, _ operation.Operation, p *field.Path, header, _ *string) field.ErrorList + func ValidateCustom_CredentialHeaderInjection_Prefix(_ context.Context, _ operation.Operation, p *field.Path, prefix, _ *string) field.ErrorList + func ValidateCustom_EgressPolicy_Metadata(_ context.Context, _ operation.Operation, root *field.Path, ...) field.ErrorList + func ValidateCustom_EgressRuleEffects(_ context.Context, _ operation.Operation, p *field.Path, ...) field.ErrorList + func ValidateCustom_EgressRuleEffects_InjectStaticHeaders(_ context.Context, _ operation.Operation, p *field.Path, ...) field.ErrorList + func ValidateCustom_EnvVar_Name(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_ExternalVolumeTemplate_Capacity(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_ExternalVolume_StorageVolumeId(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_ExternalVolume_VolumeType(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_HTTPGetAction_Path(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_HostnameRule_Patterns(_ context.Context, _ operation.Operation, p *field.Path, patterns, _ []string) field.ErrorList + func ValidateCustom_IPBlockRule_Cidrs(_ context.Context, _ operation.Operation, p *field.Path, cidrs, _ []string) field.ErrorList + func ValidateCustom_ImageVolumeSource_Reference(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_MintCertRequest_CertificateSigningRequest(_ context.Context, _ operation.Operation, fldPath *field.Path, value, _ []byte) field.ErrorList + func ValidateCustom_Resources_Limits(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_SnapshotsConfig(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_UpdateActorEgressPolicyRequest(_ context.Context, _ operation.Operation, p *field.Path, ...) field.ErrorList + func ValidateCustom_UpdateActorRequest_Actor(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_UpdateTagRequest_Tag(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_UpdateWorkerRequest_Worker(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_VolumeMount_MountPath(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_WorkerAssignment_WorkerPodIp(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func ValidateCustom_Worker_Ip(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList + func Validate_Actor(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ActorMetadataDataSource(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ActorMetadataItem(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ActorStatus(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ActorTemplate(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ActorTemplateStatus(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Atespace(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Capabilities(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Container(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ContainerReadyz(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateActorEgressPolicyRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateActorTemplateRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateAtespaceRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateTagRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CreateWorkerRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_CredentialHeaderInjection(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteActorEgressPolicyRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteActorTemplateRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteAtespaceRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteOptions(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteTagRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DeleteWorkerRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_DrainWorkerRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_EgressPolicy(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_EgressRule(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_EgressRuleEffects(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_EnvVar(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ExternalSnapshot(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ExternalVolume(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ExternalVolumeTemplate(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetActorEgressPolicyRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetActorTemplateRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetAtespaceRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetTagRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GetWorkerRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_GoldenSnapshotStatus(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_HTTPGetAction(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_HostnameRule(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_IPBlockRule(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ImageVolumeSource(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Limits(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListActorTemplatesRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListActorsRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListAtespacesRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListTagsRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListWorkerActorAssignmentsRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ListWorkersRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_LocalSnapshotInfo(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_MintCertRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_MintJWTRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ObjectRef(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_OnResumeConfig(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_PauseActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ResourceMetadata(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Resources(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_ResumeActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SandboxConfig(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SecurityContext(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Selector(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SetWorkerCapacityRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SnapshotsConfig(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SuspendActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SystemInfoDataSource(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_SystemInfoVolumeSource(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Tag(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_TagStatus(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_TrustBundleDataSource(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_UpdateActorEgressPolicyRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_UpdateActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_UpdateTagRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_UpdateWorkerRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Volume(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_VolumeMount(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_Worker(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_WorkerAssignment(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_WorkerResources(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func Validate_WorkerStatus(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList) + func WorkerPodInformer(kc kubernetes.Interface) (informers.SharedInformerFactory, cache.SharedIndexInformer) + type ActorTemplateReconciler struct + func NewActorTemplateReconciler(persistence templateReconcilerStore, control goldenActorControl) *ActorTemplateReconciler + func (r *ActorTemplateReconciler) Start(ctx context.Context) + type ActorWorkflow struct + func NewActorWorkflow(store actorWorkflowStore, workerCache *workercache.Cache, dialer *AteletDialer, ...) *ActorWorkflow + func (w *ActorWorkflow) DeleteActor(ctx context.Context, actorRef resources.ActorRef, anyState bool) (*ateapipb.Actor, error) + func (w *ActorWorkflow) PauseActor(ctx context.Context, actorRef resources.ActorRef) (_ *ateapipb.Actor, err error) + func (w *ActorWorkflow) ResumeActor(ctx context.Context, actorRef resources.ActorRef, boot bool) (_ *ateapipb.Actor, resumed bool, err error) + func (w *ActorWorkflow) SuspendActor(ctx context.Context, actorRef resources.ActorRef) (_ *ateapipb.Actor, err error) + func (w *ActorWorkflow) TagActorSnapshot(ctx context.Context, tag *ateapipb.Tag) (*ateapipb.Tag, error) + type AteletDialer struct + func NewAteletDialer(workerIndexer cache.Indexer, ateletIndexer cache.Indexer, ...) *AteletDialer + func (d *AteletDialer) DialForAteletOnNode(nodeName string) (*grpc.ClientConn, error) + func (d *AteletDialer) DialForWorker(workerPodNamespace, workerPodName string) (*grpc.ClientConn, error) + type DialerOption func(*AteletDialer) + func WithDialCredentials(build func(expectedPodUID string) (credentials.TransportCredentials, error)) DialerOption + type Instruments struct + func NewInstruments(meter metric.Meter) (*Instruments, error) + type RPCService struct + func NewRPCService(persistence store.Interface, workerCache *workercache.Cache, ...) *RPCService + func (s *RPCService) CreateActor(ctx context.Context, req *ateapipb.CreateActorRequest) (created *ateapipb.Actor, err error) + func (s *RPCService) CreateActorEgressPolicy(ctx context.Context, req *ateapipb.CreateActorEgressPolicyRequest) (*ateapipb.EgressPolicy, error) + func (s *RPCService) CreateActorTemplate(ctx context.Context, req *ateapipb.CreateActorTemplateRequest) (*ateapipb.ActorTemplate, error) + func (s *RPCService) CreateAtespace(ctx context.Context, req *ateapipb.CreateAtespaceRequest) (*ateapipb.Atespace, error) + func (s *RPCService) CreateTag(ctx context.Context, req *ateapipb.CreateTagRequest) (*ateapipb.Tag, error) + func (s *RPCService) CreateWorker(ctx context.Context, req *ateapipb.CreateWorkerRequest) (*ateapipb.Worker, error) + func (s *RPCService) DeleteActor(ctx context.Context, req *ateapipb.DeleteActorRequest) (deleted *ateapipb.Actor, err error) + func (s *RPCService) DeleteActorEgressPolicy(ctx context.Context, req *ateapipb.DeleteActorEgressPolicyRequest) (*ateapipb.EgressPolicy, error) + func (s *RPCService) DeleteActorTemplate(ctx context.Context, req *ateapipb.DeleteActorTemplateRequest) (*ateapipb.ActorTemplate, error) + func (s *RPCService) DeleteAtespace(ctx context.Context, req *ateapipb.DeleteAtespaceRequest) (*ateapipb.Atespace, error) + func (s *RPCService) DeleteTag(ctx context.Context, req *ateapipb.DeleteTagRequest) (*ateapipb.Tag, error) + func (s *RPCService) DeleteWorker(ctx context.Context, req *ateapipb.DeleteWorkerRequest) (*ateapipb.Worker, error) + func (s *RPCService) DrainWorker(ctx context.Context, req *ateapipb.DrainWorkerRequest) (*ateapipb.Worker, error) + func (s *RPCService) GetActor(ctx context.Context, req *ateapipb.GetActorRequest) (*ateapipb.Actor, error) + func (s *RPCService) GetActorEgressPolicy(ctx context.Context, req *ateapipb.GetActorEgressPolicyRequest) (*ateapipb.EgressPolicy, error) + func (s *RPCService) GetActorTemplate(ctx context.Context, req *ateapipb.GetActorTemplateRequest) (*ateapipb.ActorTemplate, error) + func (s *RPCService) GetAtespace(ctx context.Context, req *ateapipb.GetAtespaceRequest) (*ateapipb.Atespace, error) + func (s *RPCService) GetPlugin(ctx context.Context, driverName string) (volume.VolumePluginControlPlane, error) + func (s *RPCService) GetTag(ctx context.Context, req *ateapipb.GetTagRequest) (*ateapipb.Tag, error) + func (s *RPCService) GetWorker(ctx context.Context, req *ateapipb.GetWorkerRequest) (*ateapipb.Worker, error) + func (s *RPCService) ListActorTemplates(ctx context.Context, req *ateapipb.ListActorTemplatesRequest) (*ateapipb.ListActorTemplatesResponse, error) + func (s *RPCService) ListActors(ctx context.Context, req *ateapipb.ListActorsRequest) (*ateapipb.ListActorsResponse, error) + func (s *RPCService) ListAtespaces(ctx context.Context, req *ateapipb.ListAtespacesRequest) (*ateapipb.ListAtespacesResponse, error) + func (s *RPCService) ListTags(ctx context.Context, req *ateapipb.ListTagsRequest) (*ateapipb.ListTagsResponse, error) + func (s *RPCService) ListWorkerActorAssignments(ctx context.Context, req *ateapipb.ListWorkerActorAssignmentsRequest) (*ateapipb.ListWorkerActorAssignmentsResponse, error) + func (s *RPCService) ListWorkers(ctx context.Context, req *ateapipb.ListWorkersRequest) (*ateapipb.ListWorkersResponse, error) + func (s *RPCService) PauseActor(ctx context.Context, req *ateapipb.PauseActorRequest) (*ateapipb.PauseActorResponse, error) + func (s *RPCService) ResumeActor(ctx context.Context, req *ateapipb.ResumeActorRequest) (*ateapipb.ResumeActorResponse, error) + func (s *RPCService) SuspendActor(ctx context.Context, req *ateapipb.SuspendActorRequest) (*ateapipb.SuspendActorResponse, error) + func (s *RPCService) UpdateActor(ctx context.Context, req *ateapipb.UpdateActorRequest) (*ateapipb.Actor, error) + func (s *RPCService) UpdateActorEgressPolicy(ctx context.Context, req *ateapipb.UpdateActorEgressPolicyRequest) (*ateapipb.EgressPolicy, error) + func (s *RPCService) UpdateTag(ctx context.Context, req *ateapipb.UpdateTagRequest) (*ateapipb.Tag, error) + func (s *RPCService) UpdateWorker(ctx context.Context, req *ateapipb.UpdateWorkerRequest) (*ateapipb.Worker, error) + type ServiceImpl struct + func (s *ServiceImpl) AcquireLease(ctx context.Context, key string) (*store.Lease, error) + func (s *ServiceImpl) BindActorToWorker(ctx context.Context, workerName string, assignment *ateapipb.ActorAssignment, ...) error + func (s *ServiceImpl) CreateActor(ctx context.Context, inActor *ateapipb.Actor) (*ateapipb.Actor, error) + func (s *ServiceImpl) CreateActorTemplate(ctx context.Context, inTemplate *ateapipb.ActorTemplate) (*ateapipb.ActorTemplate, error) + func (s *ServiceImpl) CreateAtespace(ctx context.Context, inAtespace *ateapipb.Atespace) (*ateapipb.Atespace, error) + func (s *ServiceImpl) CreateEgressPolicy(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.EgressPolicy, error) + func (s *ServiceImpl) CreateTag(ctx context.Context, tag *ateapipb.Tag) (*ateapipb.Tag, error) + func (s *ServiceImpl) CreateWorker(ctx context.Context, inWorker *ateapipb.Worker) (*ateapipb.Worker, error) + func (s *ServiceImpl) DeleteActor(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + func (s *ServiceImpl) DeleteActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + func (s *ServiceImpl) DeleteAtespace(ctx context.Context, name string) (*ateapipb.Atespace, error) + func (s *ServiceImpl) DeleteEgressPolicy(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + func (s *ServiceImpl) DeleteTag(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + func (s *ServiceImpl) DeleteWorker(ctx context.Context, name string, pre store.DeletePreconditions) (*ateapipb.Worker, error) + func (s *ServiceImpl) FindWorkerHostingActor(ctx context.Context, actorUID string) (string, error) + func (s *ServiceImpl) GetActor(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.Actor, error) + func (s *ServiceImpl) GetActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef) (*ateapipb.ActorTemplate, error) + func (s *ServiceImpl) GetAtespace(ctx context.Context, name string) (*ateapipb.Atespace, error) + func (s *ServiceImpl) GetEgressPolicy(ctx context.Context, actorRef resources.ActorRef) (*ateapipb.EgressPolicy, error) + func (s *ServiceImpl) GetTag(ctx context.Context, tagRef resources.TagRef) (*ateapipb.Tag, error) + func (s *ServiceImpl) GetWorker(ctx context.Context, name string) (*ateapipb.Worker, error) + func (s *ServiceImpl) GetWorkerAssignment(ctx context.Context, workerName, actorUID string) (*ateapipb.ActorAssignment, error) + func (s *ServiceImpl) ListActorTemplates(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.ActorTemplate], error) + func (s *ServiceImpl) ListActors(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.Actor], error) + func (s *ServiceImpl) ListAtespaces(ctx context.Context, opts store.ListOptions) (store.ListResponse[*ateapipb.Atespace], error) + func (s *ServiceImpl) ListTags(ctx context.Context, atespace string, opts store.ListOptions) (store.ListResponse[*ateapipb.Tag], error) + func (s *ServiceImpl) ListWorkerAssignments(ctx context.Context, workerName string, opts store.ListOptions) (store.ListResponse[*ateapipb.ActorAssignment], error) + func (s *ServiceImpl) ListWorkers(ctx context.Context, opts store.ListOptions) (store.ListResponse[*ateapipb.Worker], error) + func (s *ServiceImpl) ReleaseActorFromWorker(ctx context.Context, workerName string, actorUID string) (*ateapipb.Worker, error) + func (s *ServiceImpl) UpdateActor(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.Actor, error) + func (s *ServiceImpl) UpdateActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef, ...) (*ateapipb.ActorTemplate, error) + func (s *ServiceImpl) UpdateEgressPolicy(ctx context.Context, actorRef resources.ActorRef, ...) (*ateapipb.EgressPolicy, error) + func (s *ServiceImpl) UpdateTag(ctx context.Context, tagRef resources.TagRef, precondition store.Precondition, ...) (*ateapipb.Tag, error) + func (s *ServiceImpl) UpdateWorker(ctx context.Context, name string, precondition store.Precondition, ...) (*ateapipb.Worker, error) + func (s *ServiceImpl) WatchWorkers(ctx context.Context) (*store.WorkerWatch, error) + type VolumePluginRegistry interface + GetPlugin func(ctx context.Context, name string) (volume.VolumePluginControlPlane, error) + type WorkerWorkflow struct + func NewWorkerWorkflow(store workerWorkflowStore) *WorkerWorkflow + func (w *WorkerWorkflow) DeleteWorker(ctx context.Context, name string, pre store.DeletePreconditions) (*ateapipb.Worker, error)
Go to main page