Documentation ¶
Index ¶
- Variables
- func RegisterIdentityServer(s *grpc.Server, srv IdentityServer)
- func RegisterMachineServer(s *grpc.Server, srv MachineServer)
- type CreateMachineRequest
- func (*CreateMachineRequest) Descriptor() ([]byte, []int)
- func (m *CreateMachineRequest) GetLastKnownState() []byte
- func (m *CreateMachineRequest) GetMachineName() string
- func (m *CreateMachineRequest) GetProviderSpec() []byte
- func (m *CreateMachineRequest) GetSecrets() map[string][]byte
- func (*CreateMachineRequest) ProtoMessage()
- func (m *CreateMachineRequest) Reset()
- func (m *CreateMachineRequest) String() string
- func (m *CreateMachineRequest) XXX_DiscardUnknown()
- func (m *CreateMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateMachineRequest) XXX_Merge(src proto.Message)
- func (m *CreateMachineRequest) XXX_Size() int
- func (m *CreateMachineRequest) XXX_Unmarshal(b []byte) error
- type CreateMachineResponse
- func (*CreateMachineResponse) Descriptor() ([]byte, []int)
- func (m *CreateMachineResponse) GetLastKnownState() []byte
- func (m *CreateMachineResponse) GetNodeName() string
- func (m *CreateMachineResponse) GetProviderID() string
- func (*CreateMachineResponse) ProtoMessage()
- func (m *CreateMachineResponse) Reset()
- func (m *CreateMachineResponse) String() string
- func (m *CreateMachineResponse) XXX_DiscardUnknown()
- func (m *CreateMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateMachineResponse) XXX_Merge(src proto.Message)
- func (m *CreateMachineResponse) XXX_Size() int
- func (m *CreateMachineResponse) XXX_Unmarshal(b []byte) error
- type DeleteMachineRequest
- func (*DeleteMachineRequest) Descriptor() ([]byte, []int)
- func (m *DeleteMachineRequest) GetLastKnownState() []byte
- func (m *DeleteMachineRequest) GetMachineName() string
- func (m *DeleteMachineRequest) GetProviderID() string
- func (m *DeleteMachineRequest) GetProviderSpec() []byte
- func (m *DeleteMachineRequest) GetSecrets() map[string][]byte
- func (*DeleteMachineRequest) ProtoMessage()
- func (m *DeleteMachineRequest) Reset()
- func (m *DeleteMachineRequest) String() string
- func (m *DeleteMachineRequest) XXX_DiscardUnknown()
- func (m *DeleteMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DeleteMachineRequest) XXX_Merge(src proto.Message)
- func (m *DeleteMachineRequest) XXX_Size() int
- func (m *DeleteMachineRequest) XXX_Unmarshal(b []byte) error
- type DeleteMachineResponse
- func (*DeleteMachineResponse) Descriptor() ([]byte, []int)
- func (m *DeleteMachineResponse) GetLastKnownState() []byte
- func (*DeleteMachineResponse) ProtoMessage()
- func (m *DeleteMachineResponse) Reset()
- func (m *DeleteMachineResponse) String() string
- func (m *DeleteMachineResponse) XXX_DiscardUnknown()
- func (m *DeleteMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DeleteMachineResponse) XXX_Merge(src proto.Message)
- func (m *DeleteMachineResponse) XXX_Size() int
- func (m *DeleteMachineResponse) XXX_Unmarshal(b []byte) error
- type GetMachineStatusRequest
- func (*GetMachineStatusRequest) Descriptor() ([]byte, []int)
- func (m *GetMachineStatusRequest) GetMachineName() string
- func (m *GetMachineStatusRequest) GetProviderID() string
- func (m *GetMachineStatusRequest) GetProviderSpec() []byte
- func (m *GetMachineStatusRequest) GetSecrets() map[string][]byte
- func (*GetMachineStatusRequest) ProtoMessage()
- func (m *GetMachineStatusRequest) Reset()
- func (m *GetMachineStatusRequest) String() string
- func (m *GetMachineStatusRequest) XXX_DiscardUnknown()
- func (m *GetMachineStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetMachineStatusRequest) XXX_Merge(src proto.Message)
- func (m *GetMachineStatusRequest) XXX_Size() int
- func (m *GetMachineStatusRequest) XXX_Unmarshal(b []byte) error
- type GetMachineStatusResponse
- func (*GetMachineStatusResponse) Descriptor() ([]byte, []int)
- func (m *GetMachineStatusResponse) GetNodeName() string
- func (m *GetMachineStatusResponse) GetProviderID() string
- func (*GetMachineStatusResponse) ProtoMessage()
- func (m *GetMachineStatusResponse) Reset()
- func (m *GetMachineStatusResponse) String() string
- func (m *GetMachineStatusResponse) XXX_DiscardUnknown()
- func (m *GetMachineStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetMachineStatusResponse) XXX_Merge(src proto.Message)
- func (m *GetMachineStatusResponse) XXX_Size() int
- func (m *GetMachineStatusResponse) XXX_Unmarshal(b []byte) error
- type GetPluginCapabilitiesRequest
- func (*GetPluginCapabilitiesRequest) Descriptor() ([]byte, []int)
- func (*GetPluginCapabilitiesRequest) ProtoMessage()
- func (m *GetPluginCapabilitiesRequest) Reset()
- func (m *GetPluginCapabilitiesRequest) String() string
- func (m *GetPluginCapabilitiesRequest) XXX_DiscardUnknown()
- func (m *GetPluginCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetPluginCapabilitiesRequest) XXX_Merge(src proto.Message)
- func (m *GetPluginCapabilitiesRequest) XXX_Size() int
- func (m *GetPluginCapabilitiesRequest) XXX_Unmarshal(b []byte) error
- type GetPluginCapabilitiesResponse
- func (*GetPluginCapabilitiesResponse) Descriptor() ([]byte, []int)
- func (m *GetPluginCapabilitiesResponse) GetCapabilities() []*PluginCapability
- func (*GetPluginCapabilitiesResponse) ProtoMessage()
- func (m *GetPluginCapabilitiesResponse) Reset()
- func (m *GetPluginCapabilitiesResponse) String() string
- func (m *GetPluginCapabilitiesResponse) XXX_DiscardUnknown()
- func (m *GetPluginCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetPluginCapabilitiesResponse) XXX_Merge(src proto.Message)
- func (m *GetPluginCapabilitiesResponse) XXX_Size() int
- func (m *GetPluginCapabilitiesResponse) XXX_Unmarshal(b []byte) error
- type GetPluginInfoRequest
- func (*GetPluginInfoRequest) Descriptor() ([]byte, []int)
- func (*GetPluginInfoRequest) ProtoMessage()
- func (m *GetPluginInfoRequest) Reset()
- func (m *GetPluginInfoRequest) String() string
- func (m *GetPluginInfoRequest) XXX_DiscardUnknown()
- func (m *GetPluginInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetPluginInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetPluginInfoRequest) XXX_Size() int
- func (m *GetPluginInfoRequest) XXX_Unmarshal(b []byte) error
- type GetPluginInfoResponse
- func (*GetPluginInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetPluginInfoResponse) GetManifest() map[string]string
- func (m *GetPluginInfoResponse) GetName() string
- func (m *GetPluginInfoResponse) GetVersion() string
- func (*GetPluginInfoResponse) ProtoMessage()
- func (m *GetPluginInfoResponse) Reset()
- func (m *GetPluginInfoResponse) String() string
- func (m *GetPluginInfoResponse) XXX_DiscardUnknown()
- func (m *GetPluginInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetPluginInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetPluginInfoResponse) XXX_Size() int
- func (m *GetPluginInfoResponse) XXX_Unmarshal(b []byte) error
- type GetVolumeIDsRequest
- func (*GetVolumeIDsRequest) Descriptor() ([]byte, []int)
- func (m *GetVolumeIDsRequest) GetPVSpecList() []byte
- func (*GetVolumeIDsRequest) ProtoMessage()
- func (m *GetVolumeIDsRequest) Reset()
- func (m *GetVolumeIDsRequest) String() string
- func (m *GetVolumeIDsRequest) XXX_DiscardUnknown()
- func (m *GetVolumeIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetVolumeIDsRequest) XXX_Merge(src proto.Message)
- func (m *GetVolumeIDsRequest) XXX_Size() int
- func (m *GetVolumeIDsRequest) XXX_Unmarshal(b []byte) error
- type GetVolumeIDsResponse
- func (*GetVolumeIDsResponse) Descriptor() ([]byte, []int)
- func (m *GetVolumeIDsResponse) GetVolumeIDs() []string
- func (*GetVolumeIDsResponse) ProtoMessage()
- func (m *GetVolumeIDsResponse) Reset()
- func (m *GetVolumeIDsResponse) String() string
- func (m *GetVolumeIDsResponse) XXX_DiscardUnknown()
- func (m *GetVolumeIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetVolumeIDsResponse) XXX_Merge(src proto.Message)
- func (m *GetVolumeIDsResponse) XXX_Size() int
- func (m *GetVolumeIDsResponse) XXX_Unmarshal(b []byte) error
- type IdentityClient
- type IdentityServer
- type ListMachinesRequest
- func (*ListMachinesRequest) Descriptor() ([]byte, []int)
- func (m *ListMachinesRequest) GetProviderSpec() []byte
- func (m *ListMachinesRequest) GetSecrets() map[string][]byte
- func (*ListMachinesRequest) ProtoMessage()
- func (m *ListMachinesRequest) Reset()
- func (m *ListMachinesRequest) String() string
- func (m *ListMachinesRequest) XXX_DiscardUnknown()
- func (m *ListMachinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListMachinesRequest) XXX_Merge(src proto.Message)
- func (m *ListMachinesRequest) XXX_Size() int
- func (m *ListMachinesRequest) XXX_Unmarshal(b []byte) error
- type ListMachinesResponse
- func (*ListMachinesResponse) Descriptor() ([]byte, []int)
- func (m *ListMachinesResponse) GetMachineList() map[string]string
- func (*ListMachinesResponse) ProtoMessage()
- func (m *ListMachinesResponse) Reset()
- func (m *ListMachinesResponse) String() string
- func (m *ListMachinesResponse) XXX_DiscardUnknown()
- func (m *ListMachinesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListMachinesResponse) XXX_Merge(src proto.Message)
- func (m *ListMachinesResponse) XXX_Size() int
- func (m *ListMachinesResponse) XXX_Unmarshal(b []byte) error
- type MachineClient
- type MachineServer
- type PluginCapability
- func (*PluginCapability) Descriptor() ([]byte, []int)
- func (m *PluginCapability) GetRpc() *PluginCapability_RPC
- func (m *PluginCapability) GetType() isPluginCapability_Type
- func (*PluginCapability) ProtoMessage()
- func (m *PluginCapability) Reset()
- func (m *PluginCapability) String() string
- func (m *PluginCapability) XXX_DiscardUnknown()
- func (m *PluginCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PluginCapability) XXX_Merge(src proto.Message)
- func (*PluginCapability) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *PluginCapability) XXX_Size() int
- func (m *PluginCapability) XXX_Unmarshal(b []byte) error
- type PluginCapability_RPC
- func (*PluginCapability_RPC) Descriptor() ([]byte, []int)
- func (m *PluginCapability_RPC) GetType() PluginCapability_RPC_Type
- func (*PluginCapability_RPC) ProtoMessage()
- func (m *PluginCapability_RPC) Reset()
- func (m *PluginCapability_RPC) String() string
- func (m *PluginCapability_RPC) XXX_DiscardUnknown()
- func (m *PluginCapability_RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PluginCapability_RPC) XXX_Merge(src proto.Message)
- func (m *PluginCapability_RPC) XXX_Size() int
- func (m *PluginCapability_RPC) XXX_Unmarshal(b []byte) error
- type PluginCapability_RPC_Type
- type PluginCapability_Rpc
- type ProbeRequest
- func (*ProbeRequest) Descriptor() ([]byte, []int)
- func (*ProbeRequest) ProtoMessage()
- func (m *ProbeRequest) Reset()
- func (m *ProbeRequest) String() string
- func (m *ProbeRequest) XXX_DiscardUnknown()
- func (m *ProbeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProbeRequest) XXX_Merge(src proto.Message)
- func (m *ProbeRequest) XXX_Size() int
- func (m *ProbeRequest) XXX_Unmarshal(b []byte) error
- type ProbeResponse
- func (*ProbeResponse) Descriptor() ([]byte, []int)
- func (m *ProbeResponse) GetReady() *wrappers.BoolValue
- func (*ProbeResponse) ProtoMessage()
- func (m *ProbeResponse) Reset()
- func (m *ProbeResponse) String() string
- func (m *ProbeResponse) XXX_DiscardUnknown()
- func (m *ProbeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProbeResponse) XXX_Merge(src proto.Message)
- func (m *ProbeResponse) XXX_Size() int
- func (m *ProbeResponse) XXX_Unmarshal(b []byte) error
- type ShutDownMachineRequest
- func (*ShutDownMachineRequest) Descriptor() ([]byte, []int)
- func (m *ShutDownMachineRequest) GetLastKnownState() []byte
- func (m *ShutDownMachineRequest) GetMachineName() string
- func (m *ShutDownMachineRequest) GetProviderID() string
- func (m *ShutDownMachineRequest) GetProviderSpec() []byte
- func (m *ShutDownMachineRequest) GetSecrets() map[string][]byte
- func (*ShutDownMachineRequest) ProtoMessage()
- func (m *ShutDownMachineRequest) Reset()
- func (m *ShutDownMachineRequest) String() string
- func (m *ShutDownMachineRequest) XXX_DiscardUnknown()
- func (m *ShutDownMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ShutDownMachineRequest) XXX_Merge(src proto.Message)
- func (m *ShutDownMachineRequest) XXX_Size() int
- func (m *ShutDownMachineRequest) XXX_Unmarshal(b []byte) error
- type ShutDownMachineResponse
- func (*ShutDownMachineResponse) Descriptor() ([]byte, []int)
- func (m *ShutDownMachineResponse) GetLastKnownState() []byte
- func (*ShutDownMachineResponse) ProtoMessage()
- func (m *ShutDownMachineResponse) Reset()
- func (m *ShutDownMachineResponse) String() string
- func (m *ShutDownMachineResponse) XXX_DiscardUnknown()
- func (m *ShutDownMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ShutDownMachineResponse) XXX_Merge(src proto.Message)
- func (m *ShutDownMachineResponse) XXX_Size() int
- func (m *ShutDownMachineResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var E_CmiSecret = &proto.ExtensionDesc{ ExtendedType: (*descriptor.FieldOptions)(nil), ExtensionType: (*bool)(nil), Field: 1059, Name: "cmi.v1.cmi_secret", Tag: "varint,1059,opt,name=cmi_secret,json=cmiSecret", Filename: "github.com/gardener/machine-spec/cmi.proto", }
View Source
var PluginCapability_RPC_Type_name = map[int32]string{
0: "UNKNOWN",
1: "CREATE_MACHINE",
2: "DELETE_MACHINE",
3: "GET_MACHINE_STATUS",
4: "LIST_MACHINES",
5: "SHUTDOWN_MACHINE",
6: "GET_VOLUME_IDS",
}
View Source
var PluginCapability_RPC_Type_value = map[string]int32{
"UNKNOWN": 0,
"CREATE_MACHINE": 1,
"DELETE_MACHINE": 2,
"GET_MACHINE_STATUS": 3,
"LIST_MACHINES": 4,
"SHUTDOWN_MACHINE": 5,
"GET_VOLUME_IDS": 6,
}
Functions ¶
func RegisterIdentityServer ¶
func RegisterIdentityServer(s *grpc.Server, srv IdentityServer)
func RegisterMachineServer ¶
func RegisterMachineServer(s *grpc.Server, srv MachineServer)
Types ¶
type CreateMachineRequest ¶
type CreateMachineRequest struct { // MachineName is the name of the machine object CRD for whom a VM is to be created. // This field is REQUIRED. MachineName string `protobuf:"bytes,1,opt,name=MachineName,proto3" json:"MachineName,omitempty"` // ProviderSpec is the configuration needed to create a machine in bytes. // Plugin should parse this raw data into pre-defined spec in their respective projects. // This field is REQUIRED. ProviderSpec []byte `protobuf:"bytes,2,opt,name=ProviderSpec,proto3" json:"ProviderSpec,omitempty"` // Secrets is the map containing necessary credentials for cloud-provider to create the machine. // This field is OPTIONAL. Secrets map[string][]byte `` /* 155-byte string literal not displayed */ // LastKnownState is any additional information (if required) that can used by the plugin. // It can be used by the plugin to recover from the last execution/error state. // Plugin should parse this raw data into it's desired format. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,4,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateMachineRequest) Descriptor ¶
func (*CreateMachineRequest) Descriptor() ([]byte, []int)
func (*CreateMachineRequest) GetLastKnownState ¶
func (m *CreateMachineRequest) GetLastKnownState() []byte
func (*CreateMachineRequest) GetMachineName ¶
func (m *CreateMachineRequest) GetMachineName() string
func (*CreateMachineRequest) GetProviderSpec ¶
func (m *CreateMachineRequest) GetProviderSpec() []byte
func (*CreateMachineRequest) GetSecrets ¶
func (m *CreateMachineRequest) GetSecrets() map[string][]byte
func (*CreateMachineRequest) ProtoMessage ¶
func (*CreateMachineRequest) ProtoMessage()
func (*CreateMachineRequest) Reset ¶
func (m *CreateMachineRequest) Reset()
func (*CreateMachineRequest) String ¶
func (m *CreateMachineRequest) String() string
func (*CreateMachineRequest) XXX_DiscardUnknown ¶
func (m *CreateMachineRequest) XXX_DiscardUnknown()
func (*CreateMachineRequest) XXX_Marshal ¶
func (m *CreateMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateMachineRequest) XXX_Merge ¶
func (dst *CreateMachineRequest) XXX_Merge(src proto.Message)
func (*CreateMachineRequest) XXX_Size ¶
func (m *CreateMachineRequest) XXX_Size() int
func (*CreateMachineRequest) XXX_Unmarshal ¶
func (m *CreateMachineRequest) XXX_Unmarshal(b []byte) error
type CreateMachineResponse ¶
type CreateMachineResponse struct { // ProviderID is the unique identification of the VM at the cloud provider. // This could be the same/different from req.Name. // ProviderID typically matches with the node.Spec.ProviderID on the node object. // Eg: gce://project-name/region/vm-ID // This field is REQUIRED. ProviderID string `protobuf:"bytes,1,opt,name=ProviderID,proto3" json:"ProviderID,omitempty"` // NodeName is the name of the node-object registered to kubernetes. // This field is REQUIRED. NodeName string `protobuf:"bytes,2,opt,name=NodeName,proto3" json:"NodeName,omitempty"` // LastKnownState is any additional information (if required) that can used by the plugin. // It can be the final state of the executing call. // Could be used by the plugin to recover from the current execution/error state in any future calls. // Plugin should return a raw bytes string. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,3,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateMachineResponse) Descriptor ¶
func (*CreateMachineResponse) Descriptor() ([]byte, []int)
func (*CreateMachineResponse) GetLastKnownState ¶
func (m *CreateMachineResponse) GetLastKnownState() []byte
func (*CreateMachineResponse) GetNodeName ¶
func (m *CreateMachineResponse) GetNodeName() string
func (*CreateMachineResponse) GetProviderID ¶
func (m *CreateMachineResponse) GetProviderID() string
func (*CreateMachineResponse) ProtoMessage ¶
func (*CreateMachineResponse) ProtoMessage()
func (*CreateMachineResponse) Reset ¶
func (m *CreateMachineResponse) Reset()
func (*CreateMachineResponse) String ¶
func (m *CreateMachineResponse) String() string
func (*CreateMachineResponse) XXX_DiscardUnknown ¶
func (m *CreateMachineResponse) XXX_DiscardUnknown()
func (*CreateMachineResponse) XXX_Marshal ¶
func (m *CreateMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateMachineResponse) XXX_Merge ¶
func (dst *CreateMachineResponse) XXX_Merge(src proto.Message)
func (*CreateMachineResponse) XXX_Size ¶
func (m *CreateMachineResponse) XXX_Size() int
func (*CreateMachineResponse) XXX_Unmarshal ¶
func (m *CreateMachineResponse) XXX_Unmarshal(b []byte) error
type DeleteMachineRequest ¶
type DeleteMachineRequest struct { // MachineName is the name of the machine object for which a VM is to be deleted. // This field is REQUIRED. MachineName string `protobuf:"bytes,1,opt,name=MachineName,proto3" json:"MachineName,omitempty"` // ProviderSpec is needed to filter VMs based a cluster before deleting. // Plugin should parse this raw data into pre-defined spec in their respective projects. // This field is REQUIRED. ProviderSpec []byte `protobuf:"bytes,2,opt,name=ProviderSpec,proto3" json:"ProviderSpec,omitempty"` // Secrets is the map containing necessary credentials for cloud-provider to delete the machine. // This field is OPTIONAL. Secrets map[string][]byte `` /* 155-byte string literal not displayed */ // ProviderID is the unique identification of the VM at the cloud provider. // This could be the same/different from req.Name. // ProviderID typically matches with the node.Spec.ProviderID on the node object. // Eg: gce://project-name/region/vm-ID // This field is OPTIONAL. ProviderID string `protobuf:"bytes,4,opt,name=ProviderID,proto3" json:"ProviderID,omitempty"` // LastKnownState is any additional information (if required) that can used by the plugin. // It can be used by the plugin to recover from the last execution/error state. // Plugin should parse this raw data into it's desired format. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,5,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteMachineRequest) Descriptor ¶
func (*DeleteMachineRequest) Descriptor() ([]byte, []int)
func (*DeleteMachineRequest) GetLastKnownState ¶
func (m *DeleteMachineRequest) GetLastKnownState() []byte
func (*DeleteMachineRequest) GetMachineName ¶
func (m *DeleteMachineRequest) GetMachineName() string
func (*DeleteMachineRequest) GetProviderID ¶
func (m *DeleteMachineRequest) GetProviderID() string
func (*DeleteMachineRequest) GetProviderSpec ¶
func (m *DeleteMachineRequest) GetProviderSpec() []byte
func (*DeleteMachineRequest) GetSecrets ¶
func (m *DeleteMachineRequest) GetSecrets() map[string][]byte
func (*DeleteMachineRequest) ProtoMessage ¶
func (*DeleteMachineRequest) ProtoMessage()
func (*DeleteMachineRequest) Reset ¶
func (m *DeleteMachineRequest) Reset()
func (*DeleteMachineRequest) String ¶
func (m *DeleteMachineRequest) String() string
func (*DeleteMachineRequest) XXX_DiscardUnknown ¶
func (m *DeleteMachineRequest) XXX_DiscardUnknown()
func (*DeleteMachineRequest) XXX_Marshal ¶
func (m *DeleteMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteMachineRequest) XXX_Merge ¶
func (dst *DeleteMachineRequest) XXX_Merge(src proto.Message)
func (*DeleteMachineRequest) XXX_Size ¶
func (m *DeleteMachineRequest) XXX_Size() int
func (*DeleteMachineRequest) XXX_Unmarshal ¶
func (m *DeleteMachineRequest) XXX_Unmarshal(b []byte) error
type DeleteMachineResponse ¶
type DeleteMachineResponse struct { // LastKnownState is any additional information (if required) that can used by the plugin. // It can be the final state of the executing call. // Could be used by the plugin to recover from the current execution/error state in any future calls. // Plugin should return a raw bytes string. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,1,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteMachineResponse) Descriptor ¶
func (*DeleteMachineResponse) Descriptor() ([]byte, []int)
func (*DeleteMachineResponse) GetLastKnownState ¶
func (m *DeleteMachineResponse) GetLastKnownState() []byte
func (*DeleteMachineResponse) ProtoMessage ¶
func (*DeleteMachineResponse) ProtoMessage()
func (*DeleteMachineResponse) Reset ¶
func (m *DeleteMachineResponse) Reset()
func (*DeleteMachineResponse) String ¶
func (m *DeleteMachineResponse) String() string
func (*DeleteMachineResponse) XXX_DiscardUnknown ¶
func (m *DeleteMachineResponse) XXX_DiscardUnknown()
func (*DeleteMachineResponse) XXX_Marshal ¶
func (m *DeleteMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteMachineResponse) XXX_Merge ¶
func (dst *DeleteMachineResponse) XXX_Merge(src proto.Message)
func (*DeleteMachineResponse) XXX_Size ¶
func (m *DeleteMachineResponse) XXX_Size() int
func (*DeleteMachineResponse) XXX_Unmarshal ¶
func (m *DeleteMachineResponse) XXX_Unmarshal(b []byte) error
type GetMachineStatusRequest ¶
type GetMachineStatusRequest struct { // MachineName is name of the machine object from which the VM is to be identified. // The plugin is responsible to issuing a get call for a VM backed by this machine name. // This field is REQUIRED. MachineName string `protobuf:"bytes,1,opt,name=MachineName,proto3" json:"MachineName,omitempty"` // ProviderSpec is needed to filter VMs based a cluster before getting the status. // Plugin should parse this raw data into pre-defined spec in their respective projects. // This field is REQUIRED. ProviderSpec []byte `protobuf:"bytes,2,opt,name=ProviderSpec,proto3" json:"ProviderSpec,omitempty"` // Secrets is the map containing necessary credentials for cloud-provider to list the machines. // This field is OPTIONAL. Secrets map[string][]byte `` /* 155-byte string literal not displayed */ // ProviderID is the unique identification of the VM at the cloud provider. // This could be the same/different from req.Name. // ProviderID typically matches with the node.Spec.ProviderID on the node object. // Eg: gce://project-name/region/vm-ID // This field is OPTIONAL. ProviderID string `protobuf:"bytes,4,opt,name=ProviderID,proto3" json:"ProviderID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMachineStatusRequest) Descriptor ¶
func (*GetMachineStatusRequest) Descriptor() ([]byte, []int)
func (*GetMachineStatusRequest) GetMachineName ¶
func (m *GetMachineStatusRequest) GetMachineName() string
func (*GetMachineStatusRequest) GetProviderID ¶
func (m *GetMachineStatusRequest) GetProviderID() string
func (*GetMachineStatusRequest) GetProviderSpec ¶
func (m *GetMachineStatusRequest) GetProviderSpec() []byte
func (*GetMachineStatusRequest) GetSecrets ¶
func (m *GetMachineStatusRequest) GetSecrets() map[string][]byte
func (*GetMachineStatusRequest) ProtoMessage ¶
func (*GetMachineStatusRequest) ProtoMessage()
func (*GetMachineStatusRequest) Reset ¶
func (m *GetMachineStatusRequest) Reset()
func (*GetMachineStatusRequest) String ¶
func (m *GetMachineStatusRequest) String() string
func (*GetMachineStatusRequest) XXX_DiscardUnknown ¶
func (m *GetMachineStatusRequest) XXX_DiscardUnknown()
func (*GetMachineStatusRequest) XXX_Marshal ¶
func (m *GetMachineStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMachineStatusRequest) XXX_Merge ¶
func (dst *GetMachineStatusRequest) XXX_Merge(src proto.Message)
func (*GetMachineStatusRequest) XXX_Size ¶
func (m *GetMachineStatusRequest) XXX_Size() int
func (*GetMachineStatusRequest) XXX_Unmarshal ¶
func (m *GetMachineStatusRequest) XXX_Unmarshal(b []byte) error
type GetMachineStatusResponse ¶
type GetMachineStatusResponse struct { // ProviderID is the unique identification of the VM at the cloud provider. // This could be the same/different from req.Name. // ProviderID typically matches with the node.Spec.ProviderID on the node object. // Eg: gce://project-name/region/vm-ID // This field is REQUIRED. ProviderID string `protobuf:"bytes,1,opt,name=ProviderID,proto3" json:"ProviderID,omitempty"` // NodeName is the name of the node-object registered to kubernetes. // This field is REQUIRED. NodeName string `protobuf:"bytes,2,opt,name=NodeName,proto3" json:"NodeName,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMachineStatusResponse) Descriptor ¶
func (*GetMachineStatusResponse) Descriptor() ([]byte, []int)
func (*GetMachineStatusResponse) GetNodeName ¶
func (m *GetMachineStatusResponse) GetNodeName() string
func (*GetMachineStatusResponse) GetProviderID ¶
func (m *GetMachineStatusResponse) GetProviderID() string
func (*GetMachineStatusResponse) ProtoMessage ¶
func (*GetMachineStatusResponse) ProtoMessage()
func (*GetMachineStatusResponse) Reset ¶
func (m *GetMachineStatusResponse) Reset()
func (*GetMachineStatusResponse) String ¶
func (m *GetMachineStatusResponse) String() string
func (*GetMachineStatusResponse) XXX_DiscardUnknown ¶
func (m *GetMachineStatusResponse) XXX_DiscardUnknown()
func (*GetMachineStatusResponse) XXX_Marshal ¶
func (m *GetMachineStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMachineStatusResponse) XXX_Merge ¶
func (dst *GetMachineStatusResponse) XXX_Merge(src proto.Message)
func (*GetMachineStatusResponse) XXX_Size ¶
func (m *GetMachineStatusResponse) XXX_Size() int
func (*GetMachineStatusResponse) XXX_Unmarshal ¶
func (m *GetMachineStatusResponse) XXX_Unmarshal(b []byte) error
type GetPluginCapabilitiesRequest ¶
type GetPluginCapabilitiesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPluginCapabilitiesRequest) Descriptor ¶
func (*GetPluginCapabilitiesRequest) Descriptor() ([]byte, []int)
func (*GetPluginCapabilitiesRequest) ProtoMessage ¶
func (*GetPluginCapabilitiesRequest) ProtoMessage()
func (*GetPluginCapabilitiesRequest) Reset ¶
func (m *GetPluginCapabilitiesRequest) Reset()
func (*GetPluginCapabilitiesRequest) String ¶
func (m *GetPluginCapabilitiesRequest) String() string
func (*GetPluginCapabilitiesRequest) XXX_DiscardUnknown ¶
func (m *GetPluginCapabilitiesRequest) XXX_DiscardUnknown()
func (*GetPluginCapabilitiesRequest) XXX_Marshal ¶
func (m *GetPluginCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPluginCapabilitiesRequest) XXX_Merge ¶
func (dst *GetPluginCapabilitiesRequest) XXX_Merge(src proto.Message)
func (*GetPluginCapabilitiesRequest) XXX_Size ¶
func (m *GetPluginCapabilitiesRequest) XXX_Size() int
func (*GetPluginCapabilitiesRequest) XXX_Unmarshal ¶
func (m *GetPluginCapabilitiesRequest) XXX_Unmarshal(b []byte) error
type GetPluginCapabilitiesResponse ¶
type GetPluginCapabilitiesResponse struct { // All the capabilities that the controller service supports. // This field is OPTIONAL. Capabilities []*PluginCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPluginCapabilitiesResponse) Descriptor ¶
func (*GetPluginCapabilitiesResponse) Descriptor() ([]byte, []int)
func (*GetPluginCapabilitiesResponse) GetCapabilities ¶
func (m *GetPluginCapabilitiesResponse) GetCapabilities() []*PluginCapability
func (*GetPluginCapabilitiesResponse) ProtoMessage ¶
func (*GetPluginCapabilitiesResponse) ProtoMessage()
func (*GetPluginCapabilitiesResponse) Reset ¶
func (m *GetPluginCapabilitiesResponse) Reset()
func (*GetPluginCapabilitiesResponse) String ¶
func (m *GetPluginCapabilitiesResponse) String() string
func (*GetPluginCapabilitiesResponse) XXX_DiscardUnknown ¶
func (m *GetPluginCapabilitiesResponse) XXX_DiscardUnknown()
func (*GetPluginCapabilitiesResponse) XXX_Marshal ¶
func (m *GetPluginCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPluginCapabilitiesResponse) XXX_Merge ¶
func (dst *GetPluginCapabilitiesResponse) XXX_Merge(src proto.Message)
func (*GetPluginCapabilitiesResponse) XXX_Size ¶
func (m *GetPluginCapabilitiesResponse) XXX_Size() int
func (*GetPluginCapabilitiesResponse) XXX_Unmarshal ¶
func (m *GetPluginCapabilitiesResponse) XXX_Unmarshal(b []byte) error
type GetPluginInfoRequest ¶
type GetPluginInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPluginInfoRequest) Descriptor ¶
func (*GetPluginInfoRequest) Descriptor() ([]byte, []int)
func (*GetPluginInfoRequest) ProtoMessage ¶
func (*GetPluginInfoRequest) ProtoMessage()
func (*GetPluginInfoRequest) Reset ¶
func (m *GetPluginInfoRequest) Reset()
func (*GetPluginInfoRequest) String ¶
func (m *GetPluginInfoRequest) String() string
func (*GetPluginInfoRequest) XXX_DiscardUnknown ¶
func (m *GetPluginInfoRequest) XXX_DiscardUnknown()
func (*GetPluginInfoRequest) XXX_Marshal ¶
func (m *GetPluginInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPluginInfoRequest) XXX_Merge ¶
func (dst *GetPluginInfoRequest) XXX_Merge(src proto.Message)
func (*GetPluginInfoRequest) XXX_Size ¶
func (m *GetPluginInfoRequest) XXX_Size() int
func (*GetPluginInfoRequest) XXX_Unmarshal ¶
func (m *GetPluginInfoRequest) XXX_Unmarshal(b []byte) error
type GetPluginInfoResponse ¶
type GetPluginInfoResponse struct { // The name MUST follow domain name notation format // (https://tools.ietf.org/html/rfc1035#section-2.3.1). It SHOULD // include the plugin's host company name and the plugin name, // to minimize the possibility of collisions. It MUST be 63 // characters or less, beginning and ending with an alphanumeric // character ([a-z0-9A-Z]) with dashes (-), dots (.), and // alphanumerics between. // This field is REQUIRED. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The version specifies the plugin version // Value of this field is opaque to the CMI-Client. // This field is REQUIRED. Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // manifest contains a map of key-value pairs to pass // any additonal information about the plugin. // Values are opaque to the CMI-Client. // This field is OPTIONAL. Manifest map[string]string `` /* 157-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPluginInfoResponse) Descriptor ¶
func (*GetPluginInfoResponse) Descriptor() ([]byte, []int)
func (*GetPluginInfoResponse) GetManifest ¶
func (m *GetPluginInfoResponse) GetManifest() map[string]string
func (*GetPluginInfoResponse) GetName ¶
func (m *GetPluginInfoResponse) GetName() string
func (*GetPluginInfoResponse) GetVersion ¶
func (m *GetPluginInfoResponse) GetVersion() string
func (*GetPluginInfoResponse) ProtoMessage ¶
func (*GetPluginInfoResponse) ProtoMessage()
func (*GetPluginInfoResponse) Reset ¶
func (m *GetPluginInfoResponse) Reset()
func (*GetPluginInfoResponse) String ¶
func (m *GetPluginInfoResponse) String() string
func (*GetPluginInfoResponse) XXX_DiscardUnknown ¶
func (m *GetPluginInfoResponse) XXX_DiscardUnknown()
func (*GetPluginInfoResponse) XXX_Marshal ¶
func (m *GetPluginInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPluginInfoResponse) XXX_Merge ¶
func (dst *GetPluginInfoResponse) XXX_Merge(src proto.Message)
func (*GetPluginInfoResponse) XXX_Size ¶
func (m *GetPluginInfoResponse) XXX_Size() int
func (*GetPluginInfoResponse) XXX_Unmarshal ¶
func (m *GetPluginInfoResponse) XXX_Unmarshal(b []byte) error
type GetVolumeIDsRequest ¶
type GetVolumeIDsRequest struct { // PVSpecsList is a list of PV specs for whom volume-IDs are required // Plugin should parse this raw data into pre-defined list of PVSpecs // This field is REQUIRED. PVSpecList []byte `protobuf:"bytes,1,opt,name=PVSpecList,proto3" json:"PVSpecList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetVolumeIDsRequest) Descriptor ¶
func (*GetVolumeIDsRequest) Descriptor() ([]byte, []int)
func (*GetVolumeIDsRequest) GetPVSpecList ¶
func (m *GetVolumeIDsRequest) GetPVSpecList() []byte
func (*GetVolumeIDsRequest) ProtoMessage ¶
func (*GetVolumeIDsRequest) ProtoMessage()
func (*GetVolumeIDsRequest) Reset ¶
func (m *GetVolumeIDsRequest) Reset()
func (*GetVolumeIDsRequest) String ¶
func (m *GetVolumeIDsRequest) String() string
func (*GetVolumeIDsRequest) XXX_DiscardUnknown ¶
func (m *GetVolumeIDsRequest) XXX_DiscardUnknown()
func (*GetVolumeIDsRequest) XXX_Marshal ¶
func (m *GetVolumeIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetVolumeIDsRequest) XXX_Merge ¶
func (dst *GetVolumeIDsRequest) XXX_Merge(src proto.Message)
func (*GetVolumeIDsRequest) XXX_Size ¶
func (m *GetVolumeIDsRequest) XXX_Size() int
func (*GetVolumeIDsRequest) XXX_Unmarshal ¶
func (m *GetVolumeIDsRequest) XXX_Unmarshal(b []byte) error
type GetVolumeIDsResponse ¶
type GetVolumeIDsResponse struct { // VolumeIDs is a list of VolumeIDs. // This field is REQUIRED. VolumeIDs []string `protobuf:"bytes,1,rep,name=VolumeIDs,proto3" json:"VolumeIDs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetVolumeIDsResponse) Descriptor ¶
func (*GetVolumeIDsResponse) Descriptor() ([]byte, []int)
func (*GetVolumeIDsResponse) GetVolumeIDs ¶
func (m *GetVolumeIDsResponse) GetVolumeIDs() []string
func (*GetVolumeIDsResponse) ProtoMessage ¶
func (*GetVolumeIDsResponse) ProtoMessage()
func (*GetVolumeIDsResponse) Reset ¶
func (m *GetVolumeIDsResponse) Reset()
func (*GetVolumeIDsResponse) String ¶
func (m *GetVolumeIDsResponse) String() string
func (*GetVolumeIDsResponse) XXX_DiscardUnknown ¶
func (m *GetVolumeIDsResponse) XXX_DiscardUnknown()
func (*GetVolumeIDsResponse) XXX_Marshal ¶
func (m *GetVolumeIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetVolumeIDsResponse) XXX_Merge ¶
func (dst *GetVolumeIDsResponse) XXX_Merge(src proto.Message)
func (*GetVolumeIDsResponse) XXX_Size ¶
func (m *GetVolumeIDsResponse) XXX_Size() int
func (*GetVolumeIDsResponse) XXX_Unmarshal ¶
func (m *GetVolumeIDsResponse) XXX_Unmarshal(b []byte) error
type IdentityClient ¶
type IdentityClient interface { // GetPluginInfo returns basic details about the plugin // This method is REQUIRED. GetPluginInfo(ctx context.Context, in *GetPluginInfoRequest, opts ...grpc.CallOption) (*GetPluginInfoResponse, error) // GetPluginCapabilities returns the set of capabilities for the plugin // This method is REQUIRED. GetPluginCapabilities(ctx context.Context, in *GetPluginCapabilitiesRequest, opts ...grpc.CallOption) (*GetPluginCapabilitiesResponse, error) // Probe returns the status of the plugin // This method is REQUIRED. Probe(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error) }
IdentityClient is the client API for Identity service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewIdentityClient ¶
func NewIdentityClient(cc *grpc.ClientConn) IdentityClient
type IdentityServer ¶
type IdentityServer interface { // GetPluginInfo returns basic details about the plugin // This method is REQUIRED. GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error) // GetPluginCapabilities returns the set of capabilities for the plugin // This method is REQUIRED. GetPluginCapabilities(context.Context, *GetPluginCapabilitiesRequest) (*GetPluginCapabilitiesResponse, error) // Probe returns the status of the plugin // This method is REQUIRED. Probe(context.Context, *ProbeRequest) (*ProbeResponse, error) }
IdentityServer is the server API for Identity service.
type ListMachinesRequest ¶
type ListMachinesRequest struct { // ProviderSpec is the configuration needed to list machines. // Plugin should parse this raw data into pre-defined spec in their respective projects. // This field is REQUIRED. ProviderSpec []byte `protobuf:"bytes,1,opt,name=ProviderSpec,proto3" json:"ProviderSpec,omitempty"` // Secrets is the map containing necessary credentials for cloud-provider to list the machines. // This field is OPTIONAL. Secrets map[string][]byte `` /* 155-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListMachinesRequest) Descriptor ¶
func (*ListMachinesRequest) Descriptor() ([]byte, []int)
func (*ListMachinesRequest) GetProviderSpec ¶
func (m *ListMachinesRequest) GetProviderSpec() []byte
func (*ListMachinesRequest) GetSecrets ¶
func (m *ListMachinesRequest) GetSecrets() map[string][]byte
func (*ListMachinesRequest) ProtoMessage ¶
func (*ListMachinesRequest) ProtoMessage()
func (*ListMachinesRequest) Reset ¶
func (m *ListMachinesRequest) Reset()
func (*ListMachinesRequest) String ¶
func (m *ListMachinesRequest) String() string
func (*ListMachinesRequest) XXX_DiscardUnknown ¶
func (m *ListMachinesRequest) XXX_DiscardUnknown()
func (*ListMachinesRequest) XXX_Marshal ¶
func (m *ListMachinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMachinesRequest) XXX_Merge ¶
func (dst *ListMachinesRequest) XXX_Merge(src proto.Message)
func (*ListMachinesRequest) XXX_Size ¶
func (m *ListMachinesRequest) XXX_Size() int
func (*ListMachinesRequest) XXX_Unmarshal ¶
func (m *ListMachinesRequest) XXX_Unmarshal(b []byte) error
type ListMachinesResponse ¶
type ListMachinesResponse struct { // MachineList is the map of list of machines. Format for the map should be map<ProviderID, MachineName>. // This field is REQUIRED. MachineList map[string]string `` /* 163-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListMachinesResponse) Descriptor ¶
func (*ListMachinesResponse) Descriptor() ([]byte, []int)
func (*ListMachinesResponse) GetMachineList ¶
func (m *ListMachinesResponse) GetMachineList() map[string]string
func (*ListMachinesResponse) ProtoMessage ¶
func (*ListMachinesResponse) ProtoMessage()
func (*ListMachinesResponse) Reset ¶
func (m *ListMachinesResponse) Reset()
func (*ListMachinesResponse) String ¶
func (m *ListMachinesResponse) String() string
func (*ListMachinesResponse) XXX_DiscardUnknown ¶
func (m *ListMachinesResponse) XXX_DiscardUnknown()
func (*ListMachinesResponse) XXX_Marshal ¶
func (m *ListMachinesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMachinesResponse) XXX_Merge ¶
func (dst *ListMachinesResponse) XXX_Merge(src proto.Message)
func (*ListMachinesResponse) XXX_Size ¶
func (m *ListMachinesResponse) XXX_Size() int
func (*ListMachinesResponse) XXX_Unmarshal ¶
func (m *ListMachinesResponse) XXX_Unmarshal(b []byte) error
type MachineClient ¶
type MachineClient interface { // CreateMachine is the gRPC call to create a machine. // This method is REQUIRED. CreateMachine(ctx context.Context, in *CreateMachineRequest, opts ...grpc.CallOption) (*CreateMachineResponse, error) // DeleteMachine is the gRPC call to delete a machine. // This method is REQUIRED. DeleteMachine(ctx context.Context, in *DeleteMachineRequest, opts ...grpc.CallOption) (*DeleteMachineResponse, error) // GetMachineStatus is the gRPC call to get the status of a machine. // This method is OPTIONAL. GetMachineStatus(ctx context.Context, in *GetMachineStatusRequest, opts ...grpc.CallOption) (*GetMachineStatusResponse, error) // ListMachines is the gRPC call to list machines backed by the providerSpec. // This method is OPTIONAL. ListMachines(ctx context.Context, in *ListMachinesRequest, opts ...grpc.CallOption) (*ListMachinesResponse, error) // ShutDownMachine is the gRPC call to shutdown/power-off a machine. // This method is OPTIONAL. ShutDownMachine(ctx context.Context, in *ShutDownMachineRequest, opts ...grpc.CallOption) (*ShutDownMachineResponse, error) // GetVolumeIDs() is the gRPC call to list VolumeIDs // (if exists) for PVs provided by PVSpecList. // This method is OPTIONAL. GetVolumeIDs(ctx context.Context, in *GetVolumeIDsRequest, opts ...grpc.CallOption) (*GetVolumeIDsResponse, error) }
MachineClient is the client API for Machine service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMachineClient ¶
func NewMachineClient(cc *grpc.ClientConn) MachineClient
type MachineServer ¶
type MachineServer interface { // CreateMachine is the gRPC call to create a machine. // This method is REQUIRED. CreateMachine(context.Context, *CreateMachineRequest) (*CreateMachineResponse, error) // DeleteMachine is the gRPC call to delete a machine. // This method is REQUIRED. DeleteMachine(context.Context, *DeleteMachineRequest) (*DeleteMachineResponse, error) // GetMachineStatus is the gRPC call to get the status of a machine. // This method is OPTIONAL. GetMachineStatus(context.Context, *GetMachineStatusRequest) (*GetMachineStatusResponse, error) // ListMachines is the gRPC call to list machines backed by the providerSpec. // This method is OPTIONAL. ListMachines(context.Context, *ListMachinesRequest) (*ListMachinesResponse, error) // ShutDownMachine is the gRPC call to shutdown/power-off a machine. // This method is OPTIONAL. ShutDownMachine(context.Context, *ShutDownMachineRequest) (*ShutDownMachineResponse, error) // GetVolumeIDs() is the gRPC call to list VolumeIDs // (if exists) for PVs provided by PVSpecList. // This method is OPTIONAL. GetVolumeIDs(context.Context, *GetVolumeIDsRequest) (*GetVolumeIDsResponse, error) }
MachineServer is the server API for Machine service.
type PluginCapability ¶
type PluginCapability struct { // Types that are valid to be assigned to Type: // *PluginCapability_Rpc Type isPluginCapability_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Specifies a capability of the CMI-Plugin.
func (*PluginCapability) Descriptor ¶
func (*PluginCapability) Descriptor() ([]byte, []int)
func (*PluginCapability) GetRpc ¶
func (m *PluginCapability) GetRpc() *PluginCapability_RPC
func (*PluginCapability) GetType ¶
func (m *PluginCapability) GetType() isPluginCapability_Type
func (*PluginCapability) ProtoMessage ¶
func (*PluginCapability) ProtoMessage()
func (*PluginCapability) Reset ¶
func (m *PluginCapability) Reset()
func (*PluginCapability) String ¶
func (m *PluginCapability) String() string
func (*PluginCapability) XXX_DiscardUnknown ¶
func (m *PluginCapability) XXX_DiscardUnknown()
func (*PluginCapability) XXX_Marshal ¶
func (m *PluginCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PluginCapability) XXX_Merge ¶
func (dst *PluginCapability) XXX_Merge(src proto.Message)
func (*PluginCapability) XXX_OneofFuncs ¶
func (*PluginCapability) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*PluginCapability) XXX_Size ¶
func (m *PluginCapability) XXX_Size() int
func (*PluginCapability) XXX_Unmarshal ¶
func (m *PluginCapability) XXX_Unmarshal(b []byte) error
type PluginCapability_RPC ¶
type PluginCapability_RPC struct { Type PluginCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cmi.v1.PluginCapability_RPC_Type" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PluginCapability_RPC) Descriptor ¶
func (*PluginCapability_RPC) Descriptor() ([]byte, []int)
func (*PluginCapability_RPC) GetType ¶
func (m *PluginCapability_RPC) GetType() PluginCapability_RPC_Type
func (*PluginCapability_RPC) ProtoMessage ¶
func (*PluginCapability_RPC) ProtoMessage()
func (*PluginCapability_RPC) Reset ¶
func (m *PluginCapability_RPC) Reset()
func (*PluginCapability_RPC) String ¶
func (m *PluginCapability_RPC) String() string
func (*PluginCapability_RPC) XXX_DiscardUnknown ¶
func (m *PluginCapability_RPC) XXX_DiscardUnknown()
func (*PluginCapability_RPC) XXX_Marshal ¶
func (m *PluginCapability_RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PluginCapability_RPC) XXX_Merge ¶
func (dst *PluginCapability_RPC) XXX_Merge(src proto.Message)
func (*PluginCapability_RPC) XXX_Size ¶
func (m *PluginCapability_RPC) XXX_Size() int
func (*PluginCapability_RPC) XXX_Unmarshal ¶
func (m *PluginCapability_RPC) XXX_Unmarshal(b []byte) error
type PluginCapability_RPC_Type ¶
type PluginCapability_RPC_Type int32
const ( // UNKNOWN is used to specific an capability beyond the set // provided below PluginCapability_RPC_UNKNOWN PluginCapability_RPC_Type = 0 // CREATE_MACHINE tells that the plugin implements the // CreateMachine() RPC. // Plugin is REQUIRED to provide this capability. PluginCapability_RPC_CREATE_MACHINE PluginCapability_RPC_Type = 1 // DELETE_MACHINE tells that the plugin implements the // DeleteMachine() RPC. // Plugin is REQUIRED to provide this capability. PluginCapability_RPC_DELETE_MACHINE PluginCapability_RPC_Type = 2 // GET_MACHINE_STATUS tells that the plugin implements the // GetMachineStatus() RPC PluginCapability_RPC_GET_MACHINE_STATUS PluginCapability_RPC_Type = 3 // LIST_MACHINES tells that the plugin implements the // ListMachines() RPC PluginCapability_RPC_LIST_MACHINES PluginCapability_RPC_Type = 4 // SHUTDOWN_MACHINE tells that the plugin implements the // ShutDownMachine() RPC PluginCapability_RPC_SHUTDOWN_MACHINE PluginCapability_RPC_Type = 5 // GET_VOLUME_IDS tells if the plugin // implements the GetVolumeIDs() RPC PluginCapability_RPC_GET_VOLUME_IDS PluginCapability_RPC_Type = 6 )
func (PluginCapability_RPC_Type) EnumDescriptor ¶
func (PluginCapability_RPC_Type) EnumDescriptor() ([]byte, []int)
func (PluginCapability_RPC_Type) String ¶
func (x PluginCapability_RPC_Type) String() string
type PluginCapability_Rpc ¶
type PluginCapability_Rpc struct {
Rpc *PluginCapability_RPC `protobuf:"bytes,1,opt,name=rpc,proto3,oneof"`
}
type ProbeRequest ¶
type ProbeRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProbeRequest) Descriptor ¶
func (*ProbeRequest) Descriptor() ([]byte, []int)
func (*ProbeRequest) ProtoMessage ¶
func (*ProbeRequest) ProtoMessage()
func (*ProbeRequest) Reset ¶
func (m *ProbeRequest) Reset()
func (*ProbeRequest) String ¶
func (m *ProbeRequest) String() string
func (*ProbeRequest) XXX_DiscardUnknown ¶
func (m *ProbeRequest) XXX_DiscardUnknown()
func (*ProbeRequest) XXX_Marshal ¶
func (m *ProbeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProbeRequest) XXX_Merge ¶
func (dst *ProbeRequest) XXX_Merge(src proto.Message)
func (*ProbeRequest) XXX_Size ¶
func (m *ProbeRequest) XXX_Size() int
func (*ProbeRequest) XXX_Unmarshal ¶
func (m *ProbeRequest) XXX_Unmarshal(b []byte) error
type ProbeResponse ¶
type ProbeResponse struct { // Readiness allows a plugin to report its initialization status back // to the CMI-Client. Initialization for some plugins MAY be time consuming // and it is important for a CMI-Client to distinguish between the following // cases: // // 1) The plugin is in an unhealthy state and MAY need restarting. In // this case a gRPC error code SHALL be returned. // 2) The plugin is still initializing, but is otherwise perfectly // healthy. In this case a successful response SHALL be returned // with a readiness value of `false`. Calls to the plugin's // Machine services MAY fail due to an incomplete // initialization state. // 3) The plugin has finished initializing and is ready to service // calls to its Machine services. A successful // response is returned with a readiness value of `true`. // // This field is OPTIONAL. If not present, the caller SHALL assume // that the plugin is in a ready state and is accepting calls to its // Machine services (according to the plugin's reported // capabilities). Ready *wrappers.BoolValue `protobuf:"bytes,1,opt,name=ready,proto3" json:"ready,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProbeResponse) Descriptor ¶
func (*ProbeResponse) Descriptor() ([]byte, []int)
func (*ProbeResponse) GetReady ¶
func (m *ProbeResponse) GetReady() *wrappers.BoolValue
func (*ProbeResponse) ProtoMessage ¶
func (*ProbeResponse) ProtoMessage()
func (*ProbeResponse) Reset ¶
func (m *ProbeResponse) Reset()
func (*ProbeResponse) String ¶
func (m *ProbeResponse) String() string
func (*ProbeResponse) XXX_DiscardUnknown ¶
func (m *ProbeResponse) XXX_DiscardUnknown()
func (*ProbeResponse) XXX_Marshal ¶
func (m *ProbeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProbeResponse) XXX_Merge ¶
func (dst *ProbeResponse) XXX_Merge(src proto.Message)
func (*ProbeResponse) XXX_Size ¶
func (m *ProbeResponse) XXX_Size() int
func (*ProbeResponse) XXX_Unmarshal ¶
func (m *ProbeResponse) XXX_Unmarshal(b []byte) error
type ShutDownMachineRequest ¶
type ShutDownMachineRequest struct { // MachineName is the machine object name for whose VM, the shutdown call is to be invoked. // The plugin is responsible to issuing a shutdown call for a VM backed by this machine name. // This field is REQUIRED. MachineName string `protobuf:"bytes,1,opt,name=MachineName,proto3" json:"MachineName,omitempty"` // ProviderSpec is needed to filter VMs based a cluster before shutting down. // Plugin should parse this raw data into pre-defined spec in their respective projects. // This field is REQUIRED. ProviderSpec []byte `protobuf:"bytes,2,opt,name=ProviderSpec,proto3" json:"ProviderSpec,omitempty"` // Secrets is the map containing necessary credentials for cloud-provider to shut down the machine. // This field is OPTIONAL. Secrets map[string][]byte `` /* 155-byte string literal not displayed */ // ProviderID is the unique identification of the VM at the cloud provider. // This could be the same/different from req.Name. // ProviderID typically matches with the node.Spec.ProviderID on the node object. // Eg: gce://project-name/region/vm-ID // This field is OPTIONAL. ProviderID string `protobuf:"bytes,4,opt,name=ProviderID,proto3" json:"ProviderID,omitempty"` // LastKnownState is any additional information (if required) that can used by the plugin. // It can be used by the plugin to recover from the last execution/error state. // Plugin should parse this raw data into it's desired format. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,5,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShutDownMachineRequest) Descriptor ¶
func (*ShutDownMachineRequest) Descriptor() ([]byte, []int)
func (*ShutDownMachineRequest) GetLastKnownState ¶
func (m *ShutDownMachineRequest) GetLastKnownState() []byte
func (*ShutDownMachineRequest) GetMachineName ¶
func (m *ShutDownMachineRequest) GetMachineName() string
func (*ShutDownMachineRequest) GetProviderID ¶
func (m *ShutDownMachineRequest) GetProviderID() string
func (*ShutDownMachineRequest) GetProviderSpec ¶
func (m *ShutDownMachineRequest) GetProviderSpec() []byte
func (*ShutDownMachineRequest) GetSecrets ¶
func (m *ShutDownMachineRequest) GetSecrets() map[string][]byte
func (*ShutDownMachineRequest) ProtoMessage ¶
func (*ShutDownMachineRequest) ProtoMessage()
func (*ShutDownMachineRequest) Reset ¶
func (m *ShutDownMachineRequest) Reset()
func (*ShutDownMachineRequest) String ¶
func (m *ShutDownMachineRequest) String() string
func (*ShutDownMachineRequest) XXX_DiscardUnknown ¶
func (m *ShutDownMachineRequest) XXX_DiscardUnknown()
func (*ShutDownMachineRequest) XXX_Marshal ¶
func (m *ShutDownMachineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutDownMachineRequest) XXX_Merge ¶
func (dst *ShutDownMachineRequest) XXX_Merge(src proto.Message)
func (*ShutDownMachineRequest) XXX_Size ¶
func (m *ShutDownMachineRequest) XXX_Size() int
func (*ShutDownMachineRequest) XXX_Unmarshal ¶
func (m *ShutDownMachineRequest) XXX_Unmarshal(b []byte) error
type ShutDownMachineResponse ¶
type ShutDownMachineResponse struct { // LastKnownState is any additional information (if required) that can used by the plugin. // It can be the final state of the executing call. // Could be used by the plugin to recover from the current execution/error state in any future calls. // Plugin should return a raw bytes string. // This field is OPTIONAL. LastKnownState []byte `protobuf:"bytes,1,opt,name=LastKnownState,proto3" json:"LastKnownState,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShutDownMachineResponse) Descriptor ¶
func (*ShutDownMachineResponse) Descriptor() ([]byte, []int)
func (*ShutDownMachineResponse) GetLastKnownState ¶
func (m *ShutDownMachineResponse) GetLastKnownState() []byte
func (*ShutDownMachineResponse) ProtoMessage ¶
func (*ShutDownMachineResponse) ProtoMessage()
func (*ShutDownMachineResponse) Reset ¶
func (m *ShutDownMachineResponse) Reset()
func (*ShutDownMachineResponse) String ¶
func (m *ShutDownMachineResponse) String() string
func (*ShutDownMachineResponse) XXX_DiscardUnknown ¶
func (m *ShutDownMachineResponse) XXX_DiscardUnknown()
func (*ShutDownMachineResponse) XXX_Marshal ¶
func (m *ShutDownMachineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutDownMachineResponse) XXX_Merge ¶
func (dst *ShutDownMachineResponse) XXX_Merge(src proto.Message)
func (*ShutDownMachineResponse) XXX_Size ¶
func (m *ShutDownMachineResponse) XXX_Size() int
func (*ShutDownMachineResponse) XXX_Unmarshal ¶
func (m *ShutDownMachineResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.