ateapipb

package
v0.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	SessionIdentity_MintJWT_FullMethodName  = "/ateapi.SessionIdentity/MintJWT"
	SessionIdentity_MintCert_FullMethodName = "/ateapi.SessionIdentity/MintCert"
)

Variables

View Source
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.

View Source
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)

View Source
var File_ateapi_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Actor.ProtoReflect.Descriptor instead.

func (*Actor) GetActorId

func (x *Actor) GetActorId() string

func (*Actor) GetActorTemplateName

func (x *Actor) GetActorTemplateName() string

func (*Actor) GetActorTemplateNamespace

func (x *Actor) GetActorTemplateNamespace() string

func (*Actor) GetAteomPodIp

func (x *Actor) GetAteomPodIp() string

func (*Actor) GetAteomPodName

func (x *Actor) GetAteomPodName() string

func (*Actor) GetAteomPodNamespace

func (x *Actor) GetAteomPodNamespace() string

func (*Actor) GetInProgressSnapshot

func (x *Actor) GetInProgressSnapshot() string

func (*Actor) GetLastSnapshot

func (x *Actor) GetLastSnapshot() string

func (*Actor) GetStatus

func (x *Actor) GetStatus() Actor_Status

func (*Actor) GetVersion

func (x *Actor) GetVersion() int64

func (*Actor) ProtoMessage

func (*Actor) ProtoMessage()

func (*Actor) ProtoReflect

func (x *Actor) ProtoReflect() protoreflect.Message

func (*Actor) Reset

func (x *Actor) Reset()

func (*Actor) String

func (x *Actor) String() string

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) 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 (Actor_Status) String

func (x Actor_Status) String() string

func (Actor_Status) Type

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.

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) DebugClear

func (UnimplementedControlServer) DeleteActor

func (UnimplementedControlServer) GetActor

func (UnimplementedControlServer) ListActors

func (UnimplementedControlServer) ListWorkers

func (UnimplementedControlServer) ResumeActor

func (UnimplementedControlServer) SuspendActor

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) MintJWT

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) Descriptor() ([]byte, []int)

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetActorId

func (x *Worker) GetActorId() string

func (*Worker) GetActorNamespace

func (x *Worker) GetActorNamespace() string

func (*Worker) GetActorTemplate

func (x *Worker) GetActorTemplate() string

func (*Worker) GetIp

func (x *Worker) GetIp() string

func (*Worker) GetVersion

func (x *Worker) GetVersion() int64

func (*Worker) GetWorkerNamespace

func (x *Worker) GetWorkerNamespace() string

func (*Worker) GetWorkerPod

func (x *Worker) GetWorkerPod() string

func (*Worker) GetWorkerPool

func (x *Worker) GetWorkerPool() string

func (*Worker) ProtoMessage

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect

func (x *Worker) ProtoReflect() protoreflect.Message

func (*Worker) Reset

func (x *Worker) Reset()

func (*Worker) String

func (x *Worker) String() string

Jump to

Keyboard shortcuts

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