Versions in this module Expand all Collapse all v0 v0.0.0 May 19, 2026 Changes in this version + var ErrWorkerPodNotFound = errors.New("worker pod not found") + func AteletInformer(kc kubernetes.Interface) (informers.SharedInformerFactory, cache.SharedIndexInformer) + func RunWorkflow[Params any, Context any](ctx context.Context, params Params, wCtx Context, ...) error + func StatusErrorInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error) + func WorkerPodInformer(kc kubernetes.Interface) (informers.SharedInformerFactory, cache.SharedIndexInformer) + type ActorWorkflow struct + func NewActorWorkflow(store store.Interface, dialer *AteletDialer, ...) *ActorWorkflow + func (w *ActorWorkflow) ResumeActor(ctx context.Context, id string, boot bool) (*ateapipb.Actor, error) + func (w *ActorWorkflow) SuspendActor(ctx context.Context, id string) (*ateapipb.Actor, error) + type AssignWorkerStep struct + func (s *AssignWorkerStep) Execute(ctx context.Context, input *ResumeInput, state *ResumeState) error + func (s *AssignWorkerStep) IsComplete(ctx context.Context, input *ResumeInput, state *ResumeState) (bool, error) + func (s *AssignWorkerStep) Name() string + func (s *AssignWorkerStep) RetryBackoff() *wait.Backoff + type AteletDialer struct + func NewAteletDialer(workerIndexer cache.Indexer, ateletIndexer cache.Indexer) *AteletDialer + func (d *AteletDialer) DialForWorker(workerPodNamespace, workerPodName string) (*grpc.ClientConn, error) + type CallAteletRestoreStep struct + func (s *CallAteletRestoreStep) Execute(ctx context.Context, input *ResumeInput, state *ResumeState) error + func (s *CallAteletRestoreStep) IsComplete(ctx context.Context, input *ResumeInput, state *ResumeState) (bool, error) + func (s *CallAteletRestoreStep) Name() string + func (s *CallAteletRestoreStep) RetryBackoff() *wait.Backoff + type CallAteletSuspendStep struct + func (s *CallAteletSuspendStep) Execute(ctx context.Context, input *SuspendInput, state *SuspendState) error + func (s *CallAteletSuspendStep) IsComplete(ctx context.Context, input *SuspendInput, state *SuspendState) (bool, error) + func (s *CallAteletSuspendStep) Name() string + func (s *CallAteletSuspendStep) RetryBackoff() *wait.Backoff + type FinalizeRunningStep struct + func (s *FinalizeRunningStep) Execute(ctx context.Context, input *ResumeInput, state *ResumeState) error + func (s *FinalizeRunningStep) IsComplete(ctx context.Context, input *ResumeInput, state *ResumeState) (bool, error) + func (s *FinalizeRunningStep) Name() string + func (s *FinalizeRunningStep) RetryBackoff() *wait.Backoff + type FinalizeSuspendedStep struct + func (s *FinalizeSuspendedStep) Execute(ctx context.Context, input *SuspendInput, state *SuspendState) error + func (s *FinalizeSuspendedStep) IsComplete(ctx context.Context, input *SuspendInput, state *SuspendState) (bool, error) + func (s *FinalizeSuspendedStep) Name() string + func (s *FinalizeSuspendedStep) RetryBackoff() *wait.Backoff + type LoadActorForResumeStep struct + func (s *LoadActorForResumeStep) Execute(ctx context.Context, input *ResumeInput, state *ResumeState) error + func (s *LoadActorForResumeStep) IsComplete(ctx context.Context, input *ResumeInput, state *ResumeState) (bool, error) + func (s *LoadActorForResumeStep) Name() string + func (s *LoadActorForResumeStep) RetryBackoff() *wait.Backoff + type LoadActorForSuspendStep struct + func (s *LoadActorForSuspendStep) Execute(ctx context.Context, input *SuspendInput, state *SuspendState) error + func (s *LoadActorForSuspendStep) IsComplete(ctx context.Context, input *SuspendInput, state *SuspendState) (bool, error) + func (s *LoadActorForSuspendStep) Name() string + func (s *LoadActorForSuspendStep) RetryBackoff() *wait.Backoff + type MarkSuspendingStep struct + func (s *MarkSuspendingStep) Execute(ctx context.Context, input *SuspendInput, state *SuspendState) error + func (s *MarkSuspendingStep) IsComplete(ctx context.Context, input *SuspendInput, state *SuspendState) (bool, error) + func (s *MarkSuspendingStep) Name() string + func (s *MarkSuspendingStep) RetryBackoff() *wait.Backoff + type ResumeInput struct + ActorID string + Boot bool + type ResumeState struct + Actor *ateapipb.Actor + ActorTemplate *atev1alpha1.ActorTemplate + type Service struct + func NewService(persistence store.Interface, ...) *Service + func (s *Service) CreateActor(ctx context.Context, req *ateapipb.CreateActorRequest) (*ateapipb.CreateActorResponse, error) + func (s *Service) DebugClear(ctx context.Context, req *ateapipb.DebugClearRequest) (*ateapipb.DebugClearResponse, error) + func (s *Service) DeleteActor(ctx context.Context, req *ateapipb.DeleteActorRequest) (*ateapipb.DeleteActorResponse, error) + func (s *Service) GetActor(ctx context.Context, req *ateapipb.GetActorRequest) (*ateapipb.GetActorResponse, error) + func (s *Service) ListActors(ctx context.Context, req *ateapipb.ListActorsRequest) (*ateapipb.ListActorsResponse, error) + func (s *Service) ListWorkers(ctx context.Context, req *ateapipb.ListWorkersRequest) (*ateapipb.ListWorkersResponse, error) + func (s *Service) ResumeActor(ctx context.Context, req *ateapipb.ResumeActorRequest) (*ateapipb.ResumeActorResponse, error) + func (s *Service) SuspendActor(ctx context.Context, req *ateapipb.SuspendActorRequest) (*ateapipb.SuspendActorResponse, error) + type SuspendInput struct + ActorID string + type SuspendState struct + Actor *ateapipb.Actor + ActorTemplate *atev1alpha1.ActorTemplate + type WorkerPoolSyncer struct + func NewWorkerPoolSyncer(persistence store.Interface, workerInformer cache.SharedIndexInformer) *WorkerPoolSyncer + func (s *WorkerPoolSyncer) Start(ctx context.Context) + type WorkflowStep interface + Execute func(ctx context.Context, params Params, wCtx Context) error + IsComplete func(ctx context.Context, params Params, wCtx Context) (bool, error) + Name func() string + RetryBackoff func() *wait.Backoff
Go to main page