Documentation
¶
Index ¶
- func RegisterOrchestratorServer(s *grpc.Server, srv OrchestratorServer)
- type OrchestratorClient
- type OrchestratorServer
- type StartVMReq
- func (*StartVMReq) Descriptor() ([]byte, []int)
- func (m *StartVMReq) GetId() string
- func (m *StartVMReq) GetImage() string
- func (*StartVMReq) ProtoMessage()
- func (m *StartVMReq) Reset()
- func (m *StartVMReq) String() string
- func (m *StartVMReq) XXX_DiscardUnknown()
- func (m *StartVMReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartVMReq) XXX_Merge(src proto.Message)
- func (m *StartVMReq) XXX_Size() int
- func (m *StartVMReq) XXX_Unmarshal(b []byte) error
- type StartVMResp
- func (*StartVMResp) Descriptor() ([]byte, []int)
- func (m *StartVMResp) GetMessage() string
- func (m *StartVMResp) GetProfile() string
- func (*StartVMResp) ProtoMessage()
- func (m *StartVMResp) Reset()
- func (m *StartVMResp) String() string
- func (m *StartVMResp) XXX_DiscardUnknown()
- func (m *StartVMResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartVMResp) XXX_Merge(src proto.Message)
- func (m *StartVMResp) XXX_Size() int
- func (m *StartVMResp) XXX_Unmarshal(b []byte) error
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) GetMessage() string
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) String() string
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
- type StopSingleVMReq
- func (*StopSingleVMReq) Descriptor() ([]byte, []int)
- func (m *StopSingleVMReq) GetId() string
- func (*StopSingleVMReq) ProtoMessage()
- func (m *StopSingleVMReq) Reset()
- func (m *StopSingleVMReq) String() string
- func (m *StopSingleVMReq) XXX_DiscardUnknown()
- func (m *StopSingleVMReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopSingleVMReq) XXX_Merge(src proto.Message)
- func (m *StopSingleVMReq) XXX_Size() int
- func (m *StopSingleVMReq) XXX_Unmarshal(b []byte) error
- type StopVMsReq
- func (*StopVMsReq) Descriptor() ([]byte, []int)
- func (m *StopVMsReq) GetAllVms() bool
- func (*StopVMsReq) ProtoMessage()
- func (m *StopVMsReq) Reset()
- func (m *StopVMsReq) String() string
- func (m *StopVMsReq) XXX_DiscardUnknown()
- func (m *StopVMsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopVMsReq) XXX_Merge(src proto.Message)
- func (m *StopVMsReq) XXX_Size() int
- func (m *StopVMsReq) XXX_Unmarshal(b []byte) error
- type UnimplementedOrchestratorServer
- func (*UnimplementedOrchestratorServer) StartVM(ctx context.Context, req *StartVMReq) (*StartVMResp, error)
- func (*UnimplementedOrchestratorServer) StopSingleVM(ctx context.Context, req *StopSingleVMReq) (*Status, error)
- func (*UnimplementedOrchestratorServer) StopVMs(ctx context.Context, req *StopVMsReq) (*Status, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterOrchestratorServer ¶
func RegisterOrchestratorServer(s *grpc.Server, srv OrchestratorServer)
Types ¶
type OrchestratorClient ¶
type OrchestratorClient interface {
StartVM(ctx context.Context, in *StartVMReq, opts ...grpc.CallOption) (*StartVMResp, error)
StopVMs(ctx context.Context, in *StopVMsReq, opts ...grpc.CallOption) (*Status, error)
StopSingleVM(ctx context.Context, in *StopSingleVMReq, opts ...grpc.CallOption) (*Status, error)
}
OrchestratorClient is the client API for Orchestrator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOrchestratorClient ¶
func NewOrchestratorClient(cc grpc.ClientConnInterface) OrchestratorClient
type OrchestratorServer ¶
type OrchestratorServer interface {
StartVM(context.Context, *StartVMReq) (*StartVMResp, error)
StopVMs(context.Context, *StopVMsReq) (*Status, error)
StopSingleVM(context.Context, *StopSingleVMReq) (*Status, error)
}
OrchestratorServer is the server API for Orchestrator service.
type StartVMReq ¶
type StartVMReq struct {
Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StartVMReq) Descriptor ¶
func (*StartVMReq) Descriptor() ([]byte, []int)
func (*StartVMReq) GetId ¶
func (m *StartVMReq) GetId() string
func (*StartVMReq) GetImage ¶
func (m *StartVMReq) GetImage() string
func (*StartVMReq) ProtoMessage ¶
func (*StartVMReq) ProtoMessage()
func (*StartVMReq) Reset ¶
func (m *StartVMReq) Reset()
func (*StartVMReq) String ¶
func (m *StartVMReq) String() string
func (*StartVMReq) XXX_DiscardUnknown ¶
func (m *StartVMReq) XXX_DiscardUnknown()
func (*StartVMReq) XXX_Marshal ¶
func (m *StartVMReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartVMReq) XXX_Merge ¶
func (m *StartVMReq) XXX_Merge(src proto.Message)
func (*StartVMReq) XXX_Size ¶
func (m *StartVMReq) XXX_Size() int
func (*StartVMReq) XXX_Unmarshal ¶
func (m *StartVMReq) XXX_Unmarshal(b []byte) error
type StartVMResp ¶
type StartVMResp struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
Profile string `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StartVMResp) Descriptor ¶
func (*StartVMResp) Descriptor() ([]byte, []int)
func (*StartVMResp) GetMessage ¶
func (m *StartVMResp) GetMessage() string
func (*StartVMResp) GetProfile ¶
func (m *StartVMResp) GetProfile() string
func (*StartVMResp) ProtoMessage ¶
func (*StartVMResp) ProtoMessage()
func (*StartVMResp) Reset ¶
func (m *StartVMResp) Reset()
func (*StartVMResp) String ¶
func (m *StartVMResp) String() string
func (*StartVMResp) XXX_DiscardUnknown ¶
func (m *StartVMResp) XXX_DiscardUnknown()
func (*StartVMResp) XXX_Marshal ¶
func (m *StartVMResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartVMResp) XXX_Merge ¶
func (m *StartVMResp) XXX_Merge(src proto.Message)
func (*StartVMResp) XXX_Size ¶
func (m *StartVMResp) XXX_Size() int
func (*StartVMResp) XXX_Unmarshal ¶
func (m *StartVMResp) XXX_Unmarshal(b []byte) error
type Status ¶
type Status struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Status) Descriptor ¶
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
type StopSingleVMReq ¶
type StopSingleVMReq struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StopSingleVMReq) Descriptor ¶
func (*StopSingleVMReq) Descriptor() ([]byte, []int)
func (*StopSingleVMReq) GetId ¶
func (m *StopSingleVMReq) GetId() string
func (*StopSingleVMReq) ProtoMessage ¶
func (*StopSingleVMReq) ProtoMessage()
func (*StopSingleVMReq) Reset ¶
func (m *StopSingleVMReq) Reset()
func (*StopSingleVMReq) String ¶
func (m *StopSingleVMReq) String() string
func (*StopSingleVMReq) XXX_DiscardUnknown ¶
func (m *StopSingleVMReq) XXX_DiscardUnknown()
func (*StopSingleVMReq) XXX_Marshal ¶
func (m *StopSingleVMReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopSingleVMReq) XXX_Merge ¶
func (m *StopSingleVMReq) XXX_Merge(src proto.Message)
func (*StopSingleVMReq) XXX_Size ¶
func (m *StopSingleVMReq) XXX_Size() int
func (*StopSingleVMReq) XXX_Unmarshal ¶
func (m *StopSingleVMReq) XXX_Unmarshal(b []byte) error
type StopVMsReq ¶
type StopVMsReq struct {
AllVms bool `protobuf:"varint,1,opt,name=all_vms,json=allVms,proto3" json:"all_vms,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StopVMsReq) Descriptor ¶
func (*StopVMsReq) Descriptor() ([]byte, []int)
func (*StopVMsReq) GetAllVms ¶
func (m *StopVMsReq) GetAllVms() bool
func (*StopVMsReq) ProtoMessage ¶
func (*StopVMsReq) ProtoMessage()
func (*StopVMsReq) Reset ¶
func (m *StopVMsReq) Reset()
func (*StopVMsReq) String ¶
func (m *StopVMsReq) String() string
func (*StopVMsReq) XXX_DiscardUnknown ¶
func (m *StopVMsReq) XXX_DiscardUnknown()
func (*StopVMsReq) XXX_Marshal ¶
func (m *StopVMsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopVMsReq) XXX_Merge ¶
func (m *StopVMsReq) XXX_Merge(src proto.Message)
func (*StopVMsReq) XXX_Size ¶
func (m *StopVMsReq) XXX_Size() int
func (*StopVMsReq) XXX_Unmarshal ¶
func (m *StopVMsReq) XXX_Unmarshal(b []byte) error
type UnimplementedOrchestratorServer ¶
type UnimplementedOrchestratorServer struct {
}
UnimplementedOrchestratorServer can be embedded to have forward compatible implementations.
func (*UnimplementedOrchestratorServer) StartVM ¶
func (*UnimplementedOrchestratorServer) StartVM(ctx context.Context, req *StartVMReq) (*StartVMResp, error)
func (*UnimplementedOrchestratorServer) StopSingleVM ¶
func (*UnimplementedOrchestratorServer) StopSingleVM(ctx context.Context, req *StopSingleVMReq) (*Status, error)
func (*UnimplementedOrchestratorServer) StopVMs ¶
func (*UnimplementedOrchestratorServer) StopVMs(ctx context.Context, req *StopVMsReq) (*Status, error)
Click to show internal directories.
Click to hide internal directories.