component

Documentation

Index

• Constants
• 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, um UpdateManager, ...) ReconcileManager
  • func NewMetadCluster(clientSet kube.ClientSet, dm discovery.Interface, um UpdateManager, ...) ReconcileManager
  • func NewNebulaExporter(clientSet kube.ClientSet) ReconcileManager
  • func NewStoragedCluster(clientSet kube.ClientSet, dm discovery.Interface, sm ScaleManager, ...) ReconcileManager
• type ScaleManager
  • func NewStorageScaler(cli client.Client, clientSet kube.ClientSet) ScaleManager
• type UpdateManager
  • func NewGraphdUpdater(podClient kube.Pod) UpdateManager
  • func NewMetadUpdater(podClient kube.Pod) UpdateManager
  • func NewStoragedUpdater(cli client.Client, clientSet kube.ClientSet) UpdateManager

Constants

const (
	// TransLeaderBeginTime is the key of trans Leader begin time
	TransLeaderBeginTime = "transLeaderBeginTime"
	// TransLeaderTimeout is the timeout limit of trans leader
	TransLeaderTimeout = 30 * time.Minute
)

const (
	InPlaceGracePeriodSeconds = 60
)

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,
	um UpdateManager,
	enableEvenPodsSpread bool) ReconcileManager

func NewMetadCluster

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

func NewNebulaExporter

func NewNebulaExporter(clientSet kube.ClientSet) ReconcileManager

func NewStoragedCluster

func NewStoragedCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	sm ScaleManager,
	um UpdateManager,
	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

type UpdateManager

type UpdateManager interface {
	// Update updates the cluster, as NebulaGraph doesn't support hot upgrade, the image tag remain unchanged
	Update(nc *v1alpha1.NebulaCluster, old, new *unstructured.Unstructured, gvk schema.GroupVersionKind) error
}

func NewGraphdUpdater

func NewGraphdUpdater(podClient kube.Pod) UpdateManager

func NewMetadUpdater

func NewMetadUpdater(podClient kube.Pod) UpdateManager

func NewStoragedUpdater

func NewStoragedUpdater(cli client.Client, clientSet kube.ClientSet) UpdateManager