update

func IsInternalDB ¶

func IsInternalDB(db string) bool

func IsInternalUser ¶

func IsInternalUser(user string) bool

func NewUpdateFunctionSuite ¶

func NewUpdateFunctionSuite(
	updateFunc func(*v1.StatefulSet) (*v1.StatefulSet, error),
	updateStrategyFunc func(update *UpdateSts, updateTimer *UpdateTimer, l logr.Logger) (bool, error),
) *updateFunctionSuite

func PartitionedRollingUpdateStrategy ¶

func PartitionedRollingUpdateStrategy(perPodVerificationFunc func(*UpdateSts, int, logr.Logger) error,
) func(updateSts *UpdateSts, updateTimer *UpdateTimer, l logr.Logger) (bool, error)

partitionedRollingUpdateStrategy is an update strategy which updates the pods in a statefulset one at a time, and verifies the health of the cluster throughout the update.

partitionedRollingUpdateStrategy checks that all pods are ready before replacing a pod within a cluster.

After a pod has been updated, the perPodVerificationFunc will run to ensure the pod is in the expected state before continuing the update. This function takes a Kubernetes clientset, the StatefulSet being modified, and the pod number of the Statefulset that has just been updated. If it returns an error, the update is halted.

func RollingRestart ¶

func RollingRestart(
	ctx context.Context,
	update *UpdateRoach,
	cluster *UpdateCluster,
	l logr.Logger,
) error

RollingRestart performs a rolling restart on a sts.

func UpdateClusterCockroachVersion ¶

func UpdateClusterCockroachVersion(
	ctx context.Context,
	update *UpdateRoach,
	cluster *UpdateCluster,
	l logr.Logger,
) error

UpdateClusterCockroachVersion, and allows specifying custom pod timeouts, among other things, in order to enable unit testing.

func UpdateClusterRegionStatefulSet ¶

func UpdateClusterRegionStatefulSet(
	ctx context.Context,
	clientset kubernetes.Interface,
	name string,
	namespace string,
	updateSuite *updateFunctionSuite,
	waitUntilAllPodsReadyFunc func(context.Context, logr.Logger) error,
	podUpdateTimeout time.Duration,
	podMaxPollingInterval time.Duration,
	healthChecker healthchecker.HealthChecker,
	l logr.Logger,
) (bool, error)

UpdateClusterRegionStatefulSet is the regional version of updateClusterStatefulSets. See its documentation for more information on the parameters passed to this function.