ateletpb

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 (
	AteomHerder_Run_FullMethodName        = "/atelet.AteomHerder/Run"
	AteomHerder_Checkpoint_FullMethodName = "/atelet.AteomHerder/Checkpoint"
	AteomHerder_Restore_FullMethodName    = "/atelet.AteomHerder/Restore"
)

Variables

View Source
var AteomHerder_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "atelet.AteomHerder",
	HandlerType: (*AteomHerderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Run",
			Handler:    _AteomHerder_Run_Handler,
		},
		{
			MethodName: "Checkpoint",
			Handler:    _AteomHerder_Checkpoint_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _AteomHerder_Restore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "atelet.proto",
}

AteomHerder_ServiceDesc is the grpc.ServiceDesc for AteomHerder 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_atelet_proto protoreflect.FileDescriptor

Functions

func RegisterAteomHerderServer

func RegisterAteomHerderServer(s grpc.ServiceRegistrar, srv AteomHerderServer)

Types

type AteomHerderClient

type AteomHerderClient interface {
	// Run tells atelet to create a new containerized workload from scratch on an
	// ateom.
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	// Checkpoint tells atelet to save the current state of the workload on an
	// ateom to object storage, and then completely the ateom to a blank state
	// (back to "available" state.)
	Checkpoint(ctx context.Context, in *CheckpointRequest, opts ...grpc.CallOption) (*CheckpointResponse, error)
	// Restore restores a workload from checkpoint onto an ateom.
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*RestoreResponse, error)
}

AteomHerderClient is the client API for AteomHerder 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.

type AteomHerderServer

type AteomHerderServer interface {
	// Run tells atelet to create a new containerized workload from scratch on an
	// ateom.
	Run(context.Context, *RunRequest) (*RunResponse, error)
	// Checkpoint tells atelet to save the current state of the workload on an
	// ateom to object storage, and then completely the ateom to a blank state
	// (back to "available" state.)
	Checkpoint(context.Context, *CheckpointRequest) (*CheckpointResponse, error)
	// Restore restores a workload from checkpoint onto an ateom.
	Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	// contains filtered or unexported methods
}

AteomHerderServer is the server API for AteomHerder service. All implementations must embed UnimplementedAteomHerderServer for forward compatibility.

type AuthenticationConfig

