celestial

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Celestial_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "openfogstack.celestial.celestial.Celestial",
	HandlerType: (*CelestialServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHostInfo",
			Handler:    _Celestial_GetHostInfo_Handler,
		},
		{
			MethodName: "HostReady",
			Handler:    _Celestial_HostReady_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Celestial_Init_Handler,
		},
		{
			MethodName: "InitRemotes",
			Handler:    _Celestial_InitRemotes_Handler,
		},
		{
			MethodName: "StartPeering",
			Handler:    _Celestial_StartPeering_Handler,
		},
		{
			MethodName: "CreateMachine",
			Handler:    _Celestial_CreateMachine_Handler,
		},
		{
			MethodName: "ModifyMachine",
			Handler:    _Celestial_ModifyMachine_Handler,
		},
		{
			MethodName: "ModifyLinks",
			Handler:    _Celestial_ModifyLinks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "celestial.proto",
}

Celestial_ServiceDesc is the grpc.ServiceDesc for Celestial 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_celestial_proto protoreflect.FileDescriptor

Functions

func RegisterCelestialServer

func RegisterCelestialServer(s grpc.ServiceRegistrar, srv CelestialServer)

Types

type CelestialClient

type CelestialClient interface {
	GetHostInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HostInfo, error)
	HostReady(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReadyInfo, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	InitRemotes(ctx context.Context, in *InitRemotesRequest, opts ...grpc.CallOption) (*Empty, error)
	StartPeering(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*Empty, error)
	ModifyMachine(ctx context.Context, in *ModifyMachineRequest, opts ...grpc.CallOption) (*Empty, error)
	ModifyLinks(ctx context.Context, in *ModifyLinksRequest, opts ...grpc.CallOption) (*Empty, error)
}

CelestialClient is the client API for Celestial 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 NewCelestialClient

func NewCelestialClient(cc grpc.ClientConnInterface) CelestialClient

type CelestialServer

type CelestialServer interface {
	GetHostInfo(context.Context, *Empty) (*HostInfo, error)
	HostReady(context.Context, *Empty) (*ReadyInfo, error)
	Init(context.Context, *InitRequest) (*Empty, error)
	InitRemotes(context.Context, *InitRemotesRequest) (*Empty, error)
	StartPeering(context.Context, *Empty) (*Empty, error)
	CreateMachine(context.Context, *CreateMachineRequest) (*Empty, error)
	ModifyMachine(context.Context, *ModifyMachineRequest) (*Empty, error)
	ModifyLinks(context.Context, *ModifyLinksRequest) (*Empty, error)
}

CelestialServer is the server API for Celestial service. All implementations should embed UnimplementedCelestialServer for forward compatibility

type CreateMachineRequest

type CreateMachineRequest struct {
	Machine           *Machine           `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	Firecrackerconfig *FirecrackerConfig `protobuf:"bytes,2,opt,name=firecrackerconfig,proto3" json:"firecrackerconfig,omitempty"`
	Networkconfig     *NetworkConfig     `protobuf:"bytes,3,opt,name=networkconfig,proto3" json:"networkconfig,omitempty"`
	Status            bool               `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateMachineRequest) Descriptor deprecated

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

Deprecated: Use CreateMachineRequest.ProtoReflect.Descriptor instead.

func (*CreateMachineRequest) GetFirecrackerconfig

func (x *CreateMachineRequest) GetFirecrackerconfig() *FirecrackerConfig

func (*CreateMachineRequest) GetMachine

func (x *CreateMachineRequest) GetMachine() *Machine

func (*CreateMachineRequest) GetNetworkconfig

func (x *CreateMachineRequest) GetNetworkconfig() *NetworkConfig

func (*CreateMachineRequest) GetStatus

func (x *CreateMachineRequest) GetStatus() bool

func (*CreateMachineRequest) ProtoMessage

func (*CreateMachineRequest) ProtoMessage()

func (*CreateMachineRequest) ProtoReflect

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

func (*CreateMachineRequest) Reset

func (x *CreateMachineRequest) Reset()

func (*CreateMachineRequest) String

func (x *CreateMachineRequest) String() string

type CreateRemoteMachineRequest

