component

Documentation

Index

• func PvcGc(cli client.Client, namespace, clusterName string) error
• func PvcMark(pvcClient kube.PersistentVolumeClaim, ...) error
• type FakeGraphdCluster
  • func NewFakeGraphdCluster() *FakeGraphdCluster
  • func (f *FakeGraphdCluster) Reconcile(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeGraphdCluster) SetReconcileError(err error)
• type FakeMetadCluster
  • func NewFakeMetadCluster() *FakeMetadCluster
  • func (f *FakeMetadCluster) Reconcile(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeMetadCluster) SetReconcileError(err error)
• type FakeStoragedCluster
  • func NewFakeStoragedCluster() *FakeStoragedCluster
  • func (f *FakeStoragedCluster) Reconcile(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeStoragedCluster) SetReconcileError(err error)
• type ReconcileManager
  • func NewGraphdCluster(clientSet kube.ClientSet, dm discovery.Interface, enableEvenPodsSpread bool) ReconcileManager
  • func NewMetadCluster(clientSet kube.ClientSet, dm discovery.Interface, enableEvenPodsSpread bool) ReconcileManager
  • func NewStoragedCluster(clientSet kube.ClientSet, dm discovery.Interface, sm ScaleManager, ...) ReconcileManager
• type ScaleManager
  • func NewStorageScaler(cli client.Client, clientSet kube.ClientSet) ScaleManager

Functions

func PvcGc

func PvcGc(cli client.Client, namespace, clusterName string) error

func PvcMark

func PvcMark(pvcClient kube.PersistentVolumeClaim, component v1alpha1.NebulaClusterComponentter, oldReplicas, newReplicas int32) error

Types

type FakeGraphdCluster

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

func NewFakeGraphdCluster

func NewFakeGraphdCluster() *FakeGraphdCluster

func (*FakeGraphdCluster) Reconcile

func (f *FakeGraphdCluster) Reconcile(_ *v1alpha1.NebulaCluster) error

func (*FakeGraphdCluster) SetReconcileError

func (f *FakeGraphdCluster) SetReconcileError(err error)

type FakeMetadCluster

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

func NewFakeMetadCluster

func NewFakeMetadCluster() *FakeMetadCluster

func (*FakeMetadCluster) Reconcile

func (f *FakeMetadCluster) Reconcile(_ *v1alpha1.NebulaCluster) error

func (*FakeMetadCluster) SetReconcileError

func (f *FakeMetadCluster) SetReconcileError(err error)

type FakeStoragedCluster

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

func NewFakeStoragedCluster

func NewFakeStoragedCluster() *FakeStoragedCluster

func (*FakeStoragedCluster) Reconcile

func (f *FakeStoragedCluster) Reconcile(_ *v1alpha1.NebulaCluster) error

func (*FakeStoragedCluster) SetReconcileError

func (f *FakeStoragedCluster) SetReconcileError(err error)

type ReconcileManager

type ReconcileManager interface {
	// Reconcile reconciles the cluster to desired state
	Reconcile(cluster *v1alpha1.NebulaCluster) error
}

func NewGraphdCluster

func NewGraphdCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	enableEvenPodsSpread bool) ReconcileManager

func NewMetadCluster

func NewMetadCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	enableEvenPodsSpread bool) ReconcileManager

func NewStoragedCluster

func NewStoragedCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	sm ScaleManager,
	enableEvenPodsSpread bool) ReconcileManager

type ScaleManager

type ScaleManager interface {
	// Scale scales the cluster
	Scale(nc *v1alpha1.NebulaCluster, old, new *unstructured.Unstructured) error
	// ScaleIn scales in the cluster
	ScaleIn(nc *v1alpha1.NebulaCluster, oldReplicas, newReplicas int32) error
	// ScaleOut scales out the cluster
	ScaleOut(nc *v1alpha1.NebulaCluster) error
}

func NewStorageScaler

func NewStorageScaler(cli client.Client, clientSet kube.ClientSet) ScaleManager