type AuthenticationConfig struct {
	Gcp *GCPAuthenticationConfig `protobuf:"bytes,1,opt,name=gcp,proto3" json:"gcp,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticationConfig) Descriptor deprecated

func (*AuthenticationConfig) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticationConfig.ProtoReflect.Descriptor instead.

func (*AuthenticationConfig) GetGcp

func (*AuthenticationConfig) ProtoMessage

func (*AuthenticationConfig) ProtoMessage()

func (*AuthenticationConfig) ProtoReflect

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

func (*AuthenticationConfig) Reset

func (x *AuthenticationConfig) Reset()

func (*AuthenticationConfig) String

func (x *AuthenticationConfig) String() string

type CheckpointRequest

type CheckpointRequest struct {
	TargetAteomNamespace   string        `protobuf:"bytes,1,opt,name=target_ateom_namespace,json=targetAteomNamespace,proto3" json:"target_ateom_namespace,omitempty"`
	TargetAteomName        string        `protobuf:"bytes,2,opt,name=target_ateom_name,json=targetAteomName,proto3" json:"target_ateom_name,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"`
	ActorId                string        `protobuf:"bytes,5,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Runsc                  *RunscConfig  `protobuf:"bytes,6,opt,name=runsc,proto3" json:"runsc,omitempty"`
	Spec                   *WorkloadSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// An object storage URI prefix below which the checkpoint data will be
	// stored.
	//
	// The structure of the checkpoint should generally be treated as opaque. For
	// gVisor, the checkpoint consists of a checkpoint.img file that contains the
	// memory, sentry state, and filesystem deltas.  ateom will write additional
	// files to store the WorkloadSpec, which must be reassembled before gVisor
	// can restore a checkpoint.
	//
	// For example: "gs://bucket/actors/1234/snapshots/5678/"
	SnapshotUriPrefix string `protobuf:"bytes,8,opt,name=snapshot_uri_prefix,json=snapshotUriPrefix,proto3" json:"snapshot_uri_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckpointRequest) Descriptor deprecated

func (*CheckpointRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckpointRequest.ProtoReflect.Descriptor instead.

func (*CheckpointRequest) GetActorId

func (x *CheckpointRequest) GetActorId() string

func (*CheckpointRequest) GetActorTemplateName

func (x *CheckpointRequest) GetActorTemplateName() string

func (*CheckpointRequest) GetActorTemplateNamespace

func (x *CheckpointRequest) GetActorTemplateNamespace() string

func (*CheckpointRequest) GetRunsc

func (x *CheckpointRequest) GetRunsc() *RunscConfig

func (*CheckpointRequest) GetSnapshotUriPrefix

func (x *CheckpointRequest) GetSnapshotUriPrefix() string

func (*CheckpointRequest) GetSpec

func (x *CheckpointRequest) GetSpec() *WorkloadSpec

func (*CheckpointRequest) GetTargetAteomName

func (x *CheckpointRequest) GetTargetAteomName() string

func (*CheckpointRequest) GetTargetAteomNamespace

func (x *CheckpointRequest) GetTargetAteomNamespace() string

func (*CheckpointRequest) ProtoMessage

func (*CheckpointRequest) ProtoMessage()

func (*CheckpointRequest) ProtoReflect

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

func (*CheckpointRequest) Reset

func (x *CheckpointRequest) Reset()

func (*CheckpointRequest) String

func (x *CheckpointRequest) String() string

type CheckpointResponse

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

func (*CheckpointResponse) Descriptor deprecated

func (*CheckpointResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckpointResponse.ProtoReflect.Descriptor instead.

func (*CheckpointResponse) ProtoMessage

func (*CheckpointResponse) ProtoMessage()

func (*CheckpointResponse) ProtoReflect

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

func (*CheckpointResponse) Reset

func (x *CheckpointResponse) Reset()

func (*CheckpointResponse) String

func (x *CheckpointResponse) String() string

type Container

type Container struct {
	Name    string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image   string      `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Command []string    `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
	Env     []*EnvEntry `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated

func (*Container) Descriptor() ([]byte, []int)

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetCommand

func (x *Container) GetCommand() []string

func (*Container) GetEnv

func (x *Container) GetEnv() []*EnvEntry

func (*Container) GetImage

func (x *Container) GetImage() string

func (*Container) GetName

func (x *Container) GetName() string

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) ProtoReflect

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

func (*Container) Reset

func (x *Container) Reset()

func (*Container) String

func (x *Container) String() string

type EnvEntry

type EnvEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvEntry) Descriptor deprecated

func (*EnvEntry) Descriptor() ([]byte, []int)

Deprecated: Use EnvEntry.ProtoReflect.Descriptor instead.

func (*EnvEntry) GetName

func (x *EnvEntry) GetName() string

func (*EnvEntry) GetValue

func (x *EnvEntry) GetValue() string

func (*EnvEntry) ProtoMessage

func (*EnvEntry) ProtoMessage()

func (*EnvEntry) ProtoReflect

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

func (*EnvEntry) Reset

func (x *EnvEntry) Reset()

func (*EnvEntry) String

func (x *EnvEntry) String() string

type GCPAuthenticationConfig

type GCPAuthenticationConfig struct {
	Use bool `protobuf:"varint,1,opt,name=use,proto3" json:"use,omitempty"`
	// contains filtered or unexported fields
}

func (*GCPAuthenticationConfig) Descriptor deprecated

func (*GCPAuthenticationConfig) Descriptor() ([]byte, []int)

Deprecated: Use GCPAuthenticationConfig.ProtoReflect.Descriptor instead.

func (*GCPAuthenticationConfig) GetUse

func (x *GCPAuthenticationConfig) GetUse() bool

func (*GCPAuthenticationConfig) ProtoMessage

func (*GCPAuthenticationConfig) ProtoMessage()

func (*GCPAuthenticationConfig) ProtoReflect

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

func (*GCPAuthenticationConfig) Reset

func (x *GCPAuthenticationConfig) Reset()

func (*GCPAuthenticationConfig) String

func (x *GCPAuthenticationConfig) String() string

type RestoreRequest

