storageoscluster

package
Version: v0.0.0-...-9672418 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2022 License: MIT Imports: 42 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, kubeVersion 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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *APIManagerOperand

func (*APIManagerOperand) Delete

func (*APIManagerOperand) Ensure

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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *AfterInstallOperand

func (*AfterInstallOperand) Delete

func (*AfterInstallOperand) Ensure

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,
	requires []string,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *BeforeInstallOperand

func (*BeforeInstallOperand) Delete

func (*BeforeInstallOperand) Ensure

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 CSIOperand

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

func NewCSIOperand

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

func (*CSIOperand) Delete

func (*CSIOperand) Ensure

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 NodeManagerOperand

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

func NewNodeManagerOperand

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

func (*NodeManagerOperand) Delete

func (*NodeManagerOperand) Ensure

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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *NodeOperand

func (*NodeOperand) Delete

func (*NodeOperand) Ensure

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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *PortalManagerOperand

func (*PortalManagerOperand) Delete

func (*PortalManagerOperand) Ensure

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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *SchedulerOperand

func (*SchedulerOperand) Delete

func (*SchedulerOperand) Ensure

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,
	requeueStrategy operand.RequeueStrategy,
	fs filesys.FileSystem,
	kcl kubectl.KubectlClient,
) *StorageClassOperand

func (*StorageClassOperand) Delete

func (*StorageClassOperand) Ensure

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, kubeVersion 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 (*StorageOSClusterController) Initialize

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL