component

Documentation

Index

• Constants
• func PVCMark(pvcClient kube.PersistentVolumeClaim, ...) error
• func PvcGc(cli client.Client, namespace, clusterName string) 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 FakeNebulaExporter
  • func NewFakeNebulaExporter() *FakeNebulaExporter
  • func (f *FakeNebulaExporter) Reconcile(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeNebulaExporter) 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 PVCMark

func PVCMark(pvcClient kube.PersistentVolumeClaim, component v1alpha1.NebulaClusterComponent, oldReplicas, newReplicas int32) error

func PvcGc

func PvcGc(cli client.Client, namespace, clusterName string) 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 FakeNebulaExporter

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

func NewFakeNebulaExporter

func NewFakeNebulaExporter() *FakeNebulaExporter

func (*FakeNebulaExporter) Reconcile

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

func (*FakeNebulaExporter) SetReconcileError

func (f *FakeNebulaExporter) 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,
) ReconcileManager

func NewMetadCluster

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

func NewNebulaExporter

func NewNebulaExporter(clientSet kube.ClientSet) ReconcileManager

func NewStoragedCluster

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