Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)
- func RegisterSessionIdentityServer(s grpc.ServiceRegistrar, srv SessionIdentityServer)
- type Actor
- func (*Actor) Descriptor() ([]byte, []int)deprecated
- func (x *Actor) GetActorId() string
- func (x *Actor) GetActorTemplateName() string
- func (x *Actor) GetActorTemplateNamespace() string
- func (x *Actor) GetAteomPodIp() string
- func (x *Actor) GetAteomPodName() string
- func (x *Actor) GetAteomPodNamespace() string
- func (x *Actor) GetInProgressSnapshot() string
- func (x *Actor) GetLastSnapshot() string
- func (x *Actor) GetStatus() Actor_Status
- func (x *Actor) GetVersion() int64
- func (*Actor) ProtoMessage()
- func (x *Actor) ProtoReflect() protoreflect.Message
- func (x *Actor) Reset()
- func (x *Actor) String() string
- type Actor_Status
- func (Actor_Status) Descriptor() protoreflect.EnumDescriptor
- func (x Actor_Status) Enum() *Actor_Status
- func (Actor_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x Actor_Status) Number() protoreflect.EnumNumber
- func (x Actor_Status) String() string
- func (Actor_Status) Type() protoreflect.EnumType
- type ControlClient
- type ControlServer
- type CreateActorRequest
- func (*CreateActorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateActorRequest) GetActorId() string
- func (x *CreateActorRequest) GetActorTemplateName() string
- func (x *CreateActorRequest) GetActorTemplateNamespace() string
- func (*CreateActorRequest) ProtoMessage()
- func (x *CreateActorRequest) ProtoReflect() protoreflect.Message
- func (x *CreateActorRequest) Reset()
- func (x *CreateActorRequest) String() string
- type CreateActorResponse
- func (*CreateActorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateActorResponse) GetActor() *Actor
- func (*CreateActorResponse) ProtoMessage()
- func (x *CreateActorResponse) ProtoReflect() protoreflect.Message
- func (x *CreateActorResponse) Reset()
- func (x *CreateActorResponse) String() string
- type DebugClearRequest
- type DebugClearResponse
- type DeleteActorRequest
- func (*DeleteActorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteActorRequest) GetActorId() string
- func (*DeleteActorRequest) ProtoMessage()
- func (x *DeleteActorRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteActorRequest) Reset()
- func (x *DeleteActorRequest) String() string
- type DeleteActorResponse
- type GetActorRequest
- type GetActorResponse
- type ListActorsRequest
- type ListActorsResponse
- func (*ListActorsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActorsResponse) GetActors() []*Actor
- func (*ListActorsResponse) ProtoMessage()
- func (x *ListActorsResponse) ProtoReflect() protoreflect.Message
- func (x *ListActorsResponse) Reset()
- func (x *ListActorsResponse) String() string
- type ListWorkersRequest
- type ListWorkersResponse
- func (*ListWorkersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkersResponse) GetWorkers() []*Worker
- func (*ListWorkersResponse) ProtoMessage()
- func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkersResponse) Reset()
- func (x *ListWorkersResponse) String() string
- type MintCertRequest
- func (*MintCertRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MintCertRequest) GetAppId() string
- func (x *MintCertRequest) GetCertificateSigningRequest() []byte
- func (x *MintCertRequest) GetSessionId() string
- func (x *MintCertRequest) GetUserId() string
- func (*MintCertRequest) ProtoMessage()
- func (x *MintCertRequest) ProtoReflect() protoreflect.Message
- func (x *MintCertRequest) Reset()
- func (x *MintCertRequest) String() string
- type MintCertResponse
- func (*MintCertResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MintCertResponse) GetSessionCertificates() [][]byte
- func (*MintCertResponse) ProtoMessage()
- func (x *MintCertResponse) ProtoReflect() protoreflect.Message
- func (x *MintCertResponse) Reset()
- func (x *MintCertResponse) String() string
- type MintJWTRequest
- func (*MintJWTRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MintJWTRequest) GetAppId() string
- func (x *MintJWTRequest) GetAudience() []string
- func (x *MintJWTRequest) GetSessionId() string
- func (x *MintJWTRequest) GetUserId() string
- func (*MintJWTRequest) ProtoMessage()
- func (x *MintJWTRequest) ProtoReflect() protoreflect.Message
- func (x *MintJWTRequest) Reset()
- func (x *MintJWTRequest) String() string
- type MintJWTResponse
- type ResumeActorRequest
- func (*ResumeActorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeActorRequest) GetActorId() string
- func (x *ResumeActorRequest) GetBoot() bool
- func (*ResumeActorRequest) ProtoMessage()
- func (x *ResumeActorRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeActorRequest) Reset()
- func (x *ResumeActorRequest) String() string
- type ResumeActorResponse
- func (*ResumeActorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeActorResponse) GetActor() *Actor
- func (*ResumeActorResponse) ProtoMessage()
- func (x *ResumeActorResponse) ProtoReflect() protoreflect.Message
- func (x *ResumeActorResponse) Reset()
- func (x *ResumeActorResponse) String() string
- type SessionIdentityClient
- type SessionIdentityServer
- type SuspendActorRequest
- func (*SuspendActorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SuspendActorRequest) GetActorId() string
- func (*SuspendActorRequest) ProtoMessage()
- func (x *SuspendActorRequest) ProtoReflect() protoreflect.Message
- func (x *SuspendActorRequest) Reset()
- func (x *SuspendActorRequest) String() string
- type SuspendActorResponse
- func (*SuspendActorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SuspendActorResponse) GetActor() *Actor
- func (*SuspendActorResponse) ProtoMessage()
- func (x *SuspendActorResponse) ProtoReflect() protoreflect.Message
- func (x *SuspendActorResponse) Reset()
- func (x *SuspendActorResponse) String() string
- type UnimplementedControlServer
- func (UnimplementedControlServer) CreateActor(context.Context, *CreateActorRequest) (*CreateActorResponse, error)
- func (UnimplementedControlServer) DebugClear(context.Context, *DebugClearRequest) (*DebugClearResponse, error)
- func (UnimplementedControlServer) DeleteActor(context.Context, *DeleteActorRequest) (*DeleteActorResponse, error)
- func (UnimplementedControlServer) GetActor(context.Context, *GetActorRequest) (*GetActorResponse, error)
- func (UnimplementedControlServer) ListActors(context.Context, *ListActorsRequest) (*ListActorsResponse, error)
- func (UnimplementedControlServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
- func (UnimplementedControlServer) ResumeActor(context.Context, *ResumeActorRequest) (*ResumeActorResponse, error)
- func (UnimplementedControlServer) SuspendActor(context.Context, *SuspendActorRequest) (*SuspendActorResponse, error)
- type UnimplementedSessionIdentityServer
- type UnsafeControlServer
- type UnsafeSessionIdentityServer
- type Worker
- func (*Worker) Descriptor() ([]byte, []int)deprecated
- func (x *Worker) GetActorId() string
- func (x *Worker) GetActorNamespace() string
- func (x *Worker) GetActorTemplate() string
- func (x *Worker) GetIp() string
- func (x *Worker) GetVersion() int64
- func (x *Worker) GetWorkerNamespace() string
- func (x *Worker) GetWorkerPod() string
- func (x *Worker) GetWorkerPool() string
- func (*Worker) ProtoMessage()
- func (x *Worker) ProtoReflect() protoreflect.Message
- func (x *Worker) Reset()
- func (x *Worker) String() string
Constants ¶
const ( Control_GetActor_FullMethodName = "/ateapi.Control/GetActor" Control_CreateActor_FullMethodName = "/ateapi.Control/CreateActor" Control_SuspendActor_FullMethodName = "/ateapi.Control/SuspendActor" Control_ResumeActor_FullMethodName = "/ateapi.Control/ResumeActor" Control_DeleteActor_FullMethodName = "/ateapi.Control/DeleteActor" Control_ListWorkers_FullMethodName = "/ateapi.Control/ListWorkers" Control_ListActors_FullMethodName = "/ateapi.Control/ListActors" Control_DebugClear_FullMethodName = "/ateapi.Control/DebugClear" )
const ( SessionIdentity_MintJWT_FullMethodName = "/ateapi.SessionIdentity/MintJWT" SessionIdentity_MintCert_FullMethodName = "/ateapi.SessionIdentity/MintCert" )
Variables ¶
var ( Actor_Status_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "STATUS_RESUMING", 2: "STATUS_RUNNING", 3: "STATUS_SUSPENDING", 4: "STATUS_SUSPENDED", } Actor_Status_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "STATUS_RESUMING": 1, "STATUS_RUNNING": 2, "STATUS_SUSPENDING": 3, "STATUS_SUSPENDED": 4, } )
Enum value maps for Actor_Status.
var Control_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ateapi.Control", HandlerType: (*ControlServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetActor", Handler: _Control_GetActor_Handler, }, { MethodName: "CreateActor", Handler: _Control_CreateActor_Handler, }, { MethodName: "SuspendActor", Handler: _Control_SuspendActor_Handler, }, { MethodName: "ResumeActor", Handler: _Control_ResumeActor_Handler, }, { MethodName: "DeleteActor", Handler: _Control_DeleteActor_Handler, }, { MethodName: "ListWorkers", Handler: _Control_ListWorkers_Handler, }, { MethodName: "ListActors", Handler: _Control_ListActors_Handler, }, { MethodName: "DebugClear", Handler: _Control_DebugClear_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ateapi.proto", }
Control_ServiceDesc is the grpc.ServiceDesc for Control service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_ateapi_proto protoreflect.FileDescriptor
var SessionIdentity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ateapi.SessionIdentity", HandlerType: (*SessionIdentityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "MintJWT", Handler: _SessionIdentity_MintJWT_Handler, }, { MethodName: "MintCert", Handler: _SessionIdentity_MintCert_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ateapi.proto", }
SessionIdentity_ServiceDesc is the grpc.ServiceDesc for SessionIdentity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterControlServer ¶
func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)
func RegisterSessionIdentityServer ¶
func RegisterSessionIdentityServer(s grpc.ServiceRegistrar, srv SessionIdentityServer)
Types ¶
type Actor ¶
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"`
LastSnapshot string `protobuf:"bytes,9,opt,name=last_snapshot,json=lastSnapshot,proto3" json:"last_snapshot,omitempty"`
InProgressSnapshot string `protobuf:"bytes,10,opt,name=in_progress_snapshot,json=inProgressSnapshot,proto3" json:"in_progress_snapshot,omitempty"`
// contains filtered or unexported fields
}
func (*Actor) Descriptor
deprecated
func (*Actor) GetActorId ¶
func (*Actor) GetActorTemplateName ¶
func (*Actor) GetActorTemplateNamespace ¶
func (*Actor) GetAteomPodIp ¶
func (*Actor) GetAteomPodName ¶
func (*Actor) GetAteomPodNamespace ¶
func (*Actor) GetInProgressSnapshot ¶
func (*Actor) GetLastSnapshot ¶
func (*Actor) GetStatus ¶
func (x *Actor) GetStatus() Actor_Status
func (*Actor) GetVersion ¶
func (*Actor) ProtoMessage ¶
func (*Actor) ProtoMessage()
func (*Actor) ProtoReflect ¶
func (x *Actor) ProtoReflect() protoreflect.Message
type Actor_Status ¶
type Actor_Status int32
const ( Actor_STATUS_UNSPECIFIED Actor_Status = 0 Actor_STATUS_RESUMING Actor_Status = 1 Actor_STATUS_RUNNING Actor_Status = 2 Actor_STATUS_SUSPENDING Actor_Status = 3 Actor_STATUS_SUSPENDED Actor_Status = 4 )
func (Actor_Status) Descriptor ¶
func (Actor_Status) Descriptor() protoreflect.EnumDescriptor
func (Actor_Status) Enum ¶
func (x Actor_Status) Enum() *Actor_Status
func (Actor_Status) EnumDescriptor
deprecated
func (Actor_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use Actor_Status.Descriptor instead.
func (Actor_Status) Number ¶
func (x Actor_Status) Number() protoreflect.EnumNumber
func (Actor_Status) String ¶
func (x Actor_Status) String() string
func (Actor_Status) Type ¶
func (Actor_Status) Type() protoreflect.EnumType
type ControlClient ¶
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)
// Suspend a given actor to a new snapshot.
SuspendActor(ctx context.Context, in *SuspendActorRequest, opts ...grpc.CallOption) (*SuspendActorResponse, 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)
}
ControlClient is the client API for Control service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Control is the primary RPC interface for Agentic Substrate.
func NewControlClient ¶
func NewControlClient(cc grpc.ClientConnInterface) ControlClient
type ControlServer ¶
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)
// Suspend a given actor to a new snapshot.
SuspendActor(context.Context, *SuspendActorRequest) (*SuspendActorResponse, 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
}
ControlServer is the server API for Control service. All implementations must embed UnimplementedControlServer for forward compatibility.
Control is the primary RPC interface for Agentic Substrate.
type CreateActorRequest ¶
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"`
// contains filtered or unexported fields
}
Request to create a new Actor.
func (*CreateActorRequest) Descriptor
deprecated
func (*CreateActorRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateActorRequest.ProtoReflect.Descriptor instead.
func (*CreateActorRequest) GetActorId ¶
func (x *CreateActorRequest) GetActorId() string
func (*CreateActorRequest) GetActorTemplateName ¶
func (x *CreateActorRequest) GetActorTemplateName() string
func (*CreateActorRequest) GetActorTemplateNamespace ¶
func (x *CreateActorRequest) GetActorTemplateNamespace() string
func (*CreateActorRequest) ProtoMessage ¶
func (*CreateActorRequest) ProtoMessage()
func (*CreateActorRequest) ProtoReflect ¶
func (x *CreateActorRequest) ProtoReflect() protoreflect.Message
func (*CreateActorRequest) Reset ¶
func (x *CreateActorRequest) Reset()
func (*CreateActorRequest) String ¶
func (x *CreateActorRequest) String() string
type CreateActorResponse ¶
type CreateActorResponse struct {
Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
// contains filtered or unexported fields
}
func (*CreateActorResponse) Descriptor
deprecated
func (*CreateActorResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateActorResponse.ProtoReflect.Descriptor instead.
func (*CreateActorResponse) GetActor ¶
func (x *CreateActorResponse) GetActor() *Actor
func (*CreateActorResponse) ProtoMessage ¶
func (*CreateActorResponse) ProtoMessage()
func (*CreateActorResponse) ProtoReflect ¶
func (x *CreateActorResponse) ProtoReflect() protoreflect.Message
func (*CreateActorResponse) Reset ¶
func (x *CreateActorResponse) Reset()
func (*CreateActorResponse) String ¶
func (x *CreateActorResponse) String() string
type DebugClearRequest ¶
type DebugClearRequest struct {
// contains filtered or unexported fields
}
func (*DebugClearRequest) Descriptor
deprecated
func (*DebugClearRequest) Descriptor() ([]byte, []int)
Deprecated: Use DebugClearRequest.ProtoReflect.Descriptor instead.
func (*DebugClearRequest) ProtoMessage ¶
func (*DebugClearRequest) ProtoMessage()
func (*DebugClearRequest) ProtoReflect ¶
func (x *DebugClearRequest) ProtoReflect() protoreflect.Message
func (*DebugClearRequest) Reset ¶
func (x *DebugClearRequest) Reset()
func (*DebugClearRequest) String ¶
func (x *DebugClearRequest) String() string
type DebugClearResponse ¶
type DebugClearResponse struct {
// contains filtered or unexported fields
}
func (*DebugClearResponse) Descriptor
deprecated
func (*DebugClearResponse) Descriptor() ([]byte, []int)
Deprecated: Use DebugClearResponse.ProtoReflect.Descriptor instead.
func (*DebugClearResponse) ProtoMessage ¶
func (*DebugClearResponse) ProtoMessage()
func (*DebugClearResponse) ProtoReflect ¶
func (x *DebugClearResponse) ProtoReflect() protoreflect.Message
func (*DebugClearResponse) Reset ¶
func (x *DebugClearResponse) Reset()
func (*DebugClearResponse) String ¶
func (x *DebugClearResponse) String() string
type DeleteActorRequest ¶
type DeleteActorRequest struct {
ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteActorRequest) Descriptor
deprecated
func (*DeleteActorRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteActorRequest.ProtoReflect.Descriptor instead.
func (*DeleteActorRequest) GetActorId ¶
func (x *DeleteActorRequest) GetActorId() string
func (*DeleteActorRequest) ProtoMessage ¶
func (*DeleteActorRequest) ProtoMessage()
func (*DeleteActorRequest) ProtoReflect ¶
func (x *DeleteActorRequest) ProtoReflect() protoreflect.Message
func (*DeleteActorRequest) Reset ¶
func (x *DeleteActorRequest) Reset()
func (*DeleteActorRequest) String ¶
func (x *DeleteActorRequest) String() string
type DeleteActorResponse ¶
type DeleteActorResponse struct {
// contains filtered or unexported fields
}
func (*DeleteActorResponse) Descriptor
deprecated
func (*DeleteActorResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteActorResponse.ProtoReflect.Descriptor instead.
func (*DeleteActorResponse) ProtoMessage ¶
func (*DeleteActorResponse) ProtoMessage()
func (*DeleteActorResponse) ProtoReflect ¶
func (x *DeleteActorResponse) ProtoReflect() protoreflect.Message
func (*DeleteActorResponse) Reset ¶
func (x *DeleteActorResponse) Reset()
func (*DeleteActorResponse) String ¶
func (x *DeleteActorResponse) String() string
type GetActorRequest ¶
type GetActorRequest struct {
ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
// contains filtered or unexported fields
}
func (*GetActorRequest) Descriptor
deprecated
func (*GetActorRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetActorRequest.ProtoReflect.Descriptor instead.
func (*GetActorRequest) GetActorId ¶
func (x *GetActorRequest) GetActorId() string
func (*GetActorRequest) ProtoMessage ¶
func (*GetActorRequest) ProtoMessage()
func (*GetActorRequest) ProtoReflect ¶
func (x *GetActorRequest) ProtoReflect() protoreflect.Message
func (*GetActorRequest) Reset ¶
func (x *GetActorRequest) Reset()
func (*GetActorRequest) String ¶
func (x *GetActorRequest) String() string
type GetActorResponse ¶
type GetActorResponse struct {
Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
// contains filtered or unexported fields
}
func (*GetActorResponse) Descriptor
deprecated
func (*GetActorResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetActorResponse.ProtoReflect.Descriptor instead.
func (*GetActorResponse) GetActor ¶
func (x *GetActorResponse) GetActor() *Actor
func (*GetActorResponse) ProtoMessage ¶
func (*GetActorResponse) ProtoMessage()
func (*GetActorResponse) ProtoReflect ¶
func (x *GetActorResponse) ProtoReflect() protoreflect.Message
func (*GetActorResponse) Reset ¶
func (x *GetActorResponse) Reset()
func (*GetActorResponse) String ¶
func (x *GetActorResponse) String() string
type ListActorsRequest ¶
type ListActorsRequest struct {
// contains filtered or unexported fields
}
func (*ListActorsRequest) Descriptor
deprecated
func (*ListActorsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActorsRequest.ProtoReflect.Descriptor instead.
func (*ListActorsRequest) ProtoMessage ¶
func (*ListActorsRequest) ProtoMessage()
func (*ListActorsRequest) ProtoReflect ¶
func (x *ListActorsRequest) ProtoReflect() protoreflect.Message
func (*ListActorsRequest) Reset ¶
func (x *ListActorsRequest) Reset()
func (*ListActorsRequest) String ¶
func (x *ListActorsRequest) String() string
type ListActorsResponse ¶
type ListActorsResponse struct {
Actors []*Actor `protobuf:"bytes,1,rep,name=actors,proto3" json:"actors,omitempty"`
// contains filtered or unexported fields
}
func (*ListActorsResponse) Descriptor
deprecated
func (*ListActorsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActorsResponse.ProtoReflect.Descriptor instead.
func (*ListActorsResponse) GetActors ¶
func (x *ListActorsResponse) GetActors() []*Actor
func (*ListActorsResponse) ProtoMessage ¶
func (*ListActorsResponse) ProtoMessage()
func (*ListActorsResponse) ProtoReflect ¶
func (x *ListActorsResponse) ProtoReflect() protoreflect.Message
func (*ListActorsResponse) Reset ¶
func (x *ListActorsResponse) Reset()
func (*ListActorsResponse) String ¶
func (x *ListActorsResponse) String() string
type ListWorkersRequest ¶
type ListWorkersRequest struct {
// contains filtered or unexported fields
}
func (*ListWorkersRequest) Descriptor
deprecated
func (*ListWorkersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.
func (*ListWorkersRequest) ProtoMessage ¶
func (*ListWorkersRequest) ProtoMessage()
func (*ListWorkersRequest) ProtoReflect ¶
func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message
func (*ListWorkersRequest) Reset ¶
func (x *ListWorkersRequest) Reset()
func (*ListWorkersRequest) String ¶
func (x *ListWorkersRequest) String() string
type ListWorkersResponse ¶
type ListWorkersResponse struct {
Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
// contains filtered or unexported fields
}
func (*ListWorkersResponse) Descriptor
deprecated
func (*ListWorkersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.
func (*ListWorkersResponse) GetWorkers ¶
func (x *ListWorkersResponse) GetWorkers() []*Worker
func (*ListWorkersResponse) ProtoMessage ¶
func (*ListWorkersResponse) ProtoMessage()
func (*ListWorkersResponse) ProtoReflect ¶
func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message
func (*ListWorkersResponse) Reset ¶
func (x *ListWorkersResponse) Reset()
func (*ListWorkersResponse) String ¶
func (x *ListWorkersResponse) String() string
type MintCertRequest ¶
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
}
func (*MintCertRequest) Descriptor
deprecated
func (*MintCertRequest) Descriptor() ([]byte, []int)
Deprecated: Use MintCertRequest.ProtoReflect.Descriptor instead.
func (*MintCertRequest) GetAppId ¶
func (x *MintCertRequest) GetAppId() string
func (*MintCertRequest) GetCertificateSigningRequest ¶
func (x *MintCertRequest) GetCertificateSigningRequest() []byte
func (*MintCertRequest) GetSessionId ¶
func (x *MintCertRequest) GetSessionId() string
func (*MintCertRequest) GetUserId ¶
func (x *MintCertRequest) GetUserId() string
func (*MintCertRequest) ProtoMessage ¶
func (*MintCertRequest) ProtoMessage()
func (*MintCertRequest) ProtoReflect ¶
func (x *MintCertRequest) ProtoReflect() protoreflect.Message
func (*MintCertRequest) Reset ¶
func (x *MintCertRequest) Reset()
func (*MintCertRequest) String ¶
func (x *MintCertRequest) String() string
type MintCertResponse ¶
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
}
func (*MintCertResponse) Descriptor
deprecated
func (*MintCertResponse) Descriptor() ([]byte, []int)
Deprecated: Use MintCertResponse.ProtoReflect.Descriptor instead.
func (*MintCertResponse) GetSessionCertificates ¶
func (x *MintCertResponse) GetSessionCertificates() [][]byte
func (*MintCertResponse) ProtoMessage ¶
func (*MintCertResponse) ProtoMessage()
func (*MintCertResponse) ProtoReflect ¶
func (x *MintCertResponse) ProtoReflect() protoreflect.Message
func (*MintCertResponse) Reset ¶
func (x *MintCertResponse) Reset()
func (*MintCertResponse) String ¶
func (x *MintCertResponse) String() string
type MintJWTRequest ¶
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
}
func (*MintJWTRequest) Descriptor
deprecated
func (*MintJWTRequest) Descriptor() ([]byte, []int)
Deprecated: Use MintJWTRequest.ProtoReflect.Descriptor instead.
func (*MintJWTRequest) GetAppId ¶
func (x *MintJWTRequest) GetAppId() string
func (*MintJWTRequest) GetAudience ¶
func (x *MintJWTRequest) GetAudience() []string
func (*MintJWTRequest) GetSessionId ¶
func (x *MintJWTRequest) GetSessionId() string
func (*MintJWTRequest) GetUserId ¶
func (x *MintJWTRequest) GetUserId() string
func (*MintJWTRequest) ProtoMessage ¶
func (*MintJWTRequest) ProtoMessage()
func (*MintJWTRequest) ProtoReflect ¶
func (x *MintJWTRequest) ProtoReflect() protoreflect.Message
func (*MintJWTRequest) Reset ¶
func (x *MintJWTRequest) Reset()
func (*MintJWTRequest) String ¶
func (x *MintJWTRequest) String() string
type MintJWTResponse ¶
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
}
func (*MintJWTResponse) Descriptor
deprecated
func (*MintJWTResponse) Descriptor() ([]byte, []int)
Deprecated: Use MintJWTResponse.ProtoReflect.Descriptor instead.
func (*MintJWTResponse) GetSessionJwt ¶
func (x *MintJWTResponse) GetSessionJwt() string
func (*MintJWTResponse) ProtoMessage ¶
func (*MintJWTResponse) ProtoMessage()
func (*MintJWTResponse) ProtoReflect ¶
func (x *MintJWTResponse) ProtoReflect() protoreflect.Message
func (*MintJWTResponse) Reset ¶
func (x *MintJWTResponse) Reset()
func (*MintJWTResponse) String ¶
func (x *MintJWTResponse) String() string
type ResumeActorRequest ¶
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
}
func (*ResumeActorRequest) Descriptor
deprecated
func (*ResumeActorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeActorRequest.ProtoReflect.Descriptor instead.
func (*ResumeActorRequest) GetActorId ¶
func (x *ResumeActorRequest) GetActorId() string
func (*ResumeActorRequest) GetBoot ¶
func (x *ResumeActorRequest) GetBoot() bool
func (*ResumeActorRequest) ProtoMessage ¶
func (*ResumeActorRequest) ProtoMessage()
func (*ResumeActorRequest) ProtoReflect ¶
func (x *ResumeActorRequest) ProtoReflect() protoreflect.Message
func (*ResumeActorRequest) Reset ¶
func (x *ResumeActorRequest) Reset()
func (*ResumeActorRequest) String ¶
func (x *ResumeActorRequest) String() string
type ResumeActorResponse ¶
type ResumeActorResponse struct {
Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
// contains filtered or unexported fields
}
func (*ResumeActorResponse) Descriptor
deprecated
func (*ResumeActorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResumeActorResponse.ProtoReflect.Descriptor instead.
func (*ResumeActorResponse) GetActor ¶
func (x *ResumeActorResponse) GetActor() *Actor
func (*ResumeActorResponse) ProtoMessage ¶
func (*ResumeActorResponse) ProtoMessage()
func (*ResumeActorResponse) ProtoReflect ¶
func (x *ResumeActorResponse) ProtoReflect() protoreflect.Message
func (*ResumeActorResponse) Reset ¶
func (x *ResumeActorResponse) Reset()
func (*ResumeActorResponse) String ¶
func (x *ResumeActorResponse) String() string
type SessionIdentityClient ¶
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)
}
SessionIdentityClient is the client API for SessionIdentity service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
SessionIdentity allows substrate workloads to exchange their infrastructure-level credentials (k8s service account token, etc.) for a substrate session-level credential. A given substrate session might migrate between many different physical workers over the course of its lifecycle, whereas the session credential's identity will be stable for the life of the session.
This service requires authentication. You can authenticate with a Kubernetes service account token in an `Authorization: Bearer` header, or you can authenticate with a Kubernetes service account certificate as an mTLS certificate. (Kubernetes service account certificates do not currently exist upstream, but we will provide a polyfill based on Pod Certificates).
The broker will check that the service credentials you authenticated with belong to a Pod that is currently mapped to the requested session in the session database.
func NewSessionIdentityClient ¶
func NewSessionIdentityClient(cc grpc.ClientConnInterface) SessionIdentityClient
type SessionIdentityServer ¶
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
}
SessionIdentityServer is the server API for SessionIdentity service. All implementations must embed UnimplementedSessionIdentityServer for forward compatibility.
SessionIdentity allows substrate workloads to exchange their infrastructure-level credentials (k8s service account token, etc.) for a substrate session-level credential. A given substrate session might migrate between many different physical workers over the course of its lifecycle, whereas the session credential's identity will be stable for the life of the session.
This service requires authentication. You can authenticate with a Kubernetes service account token in an `Authorization: Bearer` header, or you can authenticate with a Kubernetes service account certificate as an mTLS certificate. (Kubernetes service account certificates do not currently exist upstream, but we will provide a polyfill based on Pod Certificates).
The broker will check that the service credentials you authenticated with belong to a Pod that is currently mapped to the requested session in the session database.
type SuspendActorRequest ¶
type SuspendActorRequest struct {
ActorId string `protobuf:"bytes,1,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
// contains filtered or unexported fields
}
func (*SuspendActorRequest) Descriptor
deprecated
func (*SuspendActorRequest) Descriptor() ([]byte, []int)
Deprecated: Use SuspendActorRequest.ProtoReflect.Descriptor instead.
func (*SuspendActorRequest) GetActorId ¶
func (x *SuspendActorRequest) GetActorId() string
func (*SuspendActorRequest) ProtoMessage ¶
func (*SuspendActorRequest) ProtoMessage()
func (*SuspendActorRequest) ProtoReflect ¶
func (x *SuspendActorRequest) ProtoReflect() protoreflect.Message
func (*SuspendActorRequest) Reset ¶
func (x *SuspendActorRequest) Reset()
func (*SuspendActorRequest) String ¶
func (x *SuspendActorRequest) String() string
type SuspendActorResponse ¶
type SuspendActorResponse struct {
Actor *Actor `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
// contains filtered or unexported fields
}
func (*SuspendActorResponse) Descriptor
deprecated
func (*SuspendActorResponse) Descriptor() ([]byte, []int)
Deprecated: Use SuspendActorResponse.ProtoReflect.Descriptor instead.
func (*SuspendActorResponse) GetActor ¶
func (x *SuspendActorResponse) GetActor() *Actor
func (*SuspendActorResponse) ProtoMessage ¶
func (*SuspendActorResponse) ProtoMessage()
func (*SuspendActorResponse) ProtoReflect ¶
func (x *SuspendActorResponse) ProtoReflect() protoreflect.Message
func (*SuspendActorResponse) Reset ¶
func (x *SuspendActorResponse) Reset()
func (*SuspendActorResponse) String ¶
func (x *SuspendActorResponse) String() string
type UnimplementedControlServer ¶
type UnimplementedControlServer struct{}
UnimplementedControlServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedControlServer) CreateActor ¶
func (UnimplementedControlServer) CreateActor(context.Context, *CreateActorRequest) (*CreateActorResponse, error)
func (UnimplementedControlServer) DebugClear ¶
func (UnimplementedControlServer) DebugClear(context.Context, *DebugClearRequest) (*DebugClearResponse, error)
func (UnimplementedControlServer) DeleteActor ¶
func (UnimplementedControlServer) DeleteActor(context.Context, *DeleteActorRequest) (*DeleteActorResponse, error)
func (UnimplementedControlServer) GetActor ¶
func (UnimplementedControlServer) GetActor(context.Context, *GetActorRequest) (*GetActorResponse, error)
func (UnimplementedControlServer) ListActors ¶
func (UnimplementedControlServer) ListActors(context.Context, *ListActorsRequest) (*ListActorsResponse, error)
func (UnimplementedControlServer) ListWorkers ¶
func (UnimplementedControlServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
func (UnimplementedControlServer) ResumeActor ¶
func (UnimplementedControlServer) ResumeActor(context.Context, *ResumeActorRequest) (*ResumeActorResponse, error)
func (UnimplementedControlServer) SuspendActor ¶
func (UnimplementedControlServer) SuspendActor(context.Context, *SuspendActorRequest) (*SuspendActorResponse, error)
type UnimplementedSessionIdentityServer ¶
type UnimplementedSessionIdentityServer struct{}
UnimplementedSessionIdentityServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedSessionIdentityServer) MintCert ¶
func (UnimplementedSessionIdentityServer) MintCert(context.Context, *MintCertRequest) (*MintCertResponse, error)
func (UnimplementedSessionIdentityServer) MintJWT ¶
func (UnimplementedSessionIdentityServer) MintJWT(context.Context, *MintJWTRequest) (*MintJWTResponse, error)
type UnsafeControlServer ¶
type UnsafeControlServer interface {
// contains filtered or unexported methods
}
UnsafeControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServer will result in compilation errors.
type UnsafeSessionIdentityServer ¶
type UnsafeSessionIdentityServer interface {
// contains filtered or unexported methods
}
UnsafeSessionIdentityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionIdentityServer will result in compilation errors.
type Worker ¶
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"`
// contains filtered or unexported fields
}
func (*Worker) Descriptor
deprecated
func (*Worker) GetActorId ¶
func (*Worker) GetActorNamespace ¶
func (*Worker) GetActorTemplate ¶
func (*Worker) GetVersion ¶
func (*Worker) GetWorkerNamespace ¶
func (*Worker) GetWorkerPod ¶
func (*Worker) GetWorkerPool ¶
func (*Worker) ProtoMessage ¶
func (*Worker) ProtoMessage()
func (*Worker) ProtoReflect ¶
func (x *Worker) ProtoReflect() protoreflect.Message