ateapipb

type Actor struct {
	ActorId                string        `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Version                int64         `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	ActorTemplateNamespace string        `` /* 129-byte string literal not displayed */
	ActorTemplateName      string        `protobuf:"bytes,4,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	Status                 Actor_Status  `protobuf:"varint,5,opt,name=status,proto3,enum=ateapi.Actor_Status" json:"status,omitempty"`
	AteomPodNamespace      string        `protobuf:"bytes,6,opt,name=ateom_pod_namespace,json=ateomPodNamespace,proto3" json:"ateom_pod_namespace,omitempty"`
	AteomPodName           string        `protobuf:"bytes,7,opt,name=ateom_pod_name,json=ateomPodName,proto3" json:"ateom_pod_name,omitempty"`
	AteomPodIp             string        `protobuf:"bytes,8,opt,name=ateom_pod_ip,json=ateomPodIp,proto3" json:"ateom_pod_ip,omitempty"`
	InProgressSnapshot     string        `protobuf:"bytes,10,opt,name=in_progress_snapshot,json=inProgressSnapshot,proto3" json:"in_progress_snapshot,omitempty"`
	AteomPodUid            string        `protobuf:"bytes,11,opt,name=ateom_pod_uid,json=ateomPodUid,proto3" json:"ateom_pod_uid,omitempty"`
	LatestSnapshotInfo     *SnapshotInfo `protobuf:"bytes,12,opt,name=latest_snapshot_info,json=latestSnapshotInfo,proto3" json:"latest_snapshot_info,omitempty"`
	// worker_selector is the per-actor placement constraint. The scheduler
	// evaluates the AND of this selector and the template's workerSelector to
	// find eligible pools. Set at CreateActor; may be updated at any time via
	// UpdateActor. Changes take effect on the next ResumeActor call.
	WorkerSelector *Selector `protobuf:"bytes,13,opt,name=worker_selector,json=workerSelector,proto3" json:"worker_selector,omitempty"`
	// worker_pool_name is the name of the WorkerPool that owns the currently
	// assigned worker, in the same namespace as ateom_pod_namespace (pool and
	// pod namespaces always match). Set by the scheduler at assignment time
	// and cleared when the worker is freed. Needed to release the worker on
	// suspend/pause since eligibility is no longer a single fixed pool
	// reference on the ActorTemplate.
	WorkerPoolName string `protobuf:"bytes,14,opt,name=worker_pool_name,json=workerPoolName,proto3" json:"worker_pool_name,omitempty"`
	// contains filtered or unexported fields
}

type Actor_Status int32

type ControlClient interface {
	// Get an Actor.
	GetActor(ctx context.Context, in *GetActorRequest, opts ...grpc.CallOption) (*GetActorResponse, error)
	// Create a new Actor deriving from a given ActorTemplate.
	CreateActor(ctx context.Context, in *CreateActorRequest, opts ...grpc.CallOption) (*CreateActorResponse, error)
	// Update mutable fields on an existing Actor.
	UpdateActor(ctx context.Context, in *UpdateActorRequest, opts ...grpc.CallOption) (*UpdateActorResponse, error)
	// Suspend a given actor to a new snapshot.
	SuspendActor(ctx context.Context, in *SuspendActorRequest, opts ...grpc.CallOption) (*SuspendActorResponse, error)
	// Pause a given actor and keep its snapshots on node VM.
	PauseActor(ctx context.Context, in *PauseActorRequest, opts ...grpc.CallOption) (*PauseActorResponse, error)
	// Resume an actor from its latest snapshot.
	ResumeActor(ctx context.Context, in *ResumeActorRequest, opts ...grpc.CallOption) (*ResumeActorResponse, error)
	// Delete an actor. Only suspended actors can be deleted.
	DeleteActor(ctx context.Context, in *DeleteActorRequest, opts ...grpc.CallOption) (*DeleteActorResponse, error)
	// List all workers currently reflected in redis.
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	// List all actors currently reflected in redis.
	ListActors(ctx context.Context, in *ListActorsRequest, opts ...grpc.CallOption) (*ListActorsResponse, error)
	// Debugging: drop all data from the ate database.
	DebugClear(ctx context.Context, in *DebugClearRequest, opts ...grpc.CallOption) (*DebugClearResponse, error)
}

type ControlServer interface {
	// Get an Actor.
	GetActor(context.Context, *GetActorRequest) (*GetActorResponse, error)
	// Create a new Actor deriving from a given ActorTemplate.
	CreateActor(context.Context, *CreateActorRequest) (*CreateActorResponse, error)
	// Update mutable fields on an existing Actor.
	UpdateActor(context.Context, *UpdateActorRequest) (*UpdateActorResponse, error)
	// Suspend a given actor to a new snapshot.
	SuspendActor(context.Context, *SuspendActorRequest) (*SuspendActorResponse, error)
	// Pause a given actor and keep its snapshots on node VM.
	PauseActor(context.Context, *PauseActorRequest) (*PauseActorResponse, error)
	// Resume an actor from its latest snapshot.
	ResumeActor(context.Context, *ResumeActorRequest) (*ResumeActorResponse, error)
	// Delete an actor. Only suspended actors can be deleted.
	DeleteActor(context.Context, *DeleteActorRequest) (*DeleteActorResponse, error)
	// List all workers currently reflected in redis.
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	// List all actors currently reflected in redis.
	ListActors(context.Context, *ListActorsRequest) (*ListActorsResponse, error)
	// Debugging: drop all data from the ate database.
	DebugClear(context.Context, *DebugClearRequest) (*DebugClearResponse, error)
	// contains filtered or unexported methods
}

type CreateActorRequest struct {

	// The custom identifier for the new Actor. Must be a valid DNS-1123 label.
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// The namespace of the ActorTemplate to derive from.
	ActorTemplateNamespace string `` /* 129-byte string literal not displayed */
	// The name of the ActorTemplate to derive from.
	ActorTemplateName string `protobuf:"bytes,3,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	// worker_selector sets the actor's placement constraint at creation time.
	// If empty, the actor matches any pool admitted by the template's selector.
	WorkerSelector *Selector `protobuf:"bytes,4,opt,name=worker_selector,json=workerSelector,proto3" json:"worker_selector,omitempty"`
	// contains filtered or unexported fields
}

type CreateActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type DebugClearRequest struct {
	// contains filtered or unexported fields
}

type DebugClearResponse struct {
	// contains filtered or unexported fields
}

type DeleteActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteActorResponse struct {
	// contains filtered or unexported fields
}

type ExternalSnapshotInfo struct {
	SnapshotUriPrefix string `protobuf:"bytes,1,opt,name=snapshot_uri_prefix,json=snapshotUriPrefix,proto3" json:"snapshot_uri_prefix,omitempty"`
	// contains filtered or unexported fields
}

type GetActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// contains filtered or unexported fields
}

type GetActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type ListActorsRequest struct {

	// The maximum number of actors to return. The server may enforce a hard limit
	// (e.g., 1000) regardless of the requested size.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// An opaque pagination token obtained from a previous ListActorsResponse.
	// Empty for the first request.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListActorsResponse struct {

	// The page of actors. This list may be empty even if there are more results.
	Actors []*Actor `protobuf:"bytes,1,rep,name=actors,proto3" json:"actors,omitempty"`
	// An opaque token to retrieve the next page of results.
	// If empty, there are no more results. Clients must loop until this is empty.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListWorkersRequest struct {
	// contains filtered or unexported fields
}

type ListWorkersResponse struct {
	Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type LocalSnapshotInfo struct {
	SnapshotPrefix string `protobuf:"bytes,1,opt,name=snapshot_prefix,json=snapshotPrefix,proto3" json:"snapshot_prefix,omitempty"`
	// Node VMs that have local snapshots for this actor, while it's PAUSED.
	NodeVmsWithLocalSnapshots []string `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MintCertRequest struct {
	AppId     string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	UserId    string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Request contains DER encoded bytes of a x509 certificate signing request.
	// The signer will ignore the contents of the CSR except to extract the
	// subject public key.
	CertificateSigningRequest []byte `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MintCertResponse struct {

	// Response contains a list of DER encoded certificates. The first entry is the
	// leaf certificate, and any remaining entries are intermediates in
	// leaf-to-root order.
	SessionCertificates [][]byte `protobuf:"bytes,1,rep,name=session_certificates,json=sessionCertificates,proto3" json:"session_certificates,omitempty"`
	// contains filtered or unexported fields
}

type MintJWTRequest struct {
	Audience  []string `protobuf:"bytes,1,rep,name=audience,proto3" json:"audience,omitempty"`
	AppId     string   `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	UserId    string   `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	SessionId string   `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type MintJWTResponse struct {

	// Session JWT.  An OIDC Discovery-compatible JWT
	//
	// Claims:
	//
	//   - iss: Issuer - a valid URL where a relying party can fetch the OIDC
	//     discovery documents.
	//   - sub: Subject - a string expressing the identity carried in the
	//
	// credential. Format
	//
	//	`app/${appid}/user/${userid}/session/${sessionid}`.
	//   - aud: Audience - a string identifying the service this token will be used
	//     to authenticate to.
	//   - nbf: Not Before - a numeric unix timestamp
	//   - exp: Expiration - a numeric unix timestamp
	//   - iat: Issued At - a numeric unix timestamp
	//   - `ate.dev`: Ate/Substrate Extension - JSON object
	//   - appID: (string) The Substrate App ID
	//   - userID: (string) The Substrate User ID
	//   - sessionID: (string) The Substrate Session ID
	SessionJwt string `protobuf:"bytes,1,opt,name=session_jwt,json=sessionJwt,proto3" json:"session_jwt,omitempty"`
	// contains filtered or unexported fields
}

type PauseActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// contains filtered or unexported fields
}

type PauseActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type ResumeActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// If true, skip golden snapshot and boot the workload from scratch.
	Boot bool `protobuf:"varint,2,opt,name=boot,proto3" json:"boot,omitempty"`
	// contains filtered or unexported fields
}

type ResumeActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type Selector struct {
	MatchLabels map[string]string `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SessionIdentityClient interface {
	// Request a Session Identity JWT.
	//
	// To call this RPC, you must be authenticated as the Kubernetes Pod that is
	// currently running the requested session.
	MintJWT(ctx context.Context, in *MintJWTRequest, opts ...grpc.CallOption) (*MintJWTResponse, error)
	// Request a Session Identity Certificate. To call this RPC, you must have
	// authenticated with a client certificate, not a bearer token.
	MintCert(ctx context.Context, in *MintCertRequest, opts ...grpc.CallOption) (*MintCertResponse, error)
}

type SessionIdentityServer interface {
	// Request a Session Identity JWT.
	//
	// To call this RPC, you must be authenticated as the Kubernetes Pod that is
	// currently running the requested session.
	MintJWT(context.Context, *MintJWTRequest) (*MintJWTResponse, error)
	// Request a Session Identity Certificate. To call this RPC, you must have
	// authenticated with a client certificate, not a bearer token.
	MintCert(context.Context, *MintCertRequest) (*MintCertResponse, error)
	// contains filtered or unexported methods
}

type SnapshotInfo struct {
	Type SnapshotType `protobuf:"varint,1,opt,name=type,proto3,enum=ateapi.SnapshotType" json:"type,omitempty"`
	// Types that are valid to be assigned to Data:
	//
	//	*SnapshotInfo_External
	//	*SnapshotInfo_Local
	Data isSnapshotInfo_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type SnapshotInfo_External struct {
	External *ExternalSnapshotInfo `protobuf:"bytes,2,opt,name=external,proto3,oneof"`
}

type SnapshotInfo_Local struct {
	Local *LocalSnapshotInfo `protobuf:"bytes,3,opt,name=local,proto3,oneof"`
}

type SnapshotType int32

type SuspendActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// contains filtered or unexported fields
}

type SuspendActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedControlServer struct{}

type UnimplementedSessionIdentityServer struct{}

type UnsafeControlServer interface {
	// contains filtered or unexported methods
}

type UnsafeSessionIdentityServer interface {
	// contains filtered or unexported methods
}

type UpdateActorRequest struct {
	ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	// worker_selector replaces the actor's current placement constraint.
	// Takes effect on the next ResumeActor call.
	WorkerSelector *Selector `protobuf:"bytes,2,opt,name=worker_selector,json=workerSelector,proto3" json:"worker_selector,omitempty"`
	// contains filtered or unexported fields
}

type UpdateActorResponse struct {
	Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

type Worker struct {
	WorkerNamespace string `protobuf:"bytes,1,opt,name=worker_namespace,json=workerNamespace,proto3" json:"worker_namespace,omitempty"`
	WorkerPool      string `protobuf:"bytes,2,opt,name=worker_pool,json=workerPool,proto3" json:"worker_pool,omitempty"`
	WorkerPod       string `protobuf:"bytes,3,opt,name=worker_pod,json=workerPod,proto3" json:"worker_pod,omitempty"`
	ActorNamespace  string `protobuf:"bytes,4,opt,name=actor_namespace,json=actorNamespace,proto3" json:"actor_namespace,omitempty"`
	ActorTemplate   string `protobuf:"bytes,5,opt,name=actor_template,json=actorTemplate,proto3" json:"actor_template,omitempty"`
	ActorId         string `protobuf:"bytes,6,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Ip              string `protobuf:"bytes,7,opt,name=ip,proto3" json:"ip,omitempty"`
	Version         int64  `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"`
	WorkerPodUid    string `protobuf:"bytes,9,opt,name=worker_pod_uid,json=workerPodUid,proto3" json:"worker_pod_uid,omitempty"`
	NodeName        string `protobuf:"bytes,10,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// contains filtered or unexported fields
}