Documentation ¶
Index ¶
- func NewPluginCapability(cap cmi.PluginCapability_RPC_Type) *cmi.PluginCapability
- type IdentityPlugin
- func (ids *IdentityPlugin) GetPluginCapabilities(ctx context.Context, req *cmi.GetPluginCapabilitiesRequest) (*cmi.GetPluginCapabilitiesResponse, error)
- func (ids *IdentityPlugin) GetPluginInfo(ctx context.Context, req *cmi.GetPluginInfoRequest) (*cmi.GetPluginInfoResponse, error)
- func (ids *IdentityPlugin) Probe(ctx context.Context, req *cmi.ProbeRequest) (*cmi.ProbeResponse, error)
- type MachinePlugin
- func (ms *MachinePlugin) CreateMachine(ctx context.Context, req *cmi.CreateMachineRequest) (*cmi.CreateMachineResponse, error)
- func (ms *MachinePlugin) DeleteMachine(ctx context.Context, req *cmi.DeleteMachineRequest) (*cmi.DeleteMachineResponse, error)
- func (ms *MachinePlugin) GetMachineStatus(ctx context.Context, req *cmi.GetMachineStatusRequest) (*cmi.GetMachineStatusResponse, error)
- func (ms *MachinePlugin) GetVolumeIDs(ctx context.Context, req *cmi.GetVolumeIDsRequest) (*cmi.GetVolumeIDsResponse, error)
- func (ms *MachinePlugin) ListMachines(ctx context.Context, req *cmi.ListMachinesRequest) (*cmi.ListMachinesResponse, error)
- func (ms *MachinePlugin) ShutDownMachine(ctx context.Context, req *cmi.ShutDownMachineRequest) (*cmi.ShutDownMachineResponse, error)
- type Plugin
- type PluginSPI
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPluginCapability ¶
func NewPluginCapability(cap cmi.PluginCapability_RPC_Type) *cmi.PluginCapability
NewPluginCapability TODO
Types ¶
type IdentityPlugin ¶
type IdentityPlugin struct {
*cmicommon.DefaultIdentityServer
}
IdentityPlugin implements the cmi.IdentityServer clients
func NewIdentityPlugin ¶
func NewIdentityPlugin(p *Plugin, spi PluginSPI) *IdentityPlugin
NewIdentityPlugin returns a new IdentityPlugin
func (*IdentityPlugin) GetPluginCapabilities ¶
func (ids *IdentityPlugin) GetPluginCapabilities(ctx context.Context, req *cmi.GetPluginCapabilitiesRequest) (*cmi.GetPluginCapabilitiesResponse, error)
GetPluginCapabilities gets capabilities of the plugin
func (*IdentityPlugin) GetPluginInfo ¶
func (ids *IdentityPlugin) GetPluginInfo(ctx context.Context, req *cmi.GetPluginInfoRequest) (*cmi.GetPluginInfoResponse, error)
GetPluginInfo returns the Server details
func (*IdentityPlugin) Probe ¶
func (ids *IdentityPlugin) Probe(ctx context.Context, req *cmi.ProbeRequest) (*cmi.ProbeResponse, error)
Probe tries to probe the server and returns a response
type MachinePlugin ¶
type MachinePlugin struct { *cmicommon.DefaultMachineServer SPI PluginSPI }
MachinePlugin implements the cmi.MachineServer It also implements the pluginSPI interface
func NewMachinePlugin ¶
func NewMachinePlugin(p *Plugin, spi PluginSPI) *MachinePlugin
NewMachinePlugin returns a new MachinePlugin
func (*MachinePlugin) CreateMachine ¶
func (ms *MachinePlugin) CreateMachine(ctx context.Context, req *cmi.CreateMachineRequest) (*cmi.CreateMachineResponse, error)
CreateMachine handles a machine creation request REQUIRED METHOD
REQUEST PARAMETERS (cmi.CreateMachineRequest) MachineName string Contains the name of the machine object for whom an VM is to be created at the provider ProviderSpec bytes(blob) Template/Configuration of the machine to be created is given by at the provider Secrets map<string,bytes> (Optional) Contains a map from string to string contains any cloud specific secrets that can be used by the provider LastKnownState bytes(blob) (Optional) Last known state of VM during last operation. Could be helpful to continue operation from previous state
RESPONSE PARAMETERS (cmi.CreateMachineResponse) ProviderID string Unique identification of the VM at the cloud provider. This could be the same/different from req.MachineName.
ProviderID typically matches with the node.Spec.ProviderID on the node object. Eg: gce://project-name/region/vm-ProviderID
NodeName string Returns the name of the node-object that the VM register's with Kubernetes.
This could be different from req.MachineName as well
LastKnownState bytes(blob) (Optional) Last known state of VM during the current operation.
Could be helpful to continue operations in future requests.
OPTIONAL IMPLEMENTATION LOGIC It is optionally expected by the safety controller to use an identification mechanisms to map the VM Created by a providerSpec. These could be done using tag(s)/resource-groups etc. This logic is used by safety controller to delete orphan VMs which are not backed by any machine CRD
func (*MachinePlugin) DeleteMachine ¶
func (ms *MachinePlugin) DeleteMachine(ctx context.Context, req *cmi.DeleteMachineRequest) (*cmi.DeleteMachineResponse, error)
DeleteMachine handles a machine deletion request
REQUEST PARAMETERS (cmi.DeleteMachineRequest) MachineName string Contains the name of the machine object for the backing VM(s) have to be deleted ProviderSpec bytes(blob) Template/Configuration of the machine to be deleted is given by at the provider Secrets map<string,bytes> (Optional) Contains a map from string to string contains any cloud specific secrets that can be used by the provider LastKnownState bytes(blob) (Optional) Last known state of VM during last operation. Could be helpful to continue operation from previous state
RESPONSE PARAMETERS (cmi.DeleteMachineResponse) LastKnownState bytes(blob) (Optional) Last known state of VM during the current operation.
Could be helpful to continue operations in future requests.
func (*MachinePlugin) GetMachineStatus ¶
func (ms *MachinePlugin) GetMachineStatus(ctx context.Context, req *cmi.GetMachineStatusRequest) (*cmi.GetMachineStatusResponse, error)
GetMachineStatus handles a machine get status request OPTIONAL METHOD
REQUEST PARAMETERS (cmi.GetMachineStatusRequest) MachineName string Contains the name of the machine object for whose status is to be retrived ProviderSpec bytes(blob) Template/Configuration of the machine whose status is to be retrived Secrets map<string,bytes> (Optional) Contains a map from string to string contains any cloud specific secrets that can be used by the provider
RESPONSE PARAMETERS (cmi.GetMachineStatueResponse) ProviderID string Unique identification of the VM at the cloud provider. This could be the same/different from req.MachineName.
ProviderID typically matches with the node.Spec.ProviderID on the node object. Eg: gce://project-name/region/vm-ProviderID
NodeName string Returns the name of the node-object that the VM register's with Kubernetes.
This could be different from req.MachineName as well
func (*MachinePlugin) GetVolumeIDs ¶
func (ms *MachinePlugin) GetVolumeIDs(ctx context.Context, req *cmi.GetVolumeIDsRequest) (*cmi.GetVolumeIDsResponse, error)
GetVolumeIDs returns a list of Volume IDs for all PV Specs for whom an provider volume was found
REQUEST PARAMETERS (cmi.GetVolumeIDsRequest) PVSpecList bytes(blob) PVSpecsList is a list PV specs for whom volume-IDs are required. Plugin should parse this raw data into pre-defined list of PVSpecs.
RESPONSE PARAMETERS (cmi.GetVolumeIDsResponse) VolumeIDs repeated string VolumeIDs is a repeated list of VolumeIDs.
func (*MachinePlugin) ListMachines ¶
func (ms *MachinePlugin) ListMachines(ctx context.Context, req *cmi.ListMachinesRequest) (*cmi.ListMachinesResponse, error)
ListMachines lists all the machines possibilly created by a providerSpec Identifying machines created by a given providerSpec depends on the OPTIONAL IMPLEMENTATION LOGIC you have used to identify machines created by a providerSpec. It could be tags/resource-groups etc OPTIONAL METHOD
REQUEST PARAMETERS (cmi.ListMachinesRequest) ProviderSpec bytes(blob) Template/Configuration of the machine that wouldn've been created by this ProviderSpec (Machine Class) Secrets map<string,bytes> (Optional) Contains a map from string to string contains any cloud specific secrets that can be used by the provider
RESPONSE PARAMETERS (cmi.ListMachinesResponse) MachineList map<string,string> A map containing the keys as the MachineID and value as the MachineName
for all machine's who where possibilly created by this ProviderSpec
func (*MachinePlugin) ShutDownMachine ¶
func (ms *MachinePlugin) ShutDownMachine(ctx context.Context, req *cmi.ShutDownMachineRequest) (*cmi.ShutDownMachineResponse, error)
ShutDownMachine handles a machine shutdown/power-off/stop request OPTIONAL METHOD
REQUEST PARAMETERS (cmi.ShutDownMachineRequest) ProviderSpec bytes(blob) Template/Configuration of the machine that wouldn've been created by this ProviderSpec (Machine Class) Secrets map<string,bytes> (Optional) Contains a map from string to string contains any cloud specific secrets that can be used by the provider LastKnownState bytes(blob) (Optional) Last known state of VM during last operation. Could be helpful to continue operation from previous state
RESPONSE PARAMETERS (cmi.DeleteMachineResponse) LastKnownState bytes(blob) (Optional) Last known state of VM during the current operation.
Could be helpful to continue operations in future requests.