Help us shape the future of Go! Take the 2026 Go Developer Survey

rpc

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Sep 29, 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
	NodeStatusStream codes.Code = 10310

	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
	WorkloadStatusStream codes.Code = 1058

	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.