type RestoreRequest struct {
	TargetAteomNamespace   string        `protobuf:"bytes,1,opt,name=target_ateom_namespace,json=targetAteomNamespace,proto3" json:"target_ateom_namespace,omitempty"`
	TargetAteomName        string        `protobuf:"bytes,2,opt,name=target_ateom_name,json=targetAteomName,proto3" json:"target_ateom_name,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"`
	ActorId                string        `protobuf:"bytes,5,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Runsc                  *RunscConfig  `protobuf:"bytes,6,opt,name=runsc,proto3" json:"runsc,omitempty"`
	Spec                   *WorkloadSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// The object storage URI prefix of the snapshot to restore.
	SnapshotUriPrefix string `protobuf:"bytes,8,opt,name=snapshot_uri_prefix,json=snapshotUriPrefix,proto3" json:"snapshot_uri_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreRequest) Descriptor deprecated

func (*RestoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.

func (*RestoreRequest) GetActorId

func (x *RestoreRequest) GetActorId() string

func (*RestoreRequest) GetActorTemplateName

func (x *RestoreRequest) GetActorTemplateName() string

func (*RestoreRequest) GetActorTemplateNamespace

func (x *RestoreRequest) GetActorTemplateNamespace() string

func (*RestoreRequest) GetRunsc

func (x *RestoreRequest) GetRunsc() *RunscConfig

func (*RestoreRequest) GetSnapshotUriPrefix

func (x *RestoreRequest) GetSnapshotUriPrefix() string

func (*RestoreRequest) GetSpec

func (x *RestoreRequest) GetSpec() *WorkloadSpec

func (*RestoreRequest) GetTargetAteomName

func (x *RestoreRequest) GetTargetAteomName() string

func (*RestoreRequest) GetTargetAteomNamespace

func (x *RestoreRequest) GetTargetAteomNamespace() string

func (*RestoreRequest) ProtoMessage

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) ProtoReflect

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

func (*RestoreRequest) Reset

func (x *RestoreRequest) Reset()

func (*RestoreRequest) String

func (x *RestoreRequest) String() string

type RestoreResponse

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

func (*RestoreResponse) Descriptor deprecated

func (*RestoreResponse) Descriptor() ([]byte, []int)

Deprecated: Use RestoreResponse.ProtoReflect.Descriptor instead.

func (*RestoreResponse) ProtoMessage

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) ProtoReflect

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

func (*RestoreResponse) Reset

func (x *RestoreResponse) Reset()

func (*RestoreResponse) String

func (x *RestoreResponse) String() string

type RunRequest

