rpc

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WatchServiceStatus codes.Code = 1001

	ListNetworks      codes.Code = 1011
	ConnectNetwork    codes.Code = 1012
	DisconnectNetwork codes.Code = 1013

	AddPod      codes.Code = 1021
	RemovePod   codes.Code = 1022
	GetPod      codes.Code = 1023
	ListPods    codes.Code = 1024
	PodResource codes.Code = 1025

	AddNode         codes.Code = 1031
	RemoveNode      codes.Code = 1032
	ListPodNodes    codes.Code = 1033
	GetNode         codes.Code = 1034
	SetNode         codes.Code = 1035
	SetNodeStatus   codes.Code = 1036
	GetNodeResource codes.Code = 1037
	GetNodeStatus   codes.Code = 1038
	GetNodeEngine   codes.Code = 1039

	CalculateCapacity codes.Code = 1041

	GetWorkload        codes.Code = 1051
	GetWorkloads       codes.Code = 1052
	ListWorkloads      codes.Code = 1053
	ListNodeWorkloads  codes.Code = 1054
	GetWorkloadsStatus codes.Code = 1055
	SetWorkloadsStatus codes.Code = 1056
	RawEngineStatus    codes.Code = 1057

	Copy          codes.Code = 1061
	Send          codes.Code = 1062
	SendLargeFile codes.Code = 1063

	BuildImage  codes.Code = 1071
	CacheImage  codes.Code = 1072
	RemoveImage codes.Code = 1073

	CreateWorkload     codes.Code = 1074
	ReplaceWorkload    codes.Code = 1075
	RemoveWorkload     codes.Code = 1076
	DissociateWorkload codes.Code = 1077
	ControlWorkload    codes.Code = 1078
	ExecuteWorkload    codes.Code = 1079
	ReallocResource    codes.Code = 10710
	LogStream          codes.Code = 10711
	RunAndWait         codes.Code = 10712
	ListImage          codes.Code = 10713
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Vibranium 

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

Vibranium implements the CoreRPC gRPC server.

func New 

func New(cluster cluster.Cluster, config types.Config, stop chan struct{}) *Vibranium

New returns a Vibranium serving cluster.

func (*Vibranium) AddNode 

func (v *Vibranium) AddNode(ctx context.Context, opts *pb.AddNodeOptions) (*pb.Node, error)

func (*Vibranium) AddPod 

func (v *Vibranium) AddPod(ctx context.Context, opts *pb.AddPodOptions) (*pb.Pod, error)

func (*Vibranium) BuildImage 

func (v *Vibranium) BuildImage(opts *pb.BuildImageOptions, stream pb.CoreRPC_BuildImageServer) error

func (*Vibranium) CacheImage 

func (v *Vibranium) CacheImage(opts *pb.CacheImageOptions, stream pb.CoreRPC_CacheImageServer) error

func (*Vibranium) CalculateCapacity 

func (v *Vibranium) CalculateCapacity(ctx context.Context, opts *pb.DeployOptions) (*pb.CapacityMessage, error)

func (*Vibranium) ConnectNetwork 

func (v *Vibranium) ConnectNetwork(ctx context.Context, opts *pb.ConnectNetworkOptions) (*pb.Network, error)

func (*Vibranium) ControlWorkload 

func (v *Vibranium) ControlWorkload(opts *pb.ControlWorkloadOptions, stream pb.CoreRPC_ControlWorkloadServer) error

func (*Vibranium) Copy 

func (v *Vibranium) Copy(opts *pb.CopyOptions, stream pb.CoreRPC_CopyServer) error

func (*Vibranium) CreateWorkload 

func (v *Vibranium) CreateWorkload(opts *pb.DeployOptions, stream pb.CoreRPC_CreateWorkloadServer) error

func (*Vibranium) DisconnectNetwork 

func (v *Vibranium) DisconnectNetwork(ctx context.Context, opts *pb.DisconnectNetworkOptions) (*pb.Empty, error)

func (*Vibranium) DissociateWorkload 

func (v *Vibranium) DissociateWorkload(opts *pb.DissociateWorkloadOptions, stream pb.CoreRPC_DissociateWorkloadServer) error

func (*Vibranium) ExecuteWorkload 

func (v *Vibranium) ExecuteWorkload(stream pb.CoreRPC_ExecuteWorkloadServer) error

func (*Vibranium) GetNode 

func (v *Vibranium) GetNode(ctx context.Context, opts *pb.GetNodeOptions) (*pb.Node, error)

func (*Vibranium) GetNodeEngineInfo 

func (v *Vibranium) GetNodeEngineInfo(ctx context.Context, opts *pb.GetNodeOptions) (*pb.Engine, error)

func (*Vibranium) GetNodeResource 

func (v *Vibranium) GetNodeResource(ctx context.Context, opts *pb.GetNodeResourceOptions) (*pb.NodeResource, error)

func (*Vibranium) GetNodeStatus 

func (v *Vibranium) GetNodeStatus(ctx context.Context, opts *pb.GetNodeStatusOptions) (*pb.NodeStatusStreamMessage, error)

func (*Vibranium) GetPod 

func (v *Vibranium) GetPod(ctx context.Context, opts *pb.GetPodOptions) (*pb.Pod, error)

