storageoscluster

package
v0.0.0-...-c44a825 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2023 License: MIT Imports: 54 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// TaintNodeOutOfDisk will be added when node runs out of disk space, and
	// removed when disk space becomes available.
	// NOTE: It is not an upstream constant.
	TaintNodeOutOfDisk = "node.kubernetes.io/out-of-disk"
)

Variables

This section is empty.

Functions

func NewOperator 

func NewOperator(mgr ctrl.Manager, appsGetter tappv1.AppsV1Interface, policyGetter tpolicyv1.PolicyV1Interface, kubeVersion, kubeDistro string, fs filesys.FileSystem, execStrategy executor.ExecutionStrategy) (*operatorv1.CompositeOperator, error)

Types

type APIManagerOperand 

type APIManagerOperand struct {
	// contains filtered or unexported fields
}

func NewAPIManagerOperand 

func NewAPIManagerOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *APIManagerOperand

func (*APIManagerOperand) CleanupRequires 

func (c *APIManagerOperand) CleanupRequires() []string

func (*APIManagerOperand) Delete 

func (c *APIManagerOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*APIManagerOperand) Ensure 

func (c *APIManagerOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*APIManagerOperand) Name 

func (c *APIManagerOperand) Name() string

func (*APIManagerOperand) PostReady 

func (c *APIManagerOperand) PostReady(ctx context.Context, obj client.Object) error

func (*APIManagerOperand) ReadyCheck 

func (c *APIManagerOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*APIManagerOperand) RequeueStrategy 

func (c *APIManagerOperand) RequeueStrategy() operand.RequeueStrategy

func (*APIManagerOperand) Requires 

func (c *APIManagerOperand) Requires() []string

type AfterInstallOperand 

type AfterInstallOperand struct {
	// contains filtered or unexported fields
}

func NewAfterInstallOperand 

func NewAfterInstallOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *AfterInstallOperand

func (*AfterInstallOperand) CleanupRequires 

func (ai *AfterInstallOperand) CleanupRequires() []string

func (*AfterInstallOperand) Delete 

func (ai *AfterInstallOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*AfterInstallOperand) Ensure 

func (ai *AfterInstallOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*AfterInstallOperand) Name 

func (ai *AfterInstallOperand) Name() string

func (*AfterInstallOperand) PostReady 

func (c *AfterInstallOperand) PostReady(ctx context.Context, obj client.Object) error

func (*AfterInstallOperand) ReadyCheck 

func (ai *AfterInstallOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*AfterInstallOperand) RequeueStrategy 

func (ai *AfterInstallOperand) RequeueStrategy() operand.RequeueStrategy

func (*AfterInstallOperand) Requires 

func (ai *AfterInstallOperand) Requires() []string

type BeforeInstallOperand 

type BeforeInstallOperand struct {
	// contains filtered or unexported fields
}

func NewBeforeInstallOperand 

