orchestrator

package
v0.0.0-...-8fe0098 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_orchestrator_proto protoreflect.FileDescriptor
View Source 
var Sandbox_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Sandbox",
	HandlerType: (*SandboxServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Sandbox_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Sandbox_Update_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Sandbox_List_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Sandbox_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "orchestrator.proto",
}

Sandbox_ServiceDesc is the grpc.ServiceDesc for Sandbox service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSandboxServer 

func RegisterSandboxServer(s grpc.ServiceRegistrar, srv SandboxServer)

Types

type RunningSandbox 

type RunningSandbox struct {
	Config    *SandboxConfig         `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	ClientID  string                 `protobuf:"bytes,2,opt,name=clientID,proto3" json:"clientID,omitempty"`
	StartTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

func (*RunningSandbox) Descriptor deprecated 

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

Deprecated: Use RunningSandbox.ProtoReflect.Descriptor instead.

func (*RunningSandbox) GetClientID 

func (x *RunningSandbox) GetClientID() string

func (*RunningSandbox) GetConfig 

func (x *RunningSandbox) GetConfig() *SandboxConfig

func (*RunningSandbox) GetEndTime 

func (x *RunningSandbox) GetEndTime() *timestamppb.Timestamp

func (*RunningSandbox) GetStartTime 

func (x *RunningSandbox) GetStartTime() *timestamppb.Timestamp

func (*RunningSandbox) ProtoMessage 

func (*RunningSandbox) ProtoMessage()

func (*RunningSandbox) ProtoReflect 

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

func (*RunningSandbox) Reset 

func (x *RunningSandbox) Reset()

func (*RunningSandbox) String 

func (x *RunningSandbox) String() string

type SandboxClient 

type SandboxClient interface {
	// Create is a gRPC service that creates a new sandbox.
	Create(ctx context.Context, in *SandboxCreateRequest, opts ...grpc.CallOption) (*SandboxCreateResponse, error)
	// Update is a gRPC service that updates a sandbox.
	Update(ctx context.Context, in *SandboxUpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// List is a gRPC service that returns a list of all the sandboxes.
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SandboxListResponse, error)
	// Delete is a gRPC service that kills a sandbox.
	Delete(ctx context.Context, in *SandboxRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SandboxClient is the client API for Sandbox 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.

func NewSandboxClient 

func NewSandboxClient(cc grpc.ClientConnInterface) SandboxClient

type SandboxConfig 

type SandboxConfig struct {
	TemplateID         string `protobuf:"bytes,1,opt,name=templateID,proto3" json:"templateID,omitempty"`
	BuildID            string `protobuf:"bytes,2,opt,name=buildID,proto3" json:"buildID,omitempty"`
	KernelVersion      string `protobuf:"bytes,3,opt,name=kernelVersion,proto3" json:"kernelVersion,omitempty"`
	FirecrackerVersion string `protobuf:"bytes,4,opt,name=firecrackerVersion,proto3" json:"firecrackerVersion,omitempty"`
	HugePages          bool   `protobuf:"varint,5,opt,name=hugePages,proto3" json:"hugePages,omitempty"`
	TeamID             string `protobuf:"bytes,6,opt,name=teamID,proto3" json:"teamID,omitempty"`
	// Maximum length of the instance in Hours
	MaxInstanceLength int64             `protobuf:"varint,7,opt,name=maxInstanceLength,proto3" json:"maxInstanceLength,omitempty"`
	Alias             *string           `protobuf:"bytes,8,opt,name=alias,proto3,oneof" json:"alias,omitempty"`
	SandboxID         string            `protobuf:"bytes,9,opt,name=sandboxID,proto3" json:"sandboxID,omitempty"`
	Metadata          map[string]string `` /* 158-byte string literal not displayed */
	EnvdVersion       string            `protobuf:"bytes,11,opt,name=envdVersion,proto3" json:"envdVersion,omitempty"`
	EnvVars           map[string]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SandboxConfig) Descriptor deprecated 

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

Deprecated: Use SandboxConfig.ProtoReflect.Descriptor instead.

func (*SandboxConfig) GetAlias 

func (x *SandboxConfig) GetAlias() string

func (*SandboxConfig) GetBuildID 

func (x *SandboxConfig) GetBuildID() string

func (*SandboxConfig) GetEnvVars 

func (x *SandboxConfig) GetEnvVars() map[string]string

func (*SandboxConfig) GetEnvdVersion 

func (x *SandboxConfig) GetEnvdVersion() string

func (*SandboxConfig) GetFirecrackerVersion 

func (x *SandboxConfig) GetFirecrackerVersion() string

func (*SandboxConfig) GetHugePages 

func (x *SandboxConfig) GetHugePages() bool

func (*SandboxConfig) GetKernelVersion 

func (x *SandboxConfig) GetKernelVersion() string

func (*SandboxConfig) GetMaxInstanceLength 

func (x *SandboxConfig) GetMaxInstanceLength() int64

func (*SandboxConfig) GetMetadata 

func (x *SandboxConfig) GetMetadata() map[string]string

func (*SandboxConfig) GetSandboxID 

func (x *SandboxConfig) GetSandboxID() string

func (*SandboxConfig) GetTeamID 

func (x *SandboxConfig) GetTeamID() string

func (*SandboxConfig) GetTemplateID 

func (x *SandboxConfig) GetTemplateID() string

func (*SandboxConfig) ProtoMessage 

func (*SandboxConfig) ProtoMessage()

func (*SandboxConfig) ProtoReflect 

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

func (*SandboxConfig) Reset 

func (x *SandboxConfig) Reset()

func (*SandboxConfig) String 

func (x *SandboxConfig) String() string

type SandboxCreateRequest 

type SandboxCreateRequest struct {
	Sandbox   *SandboxConfig         `protobuf:"bytes,1,opt,name=sandbox,proto3" json:"sandbox,omitempty"`
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

Data required for creating a new sandbox.

func (*SandboxCreateRequest) Descriptor deprecated 

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

Deprecated: Use SandboxCreateRequest.ProtoReflect.Descriptor instead.

func (*SandboxCreateRequest) GetEndTime 

func (x *SandboxCreateRequest) GetEndTime() *timestamppb.Timestamp

func (*SandboxCreateRequest) GetSandbox 

func (x *SandboxCreateRequest) GetSandbox() *SandboxConfig

func (*SandboxCreateRequest) GetStartTime 

func (x *SandboxCreateRequest) GetStartTime() *timestamppb.Timestamp

func (*SandboxCreateRequest) ProtoMessage 

func (*SandboxCreateRequest) ProtoMessage()

func (*SandboxCreateRequest) ProtoReflect 

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

func (*SandboxCreateRequest) Reset 

func (x *SandboxCreateRequest) Reset()

func (*SandboxCreateRequest) String 

func (x *SandboxCreateRequest) String() string

type SandboxCreateResponse 

type SandboxCreateResponse struct {
	ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

Data about the sandbox.

func (*SandboxCreateResponse) Descriptor deprecated 

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

Deprecated: Use SandboxCreateResponse.ProtoReflect.Descriptor instead.

func (*SandboxCreateResponse) GetClientID 

func (x *SandboxCreateResponse) GetClientID() string

func (*SandboxCreateResponse) ProtoMessage 

func (*SandboxCreateResponse) ProtoMessage()

func (*SandboxCreateResponse) ProtoReflect 

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

func (*SandboxCreateResponse) Reset 

func (x *SandboxCreateResponse) Reset()

func (*SandboxCreateResponse) String 

func (x *SandboxCreateResponse) String() string

type SandboxListResponse 

type SandboxListResponse struct {
	Sandboxes []*RunningSandbox `protobuf:"bytes,1,rep,name=sandboxes,proto3" json:"sandboxes,omitempty"`
	// contains filtered or unexported fields
}

Data returned after listing all the sandboxes.

func (*SandboxListResponse) Descriptor deprecated 

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

Deprecated: Use SandboxListResponse.ProtoReflect.Descriptor instead.

func (*SandboxListResponse) GetSandboxes 

func (x *SandboxListResponse) GetSandboxes() []*RunningSandbox

func (*SandboxListResponse) ProtoMessage 

func (*SandboxListResponse) ProtoMessage()

func (*SandboxListResponse) ProtoReflect 

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

func (*SandboxListResponse) Reset 

func (x *SandboxListResponse) Reset()

func (*SandboxListResponse) String 

func (x *SandboxListResponse) String() string

type SandboxRequest 

type SandboxRequest struct {
	SandboxID string `protobuf:"bytes,1,opt,name=sandboxID,proto3" json:"sandboxID,omitempty"`
	// contains filtered or unexported fields
}

Data required for action on a specified sandbox.

func (*SandboxRequest) Descriptor deprecated 

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

Deprecated: Use SandboxRequest.ProtoReflect.Descriptor instead.

func (*SandboxRequest) GetSandboxID 

func (x *SandboxRequest) GetSandboxID() string

func (*SandboxRequest) ProtoMessage 

func (*SandboxRequest) ProtoMessage()

func (*SandboxRequest) ProtoReflect 

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

func (*SandboxRequest) Reset 

func (x *SandboxRequest) Reset()

func (*SandboxRequest) String 

func (x *SandboxRequest) String() string

type SandboxServer 

type SandboxServer interface {
	// Create is a gRPC service that creates a new sandbox.
	Create(context.Context, *SandboxCreateRequest) (*SandboxCreateResponse, error)
	// Update is a gRPC service that updates a sandbox.
	Update(context.Context, *SandboxUpdateRequest) (*emptypb.Empty, error)
	// List is a gRPC service that returns a list of all the sandboxes.
	List(context.Context, *emptypb.Empty) (*SandboxListResponse, error)
	// Delete is a gRPC service that kills a sandbox.
	Delete(context.Context, *SandboxRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

SandboxServer is the server API for Sandbox service. All implementations must embed UnimplementedSandboxServer for forward compatibility

type SandboxUpdateRequest 

type SandboxUpdateRequest struct {
	SandboxID string                 `protobuf:"bytes,1,opt,name=sandboxID,proto3" json:"sandboxID,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

Data required for creating a new sandbox.

func (*SandboxUpdateRequest) Descriptor deprecated 

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

Deprecated: Use SandboxUpdateRequest.ProtoReflect.Descriptor instead.

func (*SandboxUpdateRequest) GetEndTime 

func (x *SandboxUpdateRequest) GetEndTime() *timestamppb.Timestamp

func (*SandboxUpdateRequest) GetSandboxID 

func (x *SandboxUpdateRequest) GetSandboxID() string

func (*SandboxUpdateRequest) ProtoMessage 

func (*SandboxUpdateRequest) ProtoMessage()

func (*SandboxUpdateRequest) ProtoReflect 

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

func (*SandboxUpdateRequest) Reset 

func (x *SandboxUpdateRequest) Reset()

func (*SandboxUpdateRequest) String 

func (x *SandboxUpdateRequest) String() string

type UnimplementedSandboxServer 

type UnimplementedSandboxServer struct {
}

UnimplementedSandboxServer must be embedded to have forward compatible implementations.

func (UnimplementedSandboxServer) Create 

func (UnimplementedSandboxServer) Create(context.Context, *SandboxCreateRequest) (*SandboxCreateResponse, error)

func (UnimplementedSandboxServer) Delete 

func (UnimplementedSandboxServer) Delete(context.Context, *SandboxRequest) (*emptypb.Empty, error)

func (UnimplementedSandboxServer) List 

func (UnimplementedSandboxServer) List(context.Context, *emptypb.Empty) (*SandboxListResponse, error)

func (UnimplementedSandboxServer) Update 

func (UnimplementedSandboxServer) Update(context.Context, *SandboxUpdateRequest) (*emptypb.Empty, error)

type UnsafeSandboxServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.