Documentation
¶
Index ¶
- type Clients
- type OperatorCRDClient
- func (oc *OperatorCRDClient) GetControllingTorcCR() (*operatorV1.TridentOrchestrator, error)
- func (oc *OperatorCRDClient) GetTconfCR(name string) (*operatorV1.TridentConfigurator, error)
- func (oc *OperatorCRDClient) GetTconfCRList() (*operatorV1.TridentConfiguratorList, error)
- func (oc *OperatorCRDClient) GetTorcCRList() (*operatorV1.TridentOrchestratorList, error)
- func (oc *OperatorCRDClient) UpdateTridentConfigurator(tconfCR *operatorV1.TridentConfigurator) error
- func (oc *OperatorCRDClient) UpdateTridentConfiguratorStatus(tconfCR *operatorV1.TridentConfigurator, ...) (*operatorV1.TridentConfigurator, bool, error)
- type OperatorCRDClientInterface
- type SnapshotCRDClient
- func (sc *SnapshotCRDClient) CheckVolumeSnapshotClassExists(name string) (bool, error)
- func (sc *SnapshotCRDClient) DeleteVolumeSnapshotClass(name string) error
- func (sc *SnapshotCRDClient) GetVolumeSnapshotClass(name string) (*snapshotv1.VolumeSnapshotClass, error)
- func (sc *SnapshotCRDClient) PatchVolumeSnapshotClass(name string, patchBytes []byte, patchType types.PatchType) error
- type SnapshotCRDClientInterface
- type TridentCRDClient
- func (tc *TridentCRDClient) CheckTridentBackendConfigExists(name, namespace string) (bool, error)
- func (tc *TridentCRDClient) DeleteTridentBackendConfig(name, namespace string) error
- func (tc *TridentCRDClient) GetTridentBackendConfig(name, namespace string) (*tridentV1.TridentBackendConfig, error)
- func (tc *TridentCRDClient) ListTridentBackend(namespace string) (*tridentV1.TridentBackendList, error)
- func (tc *TridentCRDClient) ListTridentBackendsByLabel(namespace, labelKey, labelValue string) ([]*tridentV1.TridentBackendConfig, error)
- func (tc *TridentCRDClient) PatchTridentBackendConfig(name, namespace string, patchBytes []byte, patchType types.PatchType) error
- type TridentCRDClientInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Clients ¶
type Clients struct {
KubeConfig *rest.Config
KubeClient *kubernetes.Clientset
K8SClient k8sclient.KubernetesClient
CRDClient *versioned.Clientset
TridentCRDClient *tridentClient.Clientset
SnapshotClient *snapshotClient.Clientset
K8SVersion *k8sversion.Info
Namespace string
}
func CreateK8SClients ¶
type OperatorCRDClient ¶
type OperatorCRDClient struct {
// contains filtered or unexported fields
}
func (*OperatorCRDClient) GetControllingTorcCR ¶
func (oc *OperatorCRDClient) GetControllingTorcCR() (*operatorV1.TridentOrchestrator, error)
func (*OperatorCRDClient) GetTconfCR ¶
func (oc *OperatorCRDClient) GetTconfCR(name string) (*operatorV1.TridentConfigurator, error)
func (*OperatorCRDClient) GetTconfCRList ¶
func (oc *OperatorCRDClient) GetTconfCRList() (*operatorV1.TridentConfiguratorList, error)
func (*OperatorCRDClient) GetTorcCRList ¶
func (oc *OperatorCRDClient) GetTorcCRList() (*operatorV1.TridentOrchestratorList, error)
func (*OperatorCRDClient) UpdateTridentConfigurator ¶
func (oc *OperatorCRDClient) UpdateTridentConfigurator(tconfCR *operatorV1.TridentConfigurator) error
UpdateTridentConfigurator updates the TridentConfigurator CR (metadata/spec, not status)
func (*OperatorCRDClient) UpdateTridentConfiguratorStatus ¶
func (oc *OperatorCRDClient) UpdateTridentConfiguratorStatus( tconfCR *operatorV1.TridentConfigurator, newStatus operatorV1.TridentConfiguratorStatus, ) (*operatorV1.TridentConfigurator, bool, error)
type OperatorCRDClientInterface ¶
type OperatorCRDClientInterface interface {
GetTconfCR(name string) (*operatorV1.TridentConfigurator, error)
GetTconfCRList() (*operatorV1.TridentConfiguratorList, error)
GetTorcCRList() (*operatorV1.TridentOrchestratorList, error)
GetControllingTorcCR() (*operatorV1.TridentOrchestrator, error)
UpdateTridentConfiguratorStatus(
tconfCR *operatorV1.TridentConfigurator, newStatus operatorV1.TridentConfiguratorStatus,
) (*operatorV1.TridentConfigurator, bool, error)
UpdateTridentConfigurator(tconfCR *operatorV1.TridentConfigurator) error
}
func NewOperatorCRDClient ¶
func NewOperatorCRDClient(client operatorClient.Interface) OperatorCRDClientInterface
type SnapshotCRDClient ¶
type SnapshotCRDClient struct {
// contains filtered or unexported fields
}
func (*SnapshotCRDClient) CheckVolumeSnapshotClassExists ¶
func (sc *SnapshotCRDClient) CheckVolumeSnapshotClassExists(name string) (bool, error)
func (*SnapshotCRDClient) DeleteVolumeSnapshotClass ¶
func (sc *SnapshotCRDClient) DeleteVolumeSnapshotClass(name string) error
func (*SnapshotCRDClient) GetVolumeSnapshotClass ¶
func (sc *SnapshotCRDClient) GetVolumeSnapshotClass(name string) (*snapshotv1.VolumeSnapshotClass, error)
func (*SnapshotCRDClient) PatchVolumeSnapshotClass ¶
type SnapshotCRDClientInterface ¶
type SnapshotCRDClientInterface interface {
CheckVolumeSnapshotClassExists(name string) (bool, error)
GetVolumeSnapshotClass(name string) (*snapshotv1.VolumeSnapshotClass, error)
PatchVolumeSnapshotClass(name string, patchBytes []byte, patchType types.PatchType) error
DeleteVolumeSnapshotClass(name string) error
}
func NewSnapshotCRDClient ¶
func NewSnapshotCRDClient(client snapshotClient.Interface) SnapshotCRDClientInterface
type TridentCRDClient ¶
type TridentCRDClient struct {
// contains filtered or unexported fields
}
func (*TridentCRDClient) CheckTridentBackendConfigExists ¶
func (tc *TridentCRDClient) CheckTridentBackendConfigExists(name, namespace string) (bool, error)
func (*TridentCRDClient) DeleteTridentBackendConfig ¶
func (tc *TridentCRDClient) DeleteTridentBackendConfig(name, namespace string) error
func (*TridentCRDClient) GetTridentBackendConfig ¶
func (tc *TridentCRDClient) GetTridentBackendConfig(name, namespace string) (*tridentV1.TridentBackendConfig, error)
func (*TridentCRDClient) ListTridentBackend ¶
func (tc *TridentCRDClient) ListTridentBackend(namespace string) (*tridentV1.TridentBackendList, error)
func (*TridentCRDClient) ListTridentBackendsByLabel ¶
func (tc *TridentCRDClient) ListTridentBackendsByLabel(namespace, labelKey, labelValue string) ([]*tridentV1.TridentBackendConfig, error)
ListTridentBackendsByLabel lists TridentBackendConfigs with a specific label. It is useful for cleaning up associated backends when a TridentConfigurator is deleted.
func (*TridentCRDClient) PatchTridentBackendConfig ¶
type TridentCRDClientInterface ¶
type TridentCRDClientInterface interface {
CheckTridentBackendConfigExists(name, namespace string) (bool, error)
GetTridentBackendConfig(name, namespace string) (*tridentV1.TridentBackendConfig, error)
ListTridentBackend(namespace string) (*tridentV1.TridentBackendList, error)
ListTridentBackendsByLabel(namespace, labelKey, labelValue string) ([]*tridentV1.TridentBackendConfig, error)
PatchTridentBackendConfig(name, namespace string, patchBytes []byte, patchType types.PatchType) error
DeleteTridentBackendConfig(name, namespace string) error
}
func NewTridentCRDClient ¶
func NewTridentCRDClient(client tridentClient.Interface) TridentCRDClientInterface
Click to show internal directories.
Click to hide internal directories.