Documentation
¶
Index ¶
- func Connect(address string, log logr.Logger) (*grpc.ClientConn, error)
- func GetControllerClient(restConfig *rest.Config, scheme *runtime.Scheme) (ctrlClient.Client, error)
- type ConnHandler
- type MultiClusterClient
- type PendingState
- type RemoteClusterClient
- type RemoteK8sConnHandler
- func (k8sConnHandler *RemoteK8sConnHandler) AddOrUpdateConfig(clusterID string, config *rest.Config, log logr.Logger)
- func (k8sConnHandler *RemoteK8sConnHandler) GetConnection(clusterID string) (RemoteClusterClient, error)
- func (k8sConnHandler *RemoteK8sConnHandler) Verify(ctx context.Context) error
- type RemoteK8sControllerClient
- func (c *RemoteK8sControllerClient) CreatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
- func (c *RemoteK8sControllerClient) CreateReplicationGroup(ctx context.Context, group *repV1Alpha1.DellCSIReplicationGroup) error
- func (c *RemoteK8sControllerClient) CreateStorageClass(ctx context.Context, storageClass *storageV1.StorageClass) error
- func (c *RemoteK8sControllerClient) GetCustomResourceDefinitions(ctx context.Context, crdName string) (*apiExtensionsv1.CustomResourceDefinition, error)
- func (c *RemoteK8sControllerClient) GetPersistentVolume(ctx context.Context, persistentVolumeName string) (*corev1.PersistentVolume, error)
- func (c *RemoteK8sControllerClient) GetPersistentVolumeClaim(ctx context.Context, namespace, claimName string) (*corev1.PersistentVolumeClaim, error)
- func (c *RemoteK8sControllerClient) GetReplicationGroup(ctx context.Context, replicationGroupName string) (*repV1Alpha1.DellCSIReplicationGroup, error)
- func (c *RemoteK8sControllerClient) GetStorageClass(ctx context.Context, storageClassName string) (*storageV1.StorageClass, error)
- func (c *RemoteK8sControllerClient) ListCustomResourceDefinitions(ctx context.Context) (*apiExtensionsv1.CustomResourceDefinitionList, error)
- func (c *RemoteK8sControllerClient) ListReplicationGroup(ctx context.Context) (*repV1Alpha1.DellCSIReplicationGroupList, error)
- func (c *RemoteK8sControllerClient) ListStorageClass(ctx context.Context) (*storageV1.StorageClassList, error)
- func (c *RemoteK8sControllerClient) UpdatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
- func (c *RemoteK8sControllerClient) UpdatePersistentVolumeClaim(ctx context.Context, claim *corev1.PersistentVolumeClaim) error
- func (c *RemoteK8sControllerClient) UpdateReplicationGroup(ctx context.Context, replicationGroup *repV1Alpha1.DellCSIReplicationGroup) error
- type RgIDType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetControllerClient ¶
func GetControllerClient(restConfig *rest.Config, scheme *runtime.Scheme) (ctrlClient.Client, error)
GetControllerClient - Returns a controller client which reads and writes directly to API server
Types ¶
type ConnHandler ¶
type ConnHandler interface {
Verify(ctx context.Context) error
GetConnection(clusterID string) (RemoteClusterClient, error)
}
ConnHandler - Interface
type MultiClusterClient ¶
type MultiClusterClient interface {
GetConnection(clusterID string) (RemoteClusterClient, error)
GetClusterID() string
}
MultiClusterClient interface of client that manages multiple clusters at once
type PendingState ¶
type PendingState struct {
MaxPending int
Log logr.Logger
// contains filtered or unexported fields
}
PendingState type limits the number of pending requests by making sure there are no other requests for the same RG, otherwise a "pending" error is returned. Additionally, no more than maxPending requests are processed at a time without returning an "overload" error.
type RemoteClusterClient ¶
type RemoteClusterClient interface {
GetStorageClass(ctx context.Context, storageClassName string) (*storageV1.StorageClass, error)
ListStorageClass(ctx context.Context) (*storageV1.StorageClassList, error)
CreateStorageClass(ctx context.Context, storageClass *storageV1.StorageClass) error
ListCustomResourceDefinitions(ctx context.Context) (*apiExtensionsv1.CustomResourceDefinitionList, error)
GetCustomResourceDefinitions(ctx context.Context, crdName string) (*apiExtensionsv1.CustomResourceDefinition, error)
GetPersistentVolume(ctx context.Context, persistentVolumeName string) (*corev1.PersistentVolume, error)
CreatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
UpdatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
GetPersistentVolumeClaim(ctx context.Context, namespace, claimName string) (*corev1.PersistentVolumeClaim, error)
UpdatePersistentVolumeClaim(ctx context.Context, claim *corev1.PersistentVolumeClaim) error
GetReplicationGroup(ctx context.Context, replicationGroupName string) (*repV1Alpha1.DellCSIReplicationGroup, error)
UpdateReplicationGroup(ctx context.Context, group *repV1Alpha1.DellCSIReplicationGroup) error
ListReplicationGroup(ctx context.Context) (*repV1Alpha1.DellCSIReplicationGroupList, error)
CreateReplicationGroup(ctx context.Context, group *repV1Alpha1.DellCSIReplicationGroup) error
}
RemoteClusterClient interface provides methods for creating, modifying, deleting objects on a remote k8s cluster
type RemoteK8sConnHandler ¶
type RemoteK8sConnHandler struct {
// contains filtered or unexported fields
}
RemoteK8sConnHandler handler of remote Kubernetes cluster connection
func (*RemoteK8sConnHandler) AddOrUpdateConfig ¶
func (k8sConnHandler *RemoteK8sConnHandler) AddOrUpdateConfig(clusterID string, config *rest.Config, log logr.Logger)
AddOrUpdateConfig adds (or updates) config to the list of managed clusters
func (*RemoteK8sConnHandler) GetConnection ¶
func (k8sConnHandler *RemoteK8sConnHandler) GetConnection(clusterID string) (RemoteClusterClient, error)
GetConnection returns client from the map of managed clusters
type RemoteK8sControllerClient ¶
type RemoteK8sControllerClient struct {
ClusterID string
Client ctrlClient.Client
}
RemoteK8sControllerClient - Represents a single controller split client
func (*RemoteK8sControllerClient) CreatePersistentVolume ¶
func (c *RemoteK8sControllerClient) CreatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
CreatePersistentVolume creates persistent volume object in current cluster
func (*RemoteK8sControllerClient) CreateReplicationGroup ¶
func (c *RemoteK8sControllerClient) CreateReplicationGroup(ctx context.Context, group *repV1Alpha1.DellCSIReplicationGroup) error
CreateReplicationGroup creates replication group object in current cluster
func (*RemoteK8sControllerClient) CreateStorageClass ¶
func (c *RemoteK8sControllerClient) CreateStorageClass(ctx context.Context, storageClass *storageV1.StorageClass) error
CreateStorageClass creates storage class object in current cluster
func (*RemoteK8sControllerClient) GetCustomResourceDefinitions ¶
func (c *RemoteK8sControllerClient) GetCustomResourceDefinitions(ctx context.Context, crdName string) (*apiExtensionsv1.CustomResourceDefinition, error)
GetCustomResourceDefinitions returns custom resource definition object by querying cluster using custom resource definition name
func (*RemoteK8sControllerClient) GetPersistentVolume ¶
func (c *RemoteK8sControllerClient) GetPersistentVolume(ctx context.Context, persistentVolumeName string) (*corev1.PersistentVolume, error)
GetPersistentVolume returns persistent volume object by querying cluster using persistent volume name
func (*RemoteK8sControllerClient) GetPersistentVolumeClaim ¶
func (c *RemoteK8sControllerClient) GetPersistentVolumeClaim(ctx context.Context, namespace, claimName string) (*corev1.PersistentVolumeClaim, error)
GetPersistentVolumeClaim returns persistent volume claim object by querying cluster using persistent volume claim name
func (*RemoteK8sControllerClient) GetReplicationGroup ¶
func (c *RemoteK8sControllerClient) GetReplicationGroup(ctx context.Context, replicationGroupName string) (*repV1Alpha1.DellCSIReplicationGroup, error)
GetReplicationGroup returns replication group object by querying cluster using replication group name
func (*RemoteK8sControllerClient) GetStorageClass ¶
func (c *RemoteK8sControllerClient) GetStorageClass(ctx context.Context, storageClassName string) (*storageV1.StorageClass, error)
GetStorageClass returns storage class object by querying cluster using storage class name
func (*RemoteK8sControllerClient) ListCustomResourceDefinitions ¶
func (c *RemoteK8sControllerClient) ListCustomResourceDefinitions(ctx context.Context) (*apiExtensionsv1.CustomResourceDefinitionList, error)
ListCustomResourceDefinitions returns list of custom resource definition objects that are currently in cluster
func (*RemoteK8sControllerClient) ListReplicationGroup ¶
func (c *RemoteK8sControllerClient) ListReplicationGroup(ctx context.Context) (*repV1Alpha1.DellCSIReplicationGroupList, error)
ListReplicationGroup returns list of all replication group objects that are currently in cluster
func (*RemoteK8sControllerClient) ListStorageClass ¶
func (c *RemoteK8sControllerClient) ListStorageClass(ctx context.Context) (*storageV1.StorageClassList, error)
ListStorageClass returns list of all storage classes objects that are currently in cluster
func (*RemoteK8sControllerClient) UpdatePersistentVolume ¶
func (c *RemoteK8sControllerClient) UpdatePersistentVolume(ctx context.Context, volume *corev1.PersistentVolume) error
UpdatePersistentVolume updates persistent volume object in current cluster
func (*RemoteK8sControllerClient) UpdatePersistentVolumeClaim ¶
func (c *RemoteK8sControllerClient) UpdatePersistentVolumeClaim(ctx context.Context, claim *corev1.PersistentVolumeClaim) error
UpdatePersistentVolumeClaim updates persistent volume claim object in current cluster
func (*RemoteK8sControllerClient) UpdateReplicationGroup ¶
func (c *RemoteK8sControllerClient) UpdateReplicationGroup(ctx context.Context, replicationGroup *repV1Alpha1.DellCSIReplicationGroup) error
UpdateReplicationGroup updates replication group object in current cluster
type RgIDType ¶
type RgIDType string
RgIDType represents replication group id
func (RgIDType) CheckAndUpdatePendingState ¶
func (rgID RgIDType) CheckAndUpdatePendingState(ps *PendingState) error
CheckAndUpdatePendingState sets state of current RG as pending if allowed by current capacity
func (RgIDType) ClearPending ¶
func (rgID RgIDType) ClearPending(ps *PendingState)
ClearPending removes current replication group from pending list
Source Files