func NewBeforeInstallOperand(
	name string,
	client client.Client,
	kubeDistro string,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *BeforeInstallOperand

func (*BeforeInstallOperand) CleanupRequires 

func (bi *BeforeInstallOperand) CleanupRequires() []string

func (*BeforeInstallOperand) Delete 

func (bi *BeforeInstallOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*BeforeInstallOperand) Ensure 

func (bi *BeforeInstallOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*BeforeInstallOperand) Name 

func (bi *BeforeInstallOperand) Name() string

func (*BeforeInstallOperand) PostReady 

func (c *BeforeInstallOperand) PostReady(ctx context.Context, obj client.Object) error

func (*BeforeInstallOperand) ReadyCheck 

func (bi *BeforeInstallOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*BeforeInstallOperand) RequeueStrategy 

func (bi *BeforeInstallOperand) RequeueStrategy() operand.RequeueStrategy

func (*BeforeInstallOperand) Requires 

func (bi *BeforeInstallOperand) Requires() []string

type CLIOperand 

type CLIOperand struct {
	// contains filtered or unexported fields
}

func NewCLIOperand 

func NewCLIOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *CLIOperand

func (*CLIOperand) CleanupRequires 

func (c *CLIOperand) CleanupRequires() []string

func (*CLIOperand) Delete 

func (c *CLIOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*CLIOperand) Ensure 

func (c *CLIOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*CLIOperand) Name 

func (c *CLIOperand) Name() string

func (*CLIOperand) PostReady 

func (c *CLIOperand) PostReady(ctx context.Context, obj client.Object) error

func (*CLIOperand) ReadyCheck 

func (c *CLIOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*CLIOperand) RequeueStrategy 

func (c *CLIOperand) RequeueStrategy() operand.RequeueStrategy

func (*CLIOperand) Requires 

func (c *CLIOperand) Requires() []string

type CSIOperand 

type CSIOperand struct {
	// contains filtered or unexported fields
}

func NewCSIOperand 

func NewCSIOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *CSIOperand

func (*CSIOperand) CleanupRequires 

func (c *CSIOperand) CleanupRequires() []string

func (*CSIOperand) Delete 

func (c *CSIOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*CSIOperand) Ensure 

func (c *CSIOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*CSIOperand) Name 

func (c *CSIOperand) Name() string

func (*CSIOperand) PostReady 

func (c *CSIOperand) PostReady(ctx context.Context, obj client.Object) error

func (*CSIOperand) ReadyCheck 

func (c *CSIOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*CSIOperand) RequeueStrategy 

func (c *CSIOperand) RequeueStrategy() operand.RequeueStrategy

func (*CSIOperand) Requires 

func (c *CSIOperand) Requires() []string

type MetricsExporterOperand 

type MetricsExporterOperand struct {
	// contains filtered or unexported fields
}

func NewMetricsExporterOperand 

func NewMetricsExporterOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *MetricsExporterOperand

func (*MetricsExporterOperand) CleanupRequires 

func (c *MetricsExporterOperand) CleanupRequires() []string

func (*MetricsExporterOperand) Delete 

func (c *MetricsExporterOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*MetricsExporterOperand) Ensure 

func (c *MetricsExporterOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*MetricsExporterOperand) Name 

func (c *MetricsExporterOperand) Name() string

func (*MetricsExporterOperand) PostReady 

func (c *MetricsExporterOperand) PostReady(ctx context.Context, obj client.Object) error

func (*MetricsExporterOperand) ReadyCheck 

func (c *MetricsExporterOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*MetricsExporterOperand) RequeueStrategy 

func (c *MetricsExporterOperand) RequeueStrategy() operand.RequeueStrategy

func (*MetricsExporterOperand) Requires 

func (c *MetricsExporterOperand) Requires() []string

type NodeManagerOperand 

type NodeManagerOperand struct {
	// contains filtered or unexported fields
}

func NewNodeManagerOperand 

func NewNodeManagerOperand(
	name string,
	client client.Client,
	appsGetter tappv1.AppsV1Interface,
	policyGetter tpolicyv1.PolicyV1Interface,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *NodeManagerOperand

func (*NodeManagerOperand) CleanupRequires 

func (c *NodeManagerOperand) CleanupRequires() []string

func (*NodeManagerOperand) Delete 

func (c *NodeManagerOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*NodeManagerOperand) Ensure 

func (c *NodeManagerOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*NodeManagerOperand) Name 

func (c *NodeManagerOperand) Name() string

func (*NodeManagerOperand) PostReady 

func (c *NodeManagerOperand) PostReady(ctx context.Context, obj client.Object) error

func (*NodeManagerOperand) ReadyCheck 

func (c *NodeManagerOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*NodeManagerOperand) RequeueStrategy 

func (c *NodeManagerOperand) RequeueStrategy() operand.RequeueStrategy

func (*NodeManagerOperand) Requires 

func (c *NodeManagerOperand) Requires() []string

type NodeOperand 

type NodeOperand struct {
	// contains filtered or unexported fields
}

func NewNodeOperand 

func NewNodeOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *NodeOperand

func (*NodeOperand) CleanupRequires 

func (c *NodeOperand) CleanupRequires() []string

func (*NodeOperand) Delete 

func (c *NodeOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*NodeOperand) Ensure 

func (c *NodeOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*NodeOperand) Name 

func (c *NodeOperand) Name() string

func (*NodeOperand) PostReady 

func (c *NodeOperand) PostReady(ctx context.Context, obj client.Object) error

PostReady performs actions after the control-plane is ready.

func (*NodeOperand) ReadyCheck 

func (c *NodeOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*NodeOperand) RequeueStrategy 

func (c *NodeOperand) RequeueStrategy() operand.RequeueStrategy

func (*NodeOperand) Requires 

func (c *NodeOperand) Requires() []string

type PortalManagerOperand 

type PortalManagerOperand struct {
	// contains filtered or unexported fields
}

func NewPortalManagerOperand 

func NewPortalManagerOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *PortalManagerOperand

func (*PortalManagerOperand) CleanupRequires 

func (c *PortalManagerOperand) CleanupRequires() []string

func (*PortalManagerOperand) Delete 

func (c *PortalManagerOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*PortalManagerOperand) Ensure 

func (c *PortalManagerOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*PortalManagerOperand) Name 

func (c *PortalManagerOperand) Name() string

func (*PortalManagerOperand) PostReady 

func (c *PortalManagerOperand) PostReady(ctx context.Context, obj client.Object) error

func (*PortalManagerOperand) ReadyCheck 

func (c *PortalManagerOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*PortalManagerOperand) RequeueStrategy 

func (c *PortalManagerOperand) RequeueStrategy() operand.RequeueStrategy

func (*PortalManagerOperand) Requires 

func (c *PortalManagerOperand) Requires() []string

type SchedulerOperand 

type SchedulerOperand struct {
	// contains filtered or unexported fields
}

func NewSchedulerOperand 

func NewSchedulerOperand(
	name string,
	client client.Client,
	kubeVersion string,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *SchedulerOperand

func (*SchedulerOperand) CleanupRequires 

func (c *SchedulerOperand) CleanupRequires() []string

func (*SchedulerOperand) Delete 

func (c *SchedulerOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*SchedulerOperand) Ensure 

func (c *SchedulerOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*SchedulerOperand) Name 

func (c *SchedulerOperand) Name() string

func (*SchedulerOperand) PostReady 

func (c *SchedulerOperand) PostReady(ctx context.Context, obj client.Object) error

func (*SchedulerOperand) ReadyCheck 

func (c *SchedulerOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*SchedulerOperand) RequeueStrategy 

func (c *SchedulerOperand) RequeueStrategy() operand.RequeueStrategy

func (*SchedulerOperand) Requires 

func (c *SchedulerOperand) Requires() []string

type StorageClassOperand 

type StorageClassOperand struct {
	// contains filtered or unexported fields
}

func NewStorageClassOperand 

func NewStorageClassOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *StorageClassOperand

func (*StorageClassOperand) CleanupRequires 

func (sc *StorageClassOperand) CleanupRequires() []string

func (*StorageClassOperand) Delete 

func (sc *StorageClassOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*StorageClassOperand) Ensure 

func (sc *StorageClassOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*StorageClassOperand) Name 

func (sc *StorageClassOperand) Name() string

func (*StorageClassOperand) PostReady 

func (c *StorageClassOperand) PostReady(ctx context.Context, obj client.Object) error

func (*StorageClassOperand) ReadyCheck 

func (sc *StorageClassOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*StorageClassOperand) RequeueStrategy 

func (sc *StorageClassOperand) RequeueStrategy() operand.RequeueStrategy

func (*StorageClassOperand) Requires 

func (sc *StorageClassOperand) Requires() []string

type StorageOSClusterController 

type StorageOSClusterController struct {
	Operator operatorv1.Operator
	Client   client.Client
}

func NewStorageOSClusterController 

func NewStorageOSClusterController(mgr ctrl.Manager, appsGetter tappv1.AppsV1Interface, policyGetter tpolicyv1.PolicyV1Interface, kubeVersion, kubeDistro string, fs filesys.FileSystem, execStrategy executor.ExecutionStrategy) (*StorageOSClusterController, error)

func (*StorageOSClusterController) Cleanup 

func (c *StorageOSClusterController) Cleanup(ctx context.Context, obj client.Object) (result ctrl.Result, err error)

func (*StorageOSClusterController) Default 

func (c *StorageOSClusterController) Default(context.Context, client.Object)

func (*StorageOSClusterController) Initialize 

func (c *StorageOSClusterController) Initialize(ctx context.Context, obj client.Object, condn metav1.Condition) error

func (*StorageOSClusterController) Operate 

func (c *StorageOSClusterController) Operate(ctx context.Context, obj client.Object) (result ctrl.Result, err error)

func (*StorageOSClusterController) UpdateStatus 

func (c *StorageOSClusterController) UpdateStatus(ctx context.Context, obj client.Object) error

func (*StorageOSClusterController) Validate 

func (c *StorageOSClusterController) Validate(context.Context, client.Object) error

type VolumeSnapshotClassOperand 

type VolumeSnapshotClassOperand struct {
	// contains filtered or unexported fields
}

func NewVolumeSnapshotClassOperand 

func NewVolumeSnapshotClassOperand(
	name string,
	client client.Client,
	requires []string,
	cleanupRequires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *VolumeSnapshotClassOperand

func (*VolumeSnapshotClassOperand) CleanupRequires 

func (sc *VolumeSnapshotClassOperand) CleanupRequires() []string

func (*VolumeSnapshotClassOperand) Delete 

func (sc *VolumeSnapshotClassOperand) Delete(ctx context.Context, obj client.Object) (eventv1.ReconcilerEvent, error)

func (*VolumeSnapshotClassOperand) Ensure 

func (sc *VolumeSnapshotClassOperand) Ensure(ctx context.Context, obj client.Object, ownerRef metav1.OwnerReference) (eventv1.ReconcilerEvent, error)

func (*VolumeSnapshotClassOperand) Name 

func (sc *VolumeSnapshotClassOperand) Name() string

func (*VolumeSnapshotClassOperand) PostReady 

func (c *VolumeSnapshotClassOperand) PostReady(ctx context.Context, obj client.Object) error

func (*VolumeSnapshotClassOperand) ReadyCheck 

func (sc *VolumeSnapshotClassOperand) ReadyCheck(ctx context.Context, obj client.Object) (bool, error)

func (*VolumeSnapshotClassOperand) RequeueStrategy 

func (sc *VolumeSnapshotClassOperand) RequeueStrategy() operand.RequeueStrategy

func (*VolumeSnapshotClassOperand) Requires 

func (sc *VolumeSnapshotClassOperand) Requires() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.