Documentation
¶
Index ¶
- Variables
- func RegisterCelestialServer(s grpc.ServiceRegistrar, srv CelestialServer)
- type CelestialClient
- type CelestialServer
- type CreateMachineRequest
- func (*CreateMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateMachineRequest) GetFirecrackerconfig() *FirecrackerConfig
- func (x *CreateMachineRequest) GetMachine() *Machine
- func (x *CreateMachineRequest) GetNetworkconfig() *NetworkConfig
- func (x *CreateMachineRequest) GetStatus() bool
- func (*CreateMachineRequest) ProtoMessage()
- func (x *CreateMachineRequest) ProtoReflect() protoreflect.Message
- func (x *CreateMachineRequest) Reset()
- func (x *CreateMachineRequest) String() string
- type CreateRemoteMachineRequest
- func (*CreateRemoteMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRemoteMachineRequest) GetMachine() *Machine
- func (x *CreateRemoteMachineRequest) GetNetworkconfig() *NetworkConfig
- func (*CreateRemoteMachineRequest) ProtoMessage()
- func (x *CreateRemoteMachineRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRemoteMachineRequest) Reset()
- func (x *CreateRemoteMachineRequest) String() string
- type Empty
- type FirecrackerConfig
- func (*FirecrackerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *FirecrackerConfig) GetBootparams() string
- func (x *FirecrackerConfig) GetDisk() uint64
- func (x *FirecrackerConfig) GetHt() bool
- func (x *FirecrackerConfig) GetKernel() string
- func (x *FirecrackerConfig) GetMem() uint64
- func (x *FirecrackerConfig) GetRootfs() string
- func (x *FirecrackerConfig) GetVcpu() uint64
- func (*FirecrackerConfig) ProtoMessage()
- func (x *FirecrackerConfig) ProtoReflect() protoreflect.Message
- func (x *FirecrackerConfig) Reset()
- func (x *FirecrackerConfig) String() string
- type HostInfo
- type InitRemotesRequest
- func (*InitRemotesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitRemotesRequest) GetIndex() uint64
- func (x *InitRemotesRequest) GetRemotehosts() []*RemoteHost
- func (*InitRemotesRequest) ProtoMessage()
- func (x *InitRemotesRequest) ProtoReflect() protoreflect.Message
- func (x *InitRemotesRequest) Reset()
- func (x *InitRemotesRequest) String() string
- type InitRequest
- func (*InitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitRequest) GetDatabase() bool
- func (x *InitRequest) GetDatabaseHost() string
- func (x *InitRequest) GetShellcount() uint64
- func (x *InitRequest) GetShells() []*Shell
- func (*InitRequest) ProtoMessage()
- func (x *InitRequest) ProtoReflect() protoreflect.Message
- func (x *InitRequest) Reset()
- func (x *InitRequest) String() string
- type Machine
- func (*Machine) Descriptor() ([]byte, []int)deprecated
- func (x *Machine) GetId() uint64
- func (x *Machine) GetName() string
- func (x *Machine) GetShell() int64
- func (*Machine) ProtoMessage()
- func (x *Machine) ProtoReflect() protoreflect.Message
- func (x *Machine) Reset()
- func (x *Machine) String() string
- type ModifyLinkRequest
- func (*ModifyLinkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ModifyLinkRequest) GetB() *Machine
- func (x *ModifyLinkRequest) GetBandwidth() uint64
- func (x *ModifyLinkRequest) GetLatency() float64
- func (*ModifyLinkRequest) ProtoMessage()
- func (x *ModifyLinkRequest) ProtoReflect() protoreflect.Message
- func (x *ModifyLinkRequest) Reset()
- func (x *ModifyLinkRequest) String() string
- type ModifyLinksRequest
- func (*ModifyLinksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ModifyLinksRequest) GetA() *Machine
- func (x *ModifyLinksRequest) GetModify() []*ModifyLinkRequest
- func (x *ModifyLinksRequest) GetRemove() []*RemoveLinkRequest
- func (*ModifyLinksRequest) ProtoMessage()
- func (x *ModifyLinksRequest) ProtoReflect() protoreflect.Message
- func (x *ModifyLinksRequest) Reset()
- func (x *ModifyLinksRequest) String() string
- type ModifyMachineRequest
- func (*ModifyMachineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ModifyMachineRequest) GetMachine() *Machine
- func (x *ModifyMachineRequest) GetStatus() bool
- func (*ModifyMachineRequest) ProtoMessage()
- func (x *ModifyMachineRequest) ProtoReflect() protoreflect.Message
- func (x *ModifyMachineRequest) Reset()
- func (x *ModifyMachineRequest) String() string
- type NetworkConfig
- type ReadyInfo
- type RemoteHost
- type RemoveLinkRequest
- type Shell
- type UnimplementedCelestialServer
- func (UnimplementedCelestialServer) CreateMachine(context.Context, *CreateMachineRequest) (*Empty, error)
- func (UnimplementedCelestialServer) GetHostInfo(context.Context, *Empty) (*HostInfo, error)
- func (UnimplementedCelestialServer) HostReady(context.Context, *Empty) (*ReadyInfo, error)
- func (UnimplementedCelestialServer) Init(context.Context, *InitRequest) (*Empty, error)
- func (UnimplementedCelestialServer) InitRemotes(context.Context, *InitRemotesRequest) (*Empty, error)
- func (UnimplementedCelestialServer) ModifyLinks(context.Context, *ModifyLinksRequest) (*Empty, error)
- func (UnimplementedCelestialServer) ModifyMachine(context.Context, *ModifyMachineRequest) (*Empty, error)
- func (UnimplementedCelestialServer) StartPeering(context.Context, *Empty) (*Empty, error)
- type UnsafeCelestialServer
Constants ¶
This section is empty.
Variables ¶
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)
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 (x *CreateRemoteMachineRequest) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*HostInfo) ProtoMessage()
func (*HostInfo) ProtoReflect ¶
func (x *HostInfo) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Machine) ProtoMessage()
func (*Machine) ProtoReflect ¶
func (x *Machine) ProtoReflect() protoreflect.Message
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) GetCreated ¶
func (*ReadyInfo) ProtoMessage ¶
func (*ReadyInfo) ProtoMessage()
func (*ReadyInfo) ProtoReflect ¶
func (x *ReadyInfo) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Shell) ProtoMessage()
func (*Shell) ProtoReflect ¶
func (x *Shell) ProtoReflect() protoreflect.Message
type UnimplementedCelestialServer ¶
type UnimplementedCelestialServer struct {
}
UnimplementedCelestialServer should be embedded to have forward compatible implementations.
func (UnimplementedCelestialServer) CreateMachine ¶
func (UnimplementedCelestialServer) CreateMachine(context.Context, *CreateMachineRequest) (*Empty, error)
func (UnimplementedCelestialServer) GetHostInfo ¶
func (UnimplementedCelestialServer) Init ¶
func (UnimplementedCelestialServer) Init(context.Context, *InitRequest) (*Empty, error)
func (UnimplementedCelestialServer) InitRemotes ¶
func (UnimplementedCelestialServer) InitRemotes(context.Context, *InitRemotesRequest) (*Empty, error)
func (UnimplementedCelestialServer) ModifyLinks ¶
func (UnimplementedCelestialServer) ModifyLinks(context.Context, *ModifyLinksRequest) (*Empty, error)
func (UnimplementedCelestialServer) ModifyMachine ¶
func (UnimplementedCelestialServer) ModifyMachine(context.Context, *ModifyMachineRequest) (*Empty, error)
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.