celestial

type CelestialClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	Update(ctx context.Context, opts ...grpc.CallOption) (Celestial_UpdateClient, error)
	Stop(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

type CelestialServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	Init(context.Context, *InitRequest) (*Empty, error)
	Update(Celestial_UpdateServer) error
	Stop(context.Context, *Empty) (*Empty, error)
}

type Celestial_UpdateClient interface {
	Send(*StateUpdateRequest) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Celestial_UpdateServer interface {
	SendAndClose(*Empty) error
	Recv() (*StateUpdateRequest, error)
	grpc.ServerStream
}

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

type InitRequest struct {
	Hosts    []*InitRequest_Host    `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	Machines []*InitRequest_Machine `protobuf:"bytes,2,rep,name=machines,proto3" json:"machines,omitempty"`
	// contains filtered or unexported fields
}

type InitRequest_Host struct {
	Id             uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PeerPublicKey  string `protobuf:"bytes,2,opt,name=peer_public_key,json=peerPublicKey,proto3" json:"peer_public_key,omitempty"`
	PeerListenAddr string `protobuf:"bytes,3,opt,name=peer_listen_addr,json=peerListenAddr,proto3" json:"peer_listen_addr,omitempty"`
	// contains filtered or unexported fields
}

type InitRequest_Machine struct {
	Id   *MachineID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name *string    `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// should actually be 8 bit but protobuf doesn't support uint8...
	Host   uint32                             `protobuf:"varint,3,opt,name=host,proto3" json:"host,omitempty"`
	Config *InitRequest_Machine_MachineConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type InitRequest_Machine_MachineConfig struct {

	// should also be 8 bit but protobuf doesn't support uint8...
	VcpuCount      uint32   `protobuf:"varint,1,opt,name=vcpu_count,json=vcpuCount,proto3" json:"vcpu_count,omitempty"`
	Ram            uint64   `protobuf:"varint,2,opt,name=ram,proto3" json:"ram,omitempty"`
	DiskSize       uint64   `protobuf:"varint,3,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	RootImage      string   `protobuf:"bytes,4,opt,name=root_image,json=rootImage,proto3" json:"root_image,omitempty"`
	Kernel         string   `protobuf:"bytes,5,opt,name=kernel,proto3" json:"kernel,omitempty"`
	BootParameters []string `protobuf:"bytes,6,rep,name=boot_parameters,json=bootParameters,proto3" json:"boot_parameters,omitempty"`
	// contains filtered or unexported fields
}

type MachineID struct {
	Group uint32 `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"`
	Id    uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type RegisterRequest struct {
	Host uint32 `protobuf:"varint,1,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

type RegisterResponse struct {
	AvailableCpus  uint32 `protobuf:"varint,1,opt,name=available_cpus,json=availableCpus,proto3" json:"available_cpus,omitempty"`
	AvailableRam   uint64 `protobuf:"varint,2,opt,name=available_ram,json=availableRam,proto3" json:"available_ram,omitempty"`
	PeerPublicKey  string `protobuf:"bytes,3,opt,name=peer_public_key,json=peerPublicKey,proto3" json:"peer_public_key,omitempty"`
	PeerListenAddr string `protobuf:"bytes,4,opt,name=peer_listen_addr,json=peerListenAddr,proto3" json:"peer_listen_addr,omitempty"`
	// contains filtered or unexported fields
}

type StateUpdateRequest struct {
	MachineDiffs []*StateUpdateRequest_MachineDiff `protobuf:"bytes,1,rep,name=machine_diffs,json=machineDiffs,proto3" json:"machine_diffs,omitempty"`
	NetworkDiffs []*StateUpdateRequest_NetworkDiff `protobuf:"bytes,2,rep,name=network_diffs,json=networkDiffs,proto3" json:"network_diffs,omitempty"`
	// contains filtered or unexported fields
}

type StateUpdateRequest_MachineDiff struct {
	Active VMState    `protobuf:"varint,1,opt,name=active,proto3,enum=openfogstack.celestial.celestial.VMState" json:"active,omitempty"`
	Id     *MachineID `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StateUpdateRequest_NetworkDiff struct {
	Blocked       bool       `protobuf:"varint,1,opt,name=blocked,proto3" json:"blocked,omitempty"`
	Source        *MachineID `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Target        *MachineID `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	LatencyUs     uint32     `protobuf:"varint,4,opt,name=latency_us,json=latencyUs,proto3" json:"latency_us,omitempty"`
	BandwidthKbps uint64     `protobuf:"varint,5,opt,name=bandwidth_kbps,json=bandwidthKbps,proto3" json:"bandwidth_kbps,omitempty"`
	// used for path reconstruction
	Next *MachineID `protobuf:"bytes,6,opt,name=next,proto3" json:"next,omitempty"`
	Prev *MachineID `protobuf:"bytes,7,opt,name=prev,proto3" json:"prev,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCelestialServer struct {
}

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

type VMState int32