component

package
v1.8.1 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2024 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PVCProtectionFinalizer = "kubernetes.io/pvc-protection"
	RestartTolerancePeriod = time.Minute * 1
)
View Source 
const (
	InPlaceGracePeriodSeconds = 60

	SyncVolumeConcurrency = 5
)
View Source 
const (
	// TransLeaderBeginTime is the key of transfer Leader begin time
	TransLeaderBeginTime = "transLeaderBeginTime"
	// TransLeaderTimeout is the timeout limit of transfer leader
	TransLeaderTimeout = 30 * time.Minute

	// TransferPartitionLeaderConcurrency is the count of goroutines to transfer partition leader
	TransferPartitionLeaderConcurrency = 3

	// BalanceLeaderInterval is the interval to balance the partition leader
	BalanceLeaderInterval = 15
	// BalanceWaitingTime is the waiting time to balance the partition leader
	BalanceWaitingTime = 30
)

Variables

This section is empty.

Functions

func PVCDeleter added in v1.8.0 

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

func PVCMark added in v1.5.0 

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

Types

type FailoverManager added in v1.8.0 

type FailoverManager interface {
	// Failover moves the offline state host to a ready node
	Failover(nc *v1alpha1.NebulaCluster) error
	// Recovery clears the failure hosts in nc status
	Recovery(nc *v1alpha1.NebulaCluster, hosts []string) error
}

func NewGraphdFailover added in v1.8.1 

func NewGraphdFailover(c client.Client, clientSet kube.ClientSet) FailoverManager

func NewMetadFailover added in v1.8.1 

func NewMetadFailover(c client.Client, clientSet kube.ClientSet) FailoverManager

func NewStoragedFailover added in v1.8.0 

func NewStoragedFailover(c client.Client, clientSet kube.ClientSet) FailoverManager

type FakeGraphdCluster 

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

func NewFakeGraphdCluster 

func NewFakeGraphdCluster() *FakeGraphdCluster

func (*FakeGraphdCluster) Delete added in v1.8.1 

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

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) Delete added in v1.8.1 

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

func (*FakeMetadCluster) Reconcile 

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

func (*FakeMetadCluster) SetReconcileError 

func (f *FakeMetadCluster) SetReconcileError(err error)

type FakeNebulaConsole added in v1.6.0 

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

func NewFakeNebulaConsole added in v1.6.0 

func NewFakeNebulaConsole() *FakeNebulaConsole

func (*FakeNebulaConsole) Delete added in v1.8.1 

func (f *FakeNebulaConsole) Delete(_ *v1alpha1.NebulaCluster) error

func (*FakeNebulaConsole) Reconcile added in v1.6.0 

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

func (*FakeNebulaConsole) SetReconcileError added in v1.6.0 

func (f *FakeNebulaConsole) SetReconcileError(err error)

type FakeNebulaExporter added in v1.5.0 

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

func NewFakeNebulaExporter added in v1.5.0 

func NewFakeNebulaExporter() *FakeNebulaExporter

func (*FakeNebulaExporter) Delete added in v1.8.1 

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

func (*FakeNebulaExporter) Reconcile added in v1.5.0 

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

func (*FakeNebulaExporter) SetReconcileError added in v1.5.0 

func (f *FakeNebulaExporter) SetReconcileError(err error)

type FakeStoragedCluster 

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

func NewFakeStoragedCluster 

func NewFakeStoragedCluster() *FakeStoragedCluster

func (*FakeStoragedCluster) Delete added in v1.8.1 

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

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

	// Delete deletes the cluster
	Delete(cluster *v1alpha1.NebulaCluster) error
}

func NewGraphdCluster 

func NewGraphdCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	um UpdateManager,
	fm FailoverManager,
	recorder record.EventRecorder,
) ReconcileManager

func NewMetadCluster 

func NewMetadCluster(
	clientSet kube.ClientSet,
	dm discovery.Interface,
	um UpdateManager,
	fm FailoverManager,
	recorder record.EventRecorder,
) ReconcileManager

func NewNebulaConsole added in v1.6.0 

func NewNebulaConsole(clientSet kube.ClientSet) ReconcileManager

func NewNebulaExporter added in v1.4.1 

func NewNebulaExporter(clientSet kube.ClientSet) ReconcileManager

func NewStoragedCluster 

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

type UpdateManager added in v0.9.0 

type UpdateManager interface {
	// Update updates the cluster
	Update(nc *v1alpha1.NebulaCluster, old, new *unstructured.Unstructured, gvk schema.GroupVersionKind) error

	// RestartPod restart the specified Pod
	RestartPod(nc *v1alpha1.NebulaCluster, ordinal int32) error

	// Balance balances the cluster
	Balance(nc *v1alpha1.NebulaCluster) error
}

func NewGraphdUpdater added in v0.9.0 

func NewGraphdUpdater(podClient kube.Pod) UpdateManager

func NewMetadUpdater added in v0.9.0 

func NewMetadUpdater(podClient kube.Pod) UpdateManager

func NewStoragedUpdater added in v0.9.0 

func NewStoragedUpdater(clientSet kube.ClientSet) UpdateManager

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.