func (*Vibranium) GetPodResource 

func (v *Vibranium) GetPodResource(opts *pb.GetPodOptions, stream pb.CoreRPC_GetPodResourceServer) error

func (*Vibranium) GetWorkload 

func (v *Vibranium) GetWorkload(ctx context.Context, ID *pb.WorkloadID) (*pb.Workload, error)

func (*Vibranium) GetWorkloads 

func (v *Vibranium) GetWorkloads(ctx context.Context, cids *pb.WorkloadIDs) (*pb.Workloads, error)

func (*Vibranium) GetWorkloadsStatus 

func (v *Vibranium) GetWorkloadsStatus(ctx context.Context, opts *pb.WorkloadIDs) (*pb.WorkloadsStatus, error)

func (*Vibranium) Info 

func (v *Vibranium) Info(context.Context, *pb.Empty) (*pb.CoreInfo, error)

func (*Vibranium) ListImage 

func (v *Vibranium) ListImage(opts *pb.ListImageOptions, stream pb.CoreRPC_ListImageServer) error

func (*Vibranium) ListNetworks 

func (v *Vibranium) ListNetworks(ctx context.Context, opts *pb.ListNetworkOptions) (*pb.Networks, error)

func (*Vibranium) ListNodeWorkloads 

func (v *Vibranium) ListNodeWorkloads(ctx context.Context, opts *pb.GetNodeOptions) (*pb.Workloads, error)

func (*Vibranium) ListPodNodes 

func (v *Vibranium) ListPodNodes(opts *pb.ListNodesOptions, stream pb.CoreRPC_ListPodNodesServer) error

func (*Vibranium) ListPods 

func (v *Vibranium) ListPods(ctx context.Context, _ *pb.Empty) (*pb.Pods, error)

func (*Vibranium) ListWorkloads 

func (v *Vibranium) ListWorkloads(opts *pb.ListWorkloadsOptions, stream pb.CoreRPC_ListWorkloadsServer) error

func (*Vibranium) LogStream 

func (v *Vibranium) LogStream(opts *pb.LogStreamOptions, stream pb.CoreRPC_LogStreamServer) error

func (*Vibranium) NodeStatusStream 

func (v *Vibranium) NodeStatusStream(_ *pb.Empty, stream pb.CoreRPC_NodeStatusStreamServer) error

func (*Vibranium) RawEngine 

func (v *Vibranium) RawEngine(ctx context.Context, opts *pb.RawEngineOptions) (*pb.RawEngineMessage, error)

func (*Vibranium) ReallocResource 

func (v *Vibranium) ReallocResource(ctx context.Context, opts *pb.ReallocOptions) (*pb.ReallocResourceMessage, error)

func (*Vibranium) RemoveImage 

func (v *Vibranium) RemoveImage(opts *pb.RemoveImageOptions, stream pb.CoreRPC_RemoveImageServer) error

func (*Vibranium) RemoveNode 

func (v *Vibranium) RemoveNode(ctx context.Context, opts *pb.RemoveNodeOptions) (*pb.Empty, error)

func (*Vibranium) RemovePod 

func (v *Vibranium) RemovePod(ctx context.Context, opts *pb.RemovePodOptions) (*pb.Empty, error)

func (*Vibranium) RemoveWorkload 

func (v *Vibranium) RemoveWorkload(opts *pb.RemoveWorkloadOptions, stream pb.CoreRPC_RemoveWorkloadServer) error

func (*Vibranium) ReplaceWorkload 

func (v *Vibranium) ReplaceWorkload(opts *pb.ReplaceOptions, stream pb.CoreRPC_ReplaceWorkloadServer) error

func (*Vibranium) RunAndWait 

func (v *Vibranium) RunAndWait(stream pb.CoreRPC_RunAndWaitServer) error

func (*Vibranium) Send 

func (v *Vibranium) Send(opts *pb.SendOptions, stream pb.CoreRPC_SendServer) error

func (*Vibranium) SendLargeFile 

func (v *Vibranium) SendLargeFile(stream pb.CoreRPC_SendLargeFileServer) error

func (*Vibranium) SetNode 

func (v *Vibranium) SetNode(ctx context.Context, opts *pb.SetNodeOptions) (*pb.Node, error)

func (*Vibranium) SetNodeStatus 

func (v *Vibranium) SetNodeStatus(ctx context.Context, opts *pb.SetNodeStatusOptions) (*pb.Empty, error)

func (*Vibranium) SetWorkloadsStatus 

func (v *Vibranium) SetWorkloadsStatus(ctx context.Context, opts *pb.SetWorkloadsStatusOptions) (*pb.WorkloadsStatus, error)

func (*Vibranium) Wait 

func (v *Vibranium) Wait()

Wait blocks until all in-flight tasks finish.

func (*Vibranium) WatchServiceStatus 

func (v *Vibranium) WatchServiceStatus(_ *pb.Empty, stream pb.CoreRPC_WatchServiceStatusServer) (err error)

func (*Vibranium) WorkloadStatusStream 

func (v *Vibranium) WorkloadStatusStream(opts *pb.WorkloadStatusStreamOptions, stream pb.CoreRPC_WorkloadStatusStreamServer) error

Source Files

View all Source files

Directories

Path Synopsis

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.