type CreateRemoteMachineRequest struct {
	Machine       *Machine       `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	Networkconfig *NetworkConfig `protobuf:"bytes,3,opt,name=networkconfig,proto3" json:"networkconfig,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRemoteMachineRequest) Descriptor deprecated

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

Deprecated: Use CreateRemoteMachineRequest.ProtoReflect.Descriptor instead.

func (*CreateRemoteMachineRequest) GetMachine

func (x *CreateRemoteMachineRequest) GetMachine() *Machine

func (*CreateRemoteMachineRequest) GetNetworkconfig

func (x *CreateRemoteMachineRequest) GetNetworkconfig() *NetworkConfig

func (*CreateRemoteMachineRequest) ProtoMessage

func (*CreateRemoteMachineRequest) ProtoMessage()

func (*CreateRemoteMachineRequest) ProtoReflect

func (*CreateRemoteMachineRequest) Reset

func (x *CreateRemoteMachineRequest) Reset()

func (*CreateRemoteMachineRequest) String

func (x *CreateRemoteMachineRequest) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type FirecrackerConfig

type FirecrackerConfig struct {
	Vcpu       uint64 `protobuf:"varint,1,opt,name=vcpu,proto3" json:"vcpu,omitempty"`
	Mem        uint64 `protobuf:"varint,2,opt,name=mem,proto3" json:"mem,omitempty"`
	Ht         bool   `protobuf:"varint,3,opt,name=ht,proto3" json:"ht,omitempty"`
	Disk       uint64 `protobuf:"varint,4,opt,name=disk,proto3" json:"disk,omitempty"`
	Kernel     string `protobuf:"bytes,5,opt,name=kernel,proto3" json:"kernel,omitempty"`
	Rootfs     string `protobuf:"bytes,6,opt,name=rootfs,proto3" json:"rootfs,omitempty"`
	Bootparams string `protobuf:"bytes,7,opt,name=bootparams,proto3" json:"bootparams,omitempty"`
	// contains filtered or unexported fields
}

func (*FirecrackerConfig) Descriptor deprecated

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

Deprecated: Use FirecrackerConfig.ProtoReflect.Descriptor instead.

func (*FirecrackerConfig) GetBootparams

func (x *FirecrackerConfig) GetBootparams() string

func (*FirecrackerConfig) GetDisk

func (x *FirecrackerConfig) GetDisk() uint64

func (*FirecrackerConfig) GetHt

func (x *FirecrackerConfig) GetHt() bool

func (*FirecrackerConfig) GetKernel

func (x *FirecrackerConfig) GetKernel() string

func (*FirecrackerConfig) GetMem

func (x *FirecrackerConfig) GetMem() uint64

func (*FirecrackerConfig) GetRootfs

func (x *FirecrackerConfig) GetRootfs() string

func (*FirecrackerConfig) GetVcpu

func (x *FirecrackerConfig) GetVcpu() uint64

func (*FirecrackerConfig) ProtoMessage

func (*FirecrackerConfig) ProtoMessage()

func (*FirecrackerConfig) ProtoReflect

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

func (*FirecrackerConfig) Reset

func (x *FirecrackerConfig) Reset()

func (*FirecrackerConfig) String

func (x *FirecrackerConfig) String() string

type HostInfo

type HostInfo struct {
	Cpu uint64 `protobuf:"varint,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Mem uint64 `protobuf:"varint,2,opt,name=mem,proto3" json:"mem,omitempty"`
	// contains filtered or unexported fields
}

func (*HostInfo) Descriptor deprecated

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetCpu

func (x *HostInfo) GetCpu() uint64

func (*HostInfo) GetMem

func (x *HostInfo) GetMem() uint64

func (*HostInfo) ProtoMessage

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect

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

func (*HostInfo) Reset

func (x *HostInfo) Reset()

func (*HostInfo) String

func (x *HostInfo) String() string

type InitRemotesRequest

type InitRemotesRequest struct {
	Index       uint64        `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Remotehosts []*RemoteHost `protobuf:"bytes,2,rep,name=remotehosts,proto3" json:"remotehosts,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRemotesRequest) Descriptor deprecated

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

Deprecated: Use InitRemotesRequest.ProtoReflect.Descriptor instead.

func (*InitRemotesRequest) GetIndex

func (x *InitRemotesRequest) GetIndex() uint64

func (*InitRemotesRequest) GetRemotehosts

func (x *InitRemotesRequest) GetRemotehosts() []*RemoteHost

func (*InitRemotesRequest) ProtoMessage

func (*InitRemotesRequest) ProtoMessage()

func (*InitRemotesRequest) ProtoReflect

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

func (*InitRemotesRequest) Reset

func (x *InitRemotesRequest) Reset()

func (*InitRemotesRequest) String

func (x *InitRemotesRequest) String() string

type InitRequest

type InitRequest struct {
	Database     bool     `protobuf:"varint,1,opt,name=database,proto3" json:"database,omitempty"`
	DatabaseHost string   `protobuf:"bytes,2,opt,name=databaseHost,proto3" json:"databaseHost,omitempty"`
	Shellcount   uint64   `protobuf:"varint,3,opt,name=shellcount,proto3" json:"shellcount,omitempty"`
	Shells       []*Shell `protobuf:"bytes,4,rep,name=shells,proto3" json:"shells,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetDatabase

func (x *InitRequest) GetDatabase() bool

func (*InitRequest) GetDatabaseHost

func (x *InitRequest) GetDatabaseHost() string

func (*InitRequest) GetShellcount

func (x *InitRequest) GetShellcount() uint64

func (*InitRequest) GetShells

func (x *InitRequest) GetShells() []*Shell

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type Machine

type Machine struct {

	// allow -1 for ground stations
	Shell int64  `protobuf:"varint,1,opt,name=shell,proto3" json:"shell,omitempty"`
	Id    uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// name is only used for ground stations
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Machine) Descriptor deprecated

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

Deprecated: Use Machine.ProtoReflect.Descriptor instead.

func (*Machine) GetId

func (x *Machine) GetId() uint64

func (*Machine) GetName

func (x *Machine) GetName() string

func (*Machine) GetShell

func (x *Machine) GetShell() int64

func (*Machine) ProtoMessage

func (*Machine) ProtoMessage()

func (*Machine) ProtoReflect

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

func (*Machine) Reset

func (x *Machine) Reset()

func (*Machine) String

func (x *Machine) String() string

type ModifyLinkRequest

type ModifyLinkRequest struct {
	B         *Machine `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	Latency   float64  `protobuf:"fixed64,3,opt,name=latency,proto3" json:"latency,omitempty"`
	Bandwidth uint64   `protobuf:"varint,4,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyLinkRequest) Descriptor deprecated

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

Deprecated: Use ModifyLinkRequest.ProtoReflect.Descriptor instead.

func (*ModifyLinkRequest) GetB

func (x *ModifyLinkRequest) GetB() *Machine

func (*ModifyLinkRequest) GetBandwidth

func (x *ModifyLinkRequest) GetBandwidth() uint64

func (*ModifyLinkRequest) GetLatency

func (x *ModifyLinkRequest) GetLatency() float64

func (*ModifyLinkRequest) ProtoMessage

func (*ModifyLinkRequest) ProtoMessage()

func (*ModifyLinkRequest) ProtoReflect

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

func (*ModifyLinkRequest) Reset

func (x *ModifyLinkRequest) Reset()

func (*ModifyLinkRequest) String

func (x *ModifyLinkRequest) String() string

type ModifyLinksRequest

type ModifyLinksRequest struct {
	A      *Machine             `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	Remove []*RemoveLinkRequest `protobuf:"bytes,2,rep,name=remove,proto3" json:"remove,omitempty"`
	Modify []*ModifyLinkRequest `protobuf:"bytes,3,rep,name=modify,proto3" json:"modify,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyLinksRequest) Descriptor deprecated

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

Deprecated: Use ModifyLinksRequest.ProtoReflect.Descriptor instead.

func (*ModifyLinksRequest) GetA

func (x *ModifyLinksRequest) GetA() *Machine

func (*ModifyLinksRequest) GetModify

func (x *ModifyLinksRequest) GetModify() []*ModifyLinkRequest

func (*ModifyLinksRequest) GetRemove

func (x *ModifyLinksRequest) GetRemove() []*RemoveLinkRequest

func (*ModifyLinksRequest) ProtoMessage

func (*ModifyLinksRequest) ProtoMessage()

func (*ModifyLinksRequest) ProtoReflect

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

func (*ModifyLinksRequest) Reset

func (x *ModifyLinksRequest) Reset()

func (*ModifyLinksRequest) String

func (x *ModifyLinksRequest) String() string

type ModifyMachineRequest

type ModifyMachineRequest struct {
	Machine *Machine `protobuf:"bytes,1,opt,name=machine,proto3" json:"machine,omitempty"`
	Status  bool     `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyMachineRequest) Descriptor deprecated

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

Deprecated: Use ModifyMachineRequest.ProtoReflect.Descriptor instead.

func (*ModifyMachineRequest) GetMachine

func (x *ModifyMachineRequest) GetMachine() *Machine

func (*ModifyMachineRequest) GetStatus

func (x *ModifyMachineRequest) GetStatus() bool

func (*ModifyMachineRequest) ProtoMessage

func (*ModifyMachineRequest) ProtoMessage()

func (*ModifyMachineRequest) ProtoReflect

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

func (*ModifyMachineRequest) Reset

func (x *ModifyMachineRequest) Reset()

func (*ModifyMachineRequest) String

func (x *ModifyMachineRequest) String() string

type NetworkConfig

type NetworkConfig struct {
	Bandwidth uint64 `protobuf:"varint,1,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkConfig) Descriptor deprecated

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetBandwidth

func (x *NetworkConfig) GetBandwidth() uint64

func (*NetworkConfig) ProtoMessage

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect

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

func (*NetworkConfig) Reset

func (x *NetworkConfig) Reset()

func (*NetworkConfig) String

func (x *NetworkConfig) String() string

type ReadyInfo

type ReadyInfo struct {
	Ready   bool   `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	Created uint64 `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadyInfo) Descriptor deprecated

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

Deprecated: Use ReadyInfo.ProtoReflect.Descriptor instead.

func (*ReadyInfo) GetCreated

func (x *ReadyInfo) GetCreated() uint64

func (*ReadyInfo) GetReady

func (x *ReadyInfo) GetReady() bool

func (*ReadyInfo) ProtoMessage

func (*ReadyInfo) ProtoMessage()

func (*ReadyInfo) ProtoReflect

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

func (*ReadyInfo) Reset

func (x *ReadyInfo) Reset()

func (*ReadyInfo) String

func (x *ReadyInfo) String() string

type RemoteHost

type RemoteHost struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Addr  string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteHost) Descriptor deprecated

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

Deprecated: Use RemoteHost.ProtoReflect.Descriptor instead.

func (*RemoteHost) GetAddr

func (x *RemoteHost) GetAddr() string

func (*RemoteHost) GetIndex

func (x *RemoteHost) GetIndex() uint64

func (*RemoteHost) ProtoMessage

func (*RemoteHost) ProtoMessage()

func (*RemoteHost) ProtoReflect

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

func (*RemoteHost) Reset

func (x *RemoteHost) Reset()

func (*RemoteHost) String

func (x *RemoteHost) String() string

type RemoveLinkRequest

type RemoveLinkRequest struct {
	B *Machine `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveLinkRequest) Descriptor deprecated

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

Deprecated: Use RemoveLinkRequest.ProtoReflect.Descriptor instead.

func (*RemoveLinkRequest) GetB

func (x *RemoveLinkRequest) GetB() *Machine

func (*RemoveLinkRequest) ProtoMessage

func (*RemoveLinkRequest) ProtoMessage()

func (*RemoveLinkRequest) ProtoReflect

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

func (*RemoveLinkRequest) Reset

func (x *RemoveLinkRequest) Reset()

func (*RemoveLinkRequest) String

func (x *RemoveLinkRequest) String() string

type Shell

type Shell struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Planes uint64 `protobuf:"varint,2,opt,name=planes,proto3" json:"planes,omitempty"`
	// contains filtered or unexported fields
}

func (*Shell) Descriptor deprecated

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

Deprecated: Use Shell.ProtoReflect.Descriptor instead.

func (*Shell) GetId

func (x *Shell) GetId() uint64

func (*Shell) GetPlanes

func (x *Shell) GetPlanes() uint64

func (*Shell) ProtoMessage

func (*Shell) ProtoMessage()

func (*Shell) ProtoReflect

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

func (*Shell) Reset

func (x *Shell) Reset()

func (*Shell) String

func (x *Shell) String() string

type UnimplementedCelestialServer

type UnimplementedCelestialServer struct {
}

UnimplementedCelestialServer should be embedded to have forward compatible implementations.

func (UnimplementedCelestialServer) CreateMachine

func (UnimplementedCelestialServer) GetHostInfo

func (UnimplementedCelestialServer) HostReady

func (UnimplementedCelestialServer) Init

func (UnimplementedCelestialServer) InitRemotes

func (UnimplementedCelestialServer) ModifyMachine

func (UnimplementedCelestialServer) StartPeering

type UnsafeCelestialServer

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

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

Jump to

Keyboard shortcuts

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