controlapi

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 14, 2026

Changes in this version

+ func HostingNode(ctx context.Context, st store.Interface, actor *ateapipb.Actor) (string, error)

type RPCService

+ func (s *RPCService) MarkWorkerAvailable(ctx context.Context, req *ateapipb.MarkWorkerAvailableRequest) (*ateapipb.MarkWorkerAvailableResponse, error)

+ func (s *RPCService) MarkWorkerUnavailable(ctx context.Context, req *ateapipb.MarkWorkerUnavailableRequest) (*ateapipb.MarkWorkerUnavailableResponse, error)

+ func (s *RPCService) MintActorJwt(ctx context.Context, req *ateapipb.MintActorJwtRequest) (*ateapipb.MintActorJwtResponse, error)

v0.4.0

Oct 7, 2026

Changes in this version

type RPCService

+ func (s *RPCService) CreateAtespaceAccessPolicy(ctx context.Context, req *ateapipb.CreateAtespaceAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) CreateGlobalAccessPolicy(ctx context.Context, req *ateapipb.CreateGlobalAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) DeleteAtespaceAccessPolicy(ctx context.Context, req *ateapipb.DeleteAtespaceAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) GetAtespaceAccessPolicy(ctx context.Context, req *ateapipb.GetAtespaceAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) GetGlobalAccessPolicy(ctx context.Context, req *ateapipb.GetGlobalAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) UpdateAtespaceAccessPolicy(ctx context.Context, req *ateapipb.UpdateAtespaceAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

+ func (s *RPCService) UpdateGlobalAccessPolicy(ctx context.Context, req *ateapipb.UpdateGlobalAccessPolicyRequest) (*ateapipb.AccessPolicy, error)

type ServiceImpl

+ func (s *ServiceImpl) CreateAtespaceAccessPolicy(ctx context.Context, name string, policy *ateapipb.AccessPolicy) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) CreateGlobalAccessPolicy(ctx context.Context, policy *ateapipb.AccessPolicy) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) DeleteAtespaceAccessPolicy(ctx context.Context, name string, precondition store.DeletePreconditions) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) GetAtespaceAccessPolicy(ctx context.Context, name string) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) GetGlobalAccessPolicy(ctx context.Context) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) UpdateAtespaceAccessPolicy(ctx context.Context, name string, precondition store.Precondition, ...) (*ateapipb.AccessPolicy, error)

+ func (s *ServiceImpl) UpdateGlobalAccessPolicy(ctx context.Context, precondition store.Precondition, ...) (*ateapipb.AccessPolicy, error)

+ type WorkerAssignmentReconciler struct

+ func NewWorkerAssignmentReconciler(persistence workerWorkflowStore, workers workerWatcher) *WorkerAssignmentReconciler

+ func (r *WorkerAssignmentReconciler) Start(ctx context.Context)

type WorkerWorkflow

+ func (w *WorkerWorkflow) ReconcileAssignments(ctx context.Context, name string) (err error)

v0.3.0

Sep 30, 2026

v0.2.0

Sep 25, 2026

Changes in this version

+ func ValidateCustom_ActorMetadataItem_Path(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_CIDRRule_Cidrs(_ context.Context, _ operation.Operation, p *field.Path, cidrs, _ []string) field.ErrorList

+ func ValidateCustom_Container_Image(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_ResourceMetadata(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_SnapshotConfig(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_SnapshotConfig_StorageLocation(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_SystemInfoVolumeSource_DataSources(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func ValidateCustom_TrustBundleDataSource_Path(_ context.Context, _ operation.Operation, fldPath *field.Path, ...) field.ErrorList

+ func Validate_ActorCrash(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_CIDRRule(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_ContainerWakeupProbe(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_LocalSnapshot(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_MintActorCertificateRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_MintActorJWTRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_MintAteomActorCertificateRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_RequestActorSuspendRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_RevertActorRequest(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

+ func Validate_SnapshotConfig(ctx context.Context, op operation.Operation, fldPath *field.Path, ...) (errs field.ErrorList)

type ActorWorkflow

+ func (w *ActorWorkflow) DeleteActorTemplate(ctx context.Context, templateRef resources.ActorTemplateRef, ...) (*ateapipb.ActorTemplate, error)

+ func (w *ActorWorkflow) DeleteTag(ctx context.Context, tagRef resources.TagRef, ...) (*ateapipb.Tag, error)

+ func (w *ActorWorkflow) RevertActor(ctx context.Context, actorRef resources.ActorRef) (_ *ateapipb.Actor, err error)

type RPCService

+ func (s *RPCService) MintActorCertificate(ctx context.Context, req *ateapipb.MintActorCertificateRequest) (*ateapipb.MintActorCertificateResponse, error)

+ func (s *RPCService) MintActorJWT(ctx context.Context, req *ateapipb.MintActorJWTRequest) (*ateapipb.MintActorJWTResponse, error)

+ func (s *RPCService) RevertActor(ctx context.Context, req *ateapipb.RevertActorRequest) (*ateapipb.RevertActorResponse, error)

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL