utils

package

v0.7.0-beta.4 Latest Latest Go to latest Published: Oct 13, 2023 License: AGPL-3.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apecloud/kubeblocks

Links

Open Source Insights

Documentation ¶

Index ¶

func AddTolerations(podSpec *corev1.PodSpec) (err error)
func BuildEnvByCredential(pod *corev1.Pod, credential *dpv1alpha1.ConnectionCredential) []corev1.EnvVar
func GetActionSetByName(reqCtx intctrlutil.RequestCtx, cli client.Client, name string) (*dpv1alpha1.ActionSet, error)
func GetBackupVolumeSnapshotName(backupName, volumeSource string) string
func GetPodListByLabelSelector(reqCtx intctrlutil.RequestCtx, cli client.Client, ...) (*corev1.PodList, error)
func IsJobFinished(job *batchv1.Job) (bool, batchv1.JobConditionType, string)
func MergeEnv(originalEnv, targetEnv []corev1.EnvVar) []corev1.EnvVar
func RemoveDataProtectionFinalizer(ctx context.Context, cli client.Client, obj client.Object) error
func SetControllerReference(owner, controlled metav1.Object, scheme *runtime.Scheme) error
func VolumeSnapshotEnabled(ctx context.Context, cli client.Client, pod *corev1.Pod, volumes []string) (bool, error)
type PeriodicalEnqueueSource
- func NewPeriodicalEnqueueSource(client client.Client, objList client.ObjectList, period time.Duration, ...) *PeriodicalEnqueueSource
- func (p *PeriodicalEnqueueSource) Start(ctx context.Context, _ handler.EventHandler, q workqueue.RateLimitingInterface, ...) error
- func (p *PeriodicalEnqueueSource) String() string
type PeriodicalEnqueueSourceOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddTolerations ¶

func AddTolerations(podSpec *corev1.PodSpec) (err error)

func BuildEnvByCredential ¶

func BuildEnvByCredential(pod *corev1.Pod, credential *dpv1alpha1.ConnectionCredential) []corev1.EnvVar

func GetActionSetByName ¶

func GetActionSetByName(reqCtx intctrlutil.RequestCtx,
	cli client.Client, name string) (*dpv1alpha1.ActionSet, error)

GetActionSetByName gets the ActionSet by name.

func GetBackupVolumeSnapshotName ¶

func GetBackupVolumeSnapshotName(backupName, volumeSource string) string

func GetPodListByLabelSelector ¶

func GetPodListByLabelSelector(reqCtx intctrlutil.RequestCtx,
	cli client.Client,
	labelSelector metav1.LabelSelector) (*corev1.PodList, error)

func IsJobFinished ¶

func IsJobFinished(job *batchv1.Job) (bool, batchv1.JobConditionType, string)

func MergeEnv ¶

func MergeEnv(originalEnv, targetEnv []corev1.EnvVar) []corev1.EnvVar

MergeEnv merges the targetEnv to original env. if original env exist the same name var, it will be replaced.

func RemoveDataProtectionFinalizer ¶

func RemoveDataProtectionFinalizer(ctx context.Context, cli client.Client, obj client.Object) error

func SetControllerReference ¶

func SetControllerReference(owner, controlled metav1.Object, scheme *runtime.Scheme) error

func VolumeSnapshotEnabled ¶

func VolumeSnapshotEnabled(ctx context.Context, cli client.Client, pod *corev1.Pod, volumes []string) (bool, error)

VolumeSnapshotEnabled checks if the volumes support snapshot.

Types ¶

type PeriodicalEnqueueSource ¶

type PeriodicalEnqueueSource struct {
	client.Client
	// contains filtered or unexported fields
}

PeriodicalEnqueueSource is an implementation of interface sigs.k8s.io/controller-runtime/pkg/source/Source It reads the specific resources from cache and enqueue them into the queue to trigger the reconcile procedure periodically.

func NewPeriodicalEnqueueSource ¶

func NewPeriodicalEnqueueSource(
	client client.Client,
	objList client.ObjectList,
	period time.Duration,
	option PeriodicalEnqueueSourceOption) *PeriodicalEnqueueSource

func (*PeriodicalEnqueueSource) Start ¶

func (p *PeriodicalEnqueueSource) Start(
	ctx context.Context,
	_ handler.EventHandler,
	q workqueue.RateLimitingInterface,
	predicates ...predicate.Predicate) error

func (*PeriodicalEnqueueSource) String ¶

func (p *PeriodicalEnqueueSource) String() string

type PeriodicalEnqueueSourceOption ¶

type PeriodicalEnqueueSourceOption struct {
	OrderFunc func(objList client.ObjectList) client.ObjectList
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
boolptr

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