type RunRequest struct {
	TargetAteomNamespace   string        `protobuf:"bytes,1,opt,name=target_ateom_namespace,json=targetAteomNamespace,proto3" json:"target_ateom_namespace,omitempty"`
	TargetAteomName        string        `protobuf:"bytes,2,opt,name=target_ateom_name,json=targetAteomName,proto3" json:"target_ateom_name,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"`
	ActorId                string        `protobuf:"bytes,5,opt,name=actor_id,json=actorId,proto3" json:"actor_id,omitempty"`
	Runsc                  *RunscConfig  `protobuf:"bytes,8,opt,name=runsc,proto3" json:"runsc,omitempty"`
	Spec                   *WorkloadSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated

func (*RunRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetActorId

func (x *RunRequest) GetActorId() string

func (*RunRequest) GetActorTemplateName

func (x *RunRequest) GetActorTemplateName() string

func (*RunRequest) GetActorTemplateNamespace

func (x *RunRequest) GetActorTemplateNamespace() string

func (*RunRequest) GetRunsc

func (x *RunRequest) GetRunsc() *RunscConfig

func (*RunRequest) GetSpec

func (x *RunRequest) GetSpec() *WorkloadSpec

func (*RunRequest) GetTargetAteomName

func (x *RunRequest) GetTargetAteomName() string

func (*RunRequest) GetTargetAteomNamespace

func (x *RunRequest) GetTargetAteomNamespace() string

func (*RunRequest) ProtoMessage

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect

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

func (*RunRequest) Reset

func (x *RunRequest) Reset()

func (*RunRequest) String

func (x *RunRequest) String() string

type RunResponse

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

func (*RunResponse) Descriptor deprecated

func (*RunResponse) Descriptor() ([]byte, []int)

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) ProtoMessage

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect

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

func (*RunResponse) Reset

func (x *RunResponse) Reset()

func (*RunResponse) String

func (x *RunResponse) String() string

type RunscConfig

type RunscConfig struct {
	Amd64 *RunscPlatformConfig `protobuf:"bytes,1,opt,name=amd64,proto3" json:"amd64,omitempty"`
	Arm64 *RunscPlatformConfig `protobuf:"bytes,2,opt,name=arm64,proto3" json:"arm64,omitempty"`
	// How should atelet authenticate to fetch the runsc binary?
	Authentication *AuthenticationConfig `protobuf:"bytes,3,opt,name=authentication,proto3" json:"authentication,omitempty"`
	// contains filtered or unexported fields
}

func (*RunscConfig) Descriptor deprecated

func (*RunscConfig) Descriptor() ([]byte, []int)

Deprecated: Use RunscConfig.ProtoReflect.Descriptor instead.

func (*RunscConfig) GetAmd64

func (x *RunscConfig) GetAmd64() *RunscPlatformConfig

func (*RunscConfig) GetArm64

func (x *RunscConfig) GetArm64() *RunscPlatformConfig

func (*RunscConfig) GetAuthentication

func (x *RunscConfig) GetAuthentication() *AuthenticationConfig

func (*RunscConfig) ProtoMessage

func (*RunscConfig) ProtoMessage()

func (*RunscConfig) ProtoReflect

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

func (*RunscConfig) Reset

func (x *RunscConfig) Reset()

func (*RunscConfig) String

func (x *RunscConfig) String() string

type RunscPlatformConfig

type RunscPlatformConfig struct {

	// Check the downloaded binary against this hash.  Also used for naming the
	// downloaded file to prevent collisions.
	Sha256Hash string `protobuf:"bytes,1,opt,name=sha256_hash,json=sha256Hash,proto3" json:"sha256_hash,omitempty"`
	// gs:// URL to download the runsc binary.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*RunscPlatformConfig) Descriptor deprecated

func (*RunscPlatformConfig) Descriptor() ([]byte, []int)

Deprecated: Use RunscPlatformConfig.ProtoReflect.Descriptor instead.

func (*RunscPlatformConfig) GetSha256Hash

func (x *RunscPlatformConfig) GetSha256Hash() string

func (*RunscPlatformConfig) GetUrl

func (x *RunscPlatformConfig) GetUrl() string

func (*RunscPlatformConfig) ProtoMessage

func (*RunscPlatformConfig) ProtoMessage()

func (*RunscPlatformConfig) ProtoReflect

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

func (*RunscPlatformConfig) Reset

func (x *RunscPlatformConfig) Reset()

func (*RunscPlatformConfig) String

func (x *RunscPlatformConfig) String() string

type UnimplementedAteomHerderServer

type UnimplementedAteomHerderServer struct{}

UnimplementedAteomHerderServer 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 (UnimplementedAteomHerderServer) Checkpoint

func (UnimplementedAteomHerderServer) Restore

func (UnimplementedAteomHerderServer) Run

type UnsafeAteomHerderServer

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

UnsafeAteomHerderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AteomHerderServer will result in compilation errors.

type WorkloadSpec

type WorkloadSpec struct {
	Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	PauseImage string       `protobuf:"bytes,2,opt,name=pause_image,json=pauseImage,proto3" json:"pause_image,omitempty"`
	// contains filtered or unexported fields
}

WorkloadSpec parallels Pod, but with far fewer configurable fields.

func (*WorkloadSpec) Descriptor deprecated

func (*WorkloadSpec) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadSpec.ProtoReflect.Descriptor instead.

func (*WorkloadSpec) GetContainers

func (x *WorkloadSpec) GetContainers() []*Container

func (*WorkloadSpec) GetPauseImage

func (x *WorkloadSpec) GetPauseImage() string

func (*WorkloadSpec) ProtoMessage

func (*WorkloadSpec) ProtoMessage()

func (*WorkloadSpec) ProtoReflect

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

func (*WorkloadSpec) Reset

func (x *WorkloadSpec) Reset()

func (*WorkloadSpec) String

func (x *WorkloadSpec) String() string

Jump to

Keyboard shortcuts

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