clients

Documentation

Index

• type Clients
  • func CreateK8SClients(apiServerIP, kubeConfigPath string) (*Clients, error)
• 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) UpdateTridentConfiguratorStatus(tconfCR *operatorV1.TridentConfigurator, ...) (*operatorV1.TridentConfigurator, bool, error)
• type OperatorCRDClientInterface
  • func NewOperatorCRDClient(client operatorClient.Interface) 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
  • func NewSnapshotCRDClient(client snapshotClient.Interface) 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) PatchTridentBackendConfig(name, namespace string, patchBytes []byte, patchType types.PatchType) error
• type TridentCRDClientInterface
  • func NewTridentCRDClient(client tridentClient.Interface) TridentCRDClientInterface

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

func CreateK8SClients(apiServerIP, kubeConfigPath string) (*Clients, error)

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) 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)
}

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

func (sc *SnapshotCRDClient) PatchVolumeSnapshotClass(name string, patchBytes []byte, patchType types.PatchType) error

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) PatchTridentBackendConfig

func (tc *TridentCRDClient) PatchTridentBackendConfig(name, namespace string, patchBytes []byte, patchType types.PatchType) error

type TridentCRDClientInterface

type TridentCRDClientInterface interface {
	CheckTridentBackendConfigExists(name, namespace string) (bool, error)
	GetTridentBackendConfig(name, namespace 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