coordinator

package

v2.14.0 Latest Latest Go to latest Published: Sep 19, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

Index ¶

func ChangeCoordinators(logger logr.Logger, adminClient fdbadminclient.AdminClient, ...) error
func GetCoordinatorAddress(cluster *fdbv1beta2.FoundationDBCluster, locality locality.Info) fdbv1beta2.ProcessAddress
func SelectCoordinators(logger logr.Logger, cluster *fdbv1beta2.FoundationDBCluster, ...) ([]fdbv1beta2.ProcessAddress, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ChangeCoordinators ¶

func ChangeCoordinators(
	logger logr.Logger,
	adminClient fdbadminclient.AdminClient,
	cluster *fdbv1beta2.FoundationDBCluster,
	status *fdbv1beta2.FoundationDBStatus,
) error

ChangeCoordinators will change the coordinators and set the new connection string on the FoundationDBCluster resource.

func GetCoordinatorAddress ¶

func GetCoordinatorAddress(
	cluster *fdbv1beta2.FoundationDBCluster,
	locality locality.Info,
) fdbv1beta2.ProcessAddress

GetCoordinatorAddress returns the coordinator address.

func SelectCoordinators ¶

func SelectCoordinators(
	logger logr.Logger,
	cluster *fdbv1beta2.FoundationDBCluster,
	status *fdbv1beta2.FoundationDBStatus,
	pendingRemovals map[fdbv1beta2.ProcessGroupID]time.Time,
) ([]fdbv1beta2.ProcessAddress, error)

SelectCoordinators will return a set of new coordinators.

Types ¶

This section is empty.

Source Files ¶

View all Source files

coordinator.go

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