fixtures

package

Go to main page

Versions in this module

v1

v1.39.0

May 17, 2024

v1.38.0

May 8, 2024

Changes in this version

type SidecarConfig

+ CopyAsPrimary bool

v1.37.0

Apr 19, 2024

v1.36.0

Apr 5, 2024

v1.35.0

Mar 25, 2024

Changes in this version

+ func FdbPrintable(d []byte) string

type FdbCluster

+ func (fdbCluster *FdbCluster) GetListOfUIDsFromVolumeClaims(processClass fdbv1beta2.ProcessClass) []types.UID

v1.34.0

Mar 9, 2024

v1.33.0

Jan 29, 2024

v1.32.0

Jan 29, 2024

Changes in this version

type Factory

+ func (factory *Factory) InjectPartitionBetweenWithDirection(source chaosmesh.PodSelectorSpec, target chaosmesh.PodSelectorSpec, ...) *ChaosMeshExperiment

v1.31.0

Jan 12, 2024

v1.30.0

Dec 15, 2023

v1.29.0

Dec 1, 2023

Changes in this version

type Factory

+ func (factory *Factory) Delete(object client.Object)

v1.28.1

Nov 13, 2023

v1.28.0

Nov 8, 2023

v1.27.0

Oct 23, 2023

Changes in this version

type Factory

+ func (factory *Factory) CreateDataLoaderIfAbsent(cluster *FdbCluster)

+ func (factory *Factory) GetDataLoaderImage() string

+ func (factory *Factory) WaitUntilDataLoaderIsDone(cluster *FdbCluster)

type FdbCluster

+ func (fdbCluster *FdbCluster) EnsureTeamTrackersAreHealthy()

+ func (fdbCluster *FdbCluster) EnsureTeamTrackersHaveMinReplicas()

v1.26.0

Oct 9, 2023

Changes in this version

type ClusterConfig

+ UseDNS bool

+ UseLocalityBasedExclusions bool

type HaFdbCluster

+ func (haFDBCluster *HaFdbCluster) VerifyVersion(version string)

v1.25.0

Sep 22, 2023

Changes in this version

type FdbCluster

+ func (fdbCluster *FdbCluster) UpgradeAndVerify(version string)

+ func (fdbCluster *FdbCluster) VerifyVersion(version string)

v1.24.0

Sep 5, 2023

Changes in this version

type Factory

+ func (factory *Factory) GetContext() string

type FdbCluster

+ func (fdbCluster *FdbCluster) UpdateAnnotationsAndLabels(annotations map[string]string, labels map[string]string)

v1.23.0

Aug 15, 2023

Changes in this version

+ func LoadControllerRuntimeFromContext(context string, configScheme *runtime.Scheme) (client.Client, error)

type ClusterConfig

+ UseMaintenanceMode bool

+ func (config *ClusterConfig) Copy() *ClusterConfig

type FdbCluster

+ func (fdbCluster *FdbCluster) ValidateProcessesCount(processClass fdbv1beta2.ProcessClass, countProcessGroups int, countServer int)

v1.22.0

Jul 28, 2023

v1.21.0

Jul 14, 2023

Changes in this version

type ClusterConfig

+ LogServersPerPod int

type FdbCluster

+ func (fdbCluster *FdbCluster) GetLogServersPerPod() int

+ func (fdbCluster *FdbCluster) GetProcessCountByProcessClass(pClass fdbv1beta2.ProcessClass) int

+ func (fdbCluster *FdbCluster) GetTransactionPods() *corev1.PodList

+ func (fdbCluster *FdbCluster) SetLogServersPerPod(serverPerPod int, waitForReconcile bool) error

+ func (fdbCluster *FdbCluster) SetTransactionServerPerPod(serverPerPod int, processCount int, waitForReconcile bool) error

v1.20.1

Jul 6, 2023

v1.20.0

Jun 30, 2023

Changes in this version

+ func WithUnifiedImage(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

type Factory

+ func (factory *Factory) CreateFdbClusterFromSpec(spec *fdbv1beta2.FoundationDBCluster, config *ClusterConfig, ...) *FdbCluster

+ func (factory *Factory) GenerateFDBClusterSpec(config *ClusterConfig) *fdbv1beta2.FoundationDBCluster

+ func (factory *Factory) GetLogsForPod(pod corev1.Pod, container string, since *int64) string

v1.19.0

Jun 16, 2023

Changes in this version

type FdbCluster

+ func (fdbCluster *FdbCluster) SetProcessGroupsAsUnschedulable(procesGroups []fdbv1beta2.ProcessGroupID)

type SidecarConfig

+ ImagePullPolicy corev1.PullPolicy

v1.18.0

Jun 1, 2023

Changes in this version

type FdbCluster

+ func (fdbCluster *FdbCluster) CheckPodIsDeleted(podName string) bool

+ func (fdbCluster *FdbCluster) EnsurePodIsDeletedWithCustomTimeout(podName string, timeoutMinutes int)

+ func (fdbCluster *FdbCluster) ForceReconcile()

+ func (fdbCluster *FdbCluster) GetAutomationOptions() fdbv1beta2.FoundationDBClusterAutomationOptions

+ func (fdbCluster *FdbCluster) GetNode(name string) *corev1.Node

+ func (fdbCluster *FdbCluster) SetClusterTaintConfig(taintOption []fdbv1beta2.TaintReplacementOption, ...)

+ func (fdbCluster *FdbCluster) UpdateNode(node *corev1.Node)

+ func (fdbCluster *FdbCluster) WaitUntilWithForceReconcile(pollTimeInSeconds int, timeOutInSeconds int, ...) error

v1.17.0

May 6, 2023

Changes in this version

+ const ChaosDurationForever

+ const PrimaryID

+ const PrimarySatelliteID

+ const RemoteID

+ const RemoteSatelliteID

+ const SatelliteID

+ func CheckInvariant(invariantName string, shutdownHooks *ShutdownHooks, threshold time.Duration, ...) error

+ func ChooseRandomPod(pods *corev1.PodList) *corev1.Pod

+ func GenerateCertificate() (*corev1.Secret, error)

+ func GenerateUpgradeTableEntries(options *FactoryOptions) []ginkgo.TableEntry

+ func GetBaseImageAndTag(image string) (string, string)

+ func GetDcIDsFromConfig(databaseConfiguration fdbv1beta2.DatabaseConfiguration) []string

+ func GetDebugImage(debug bool, image string) string

+ func GetOperatorSelector(namespace string) chaosmeshv1alpha1.PodSelectorSpec

+ func GetProcessClass(pod corev1.Pod) fdbv1beta2.ProcessClass

+ func GetProcessGroupID(pod corev1.Pod) fdbv1beta2.ProcessGroupID

+ func GetPvc(pod *corev1.Pod) string

+ func PodSelector(pod *corev1.Pod) chaosmeshv1alpha1.PodSelectorSpec

+ func PodsSelector(v1pods []corev1.Pod) chaosmeshv1alpha1.PodSelectorSpec

+ func RandStringRunes(n int) string

+ func RandomPickOnePod(input []corev1.Pod) corev1.Pod

+ func RandomPickPod(input []corev1.Pod, count int) []corev1.Pod

+ func RunGinkgoTests(t *testing.T, name string)

+ func ToJSON(v interface{}) string

+ func UseVersionBeforeUpgrade(factory *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ func VersionsAreProtocolCompatible(versionA string, versionB string) bool

+ func WithDNSEnabled(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ func WithLUnifiedImage(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ func WithLocalitiesForExclusion(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ func WithOneMinuteMinimumUptimeSecondsForBounce(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ func WithTLSEnabled(_ *Factory, cluster *fdbv1beta2.FoundationDBCluster)

+ type ChaosMeshExperiment struct

+ type ClusterConfig struct

+ CreationCallback func(fdbCluster *FdbCluster)

+ CreationTracker CreationTrackerLogger

+ CustomParameters map[fdbv1beta2.ProcessClass]fdbv1beta2.FoundationDBCustomParameters

+ DebugSymbols bool

+ DisksPerMachine int

+ HaMode HaMode

+ MachineCount int

+ Name string

+ Namespace string

+ NodeSelector map[string]string

+ Performance bool

+ StorageEngine fdbv1beta2.StorageEngine

+ StorageServerPerPod int

+ VolumeSize string

+ func DefaultClusterConfig(debugSymbols bool) *ClusterConfig

+ func DefaultClusterConfigWithHaMode(haMode HaMode, debugSymbols bool) *ClusterConfig

+ func (config *ClusterConfig) CalculateRoleCounts() fdbv1beta2.RoleCounts

+ func (config *ClusterConfig) CreateDatabaseConfiguration() fdbv1beta2.DatabaseConfiguration

+ func (config *ClusterConfig) SetDefaults(factory *Factory)

+ func (config ClusterConfig) GetRedundancyMode() fdbv1beta2.RedundancyMode

+ type ClusterOption func(*Factory, *fdbv1beta2.FoundationDBCluster)

+ type CreationTrackerLogger interface

+ Flush func() error

+ Log func(values map[string]interface{}) error

+ NewEntry func() map[string]interface{}

+ func NewDefaultCreationTrackerLogger() CreationTrackerLogger

+ type DefaultCreationTrackerLogger struct

+ func (logger *DefaultCreationTrackerLogger) Flush() error

+ func (logger *DefaultCreationTrackerLogger) Log(_ map[string]interface{}) error

+ func (logger *DefaultCreationTrackerLogger) NewEntry() map[string]interface{}

+ type Factory struct

+ func CreateFactory(options *FactoryOptions) *Factory

+ func (factory *Factory) AddShutdownHook(f func() error)

+ func (factory *Factory) ChaosTestsEnabled() bool

+ func (factory *Factory) CleanupChaosMeshExperiments() error

+ func (factory *Factory) CreateExperiment(chaos client.Object) *ChaosMeshExperiment

+ func (factory *Factory) CreateFDBOperatorIfAbsent(namespace string) error

+ func (factory *Factory) CreateFdbCluster(config *ClusterConfig, options ...ClusterOption) *FdbCluster

+ func (factory *Factory) CreateFdbHaCluster(config *ClusterConfig, options ...ClusterOption) *HaFdbCluster

+ func (factory *Factory) CreateIfAbsent(object client.Object) error

+ func (factory *Factory) DeleteChaosMeshExperimentSafe(experiment *ChaosMeshExperiment)

+ func (factory *Factory) DeletePod(pod *corev1.Pod)

+ func (factory *Factory) DoesPodExist(pod corev1.Pod) (bool, error)

+ func (factory *Factory) DumpState(fdbCluster *FdbCluster)

+ func (factory *Factory) DumpStateHaCluster(fdbCluster *HaFdbCluster)

+ func (factory *Factory) ExecuteCmd(namespace string, name string, container string, command string, ...) (string, string, error)

+ func (factory *Factory) ExecuteCmdOnPod(pod *corev1.Pod, container string, command string, printOutput bool) (string, string, error)

+ func (factory *Factory) ExecuteCommandRaw(namespace string, name string, container string, command []string, ...) error

+ func (factory *Factory) GetAdditionalSidecarVersions() []fdbv1beta2.Version

+ func (factory *Factory) GetBackupSecretName() string

+ func (factory *Factory) GetBeforeVersion() string

+ func (factory *Factory) GetChaosNamespace() string

+ func (factory *Factory) GetClusterOptions(options ...ClusterOption) []ClusterOption

+ func (factory *Factory) GetControllerRuntimeClient() client.Client

+ func (factory *Factory) GetDefaultLabels() map[string]string

+ func (factory *Factory) GetDefaultStorageClass() string

+ func (factory *Factory) GetFDBVersion() fdbv1beta2.Version

+ func (factory *Factory) GetFDBVersionAsString() string

+ func (factory *Factory) GetFoundationDBImage() string

+ func (factory *Factory) GetLogsFromPod(pod *corev1.Pod, container string) string

+ func (factory *Factory) GetOperatorImage() string

+ func (factory *Factory) GetOperatorPods(namespace string) *corev1.PodList

+ func (factory *Factory) GetPod(namespace string, name string) (*corev1.Pod, error)

+ func (factory *Factory) GetSecretName() string

+ func (factory *Factory) GetSidecarConfigs() []SidecarConfig

+ func (factory *Factory) GetSidecarImage() string

+ func (factory *Factory) GetStorageClasses(labels map[string]string) *storagev1.StorageClassList

+ func (factory *Factory) GetUpgradeVersions() []UpgradeTestConfiguration

+ func (factory *Factory) InjectDiskFailure(selector chaosmesh.PodSelectorSpec) *ChaosMeshExperiment

+ func (factory *Factory) InjectDiskFailureWithPath(selector chaosmesh.PodSelectorSpec, volumePath string, path string, ...) *ChaosMeshExperiment

+ func (factory *Factory) InjectHTTPClientChaosWrongResultFdbMonitorConf(selector chaosmeshv1alpha1.PodSelectorSpec, namespace string) *ChaosMeshExperiment

+ func (factory *Factory) InjectIOLatency(selector chaosmesh.PodSelectorSpec, delay string) *ChaosMeshExperiment

+ func (factory *Factory) InjectNetworkLoss(lossPercentage string, source chaosmesh.PodSelectorSpec, ...) *ChaosMeshExperiment

+ func (factory *Factory) InjectNetworkLossBetweenPods(pods []chaosmesh.PodSelectorSpec, loss string)

+ func (factory *Factory) InjectPartition(selector chaosmesh.PodSelectorSpec) *ChaosMeshExperiment

+ func (factory *Factory) InjectPartitionBetween(source chaosmesh.PodSelectorSpec, target chaosmesh.PodSelectorSpec) *ChaosMeshExperiment

+ func (factory *Factory) InjectPartitionOnSomeTargetPods(source chaosmesh.PodSelectorSpec, target chaosmesh.PodSelectorSpec, ...) *ChaosMeshExperiment

+ func (factory *Factory) MultipleNamespaces(dcIDs []string) []string

+ func (factory *Factory) OperatorIsAtLeast(version string) bool

+ func (factory *Factory) PrependRegistry(container string) string

+ func (factory *Factory) RecreateOperatorPods(namespace string)

+ func (factory *Factory) ScheduleInjectPodKill(target chaosmesh.PodSelectorSpec, schedule string, mode chaosmesh.SelectorMode) *ChaosMeshExperiment

+ func (factory *Factory) SetBeforeVersion(version string)

+ func (factory *Factory) SetFinalizerForPod(pod *corev1.Pod, finalizers []string) error

+ func (factory *Factory) Shutdown()

+ func (factory *Factory) SingleNamespace() string

+ func (factory *Factory) StopInvariantCheck()

+ func (factory *Factory) WaitUntilOperatorPodsRunning(namespace string)

+ type FactoryOptions struct

+ func InitFlags() *FactoryOptions

+ func (options *FactoryOptions) BindFlags(fs *flag.FlagSet)

+ type FdbCluster struct

+ func (fdbCluster *FdbCluster) AllProcessGroupsHaveCondition(condition fdbv1beta2.ProcessGroupConditionType) bool

+ func (fdbCluster *FdbCluster) BounceClusterWithoutWait() error

+ func (fdbCluster *FdbCluster) ClearBuggifyNoSchedule(waitForReconcile bool) error

+ func (fdbCluster *FdbCluster) ClearProcessGroupsToRemove() error

+ func (fdbCluster *FdbCluster) Create() error

+ func (fdbCluster *FdbCluster) Destroy() error

+ func (fdbCluster *FdbCluster) EnsurePodIsDeleted(podName string)

+ func (fdbCluster *FdbCluster) ExecuteCmdOnPod(pod corev1.Pod, container string, command string, printOutput bool) (string, string, error)

+ func (fdbCluster *FdbCluster) GetAllPods() *corev1.PodList

+ func (fdbCluster *FdbCluster) GetCachedCluster() *fdbv1beta2.FoundationDBCluster

+ func (fdbCluster *FdbCluster) GetCluster() *fdbv1beta2.FoundationDBCluster

+ func (fdbCluster *FdbCluster) GetClusterSpec() fdbv1beta2.FoundationDBClusterSpec

+ func (fdbCluster *FdbCluster) GetCoordinators() []corev1.Pod

+ func (fdbCluster *FdbCluster) GetCustomParameters(processClass fdbv1beta2.ProcessClass) fdbv1beta2.FoundationDBCustomParameters

+ func (fdbCluster *FdbCluster) GetFDBImage() string

+ func (fdbCluster *FdbCluster) GetLogPods() *corev1.PodList

+ func (fdbCluster *FdbCluster) GetPod(name string) *corev1.Pod

+ func (fdbCluster *FdbCluster) GetPodIDs(processClass fdbv1beta2.ProcessClass) map[fdbv1beta2.ProcessGroupID]fdbv1beta2.None

+ func (fdbCluster *FdbCluster) GetPodRoleMap() map[fdbv1beta2.ProcessGroupID][]RoleInfo

+ func (fdbCluster *FdbCluster) GetPods() *corev1.PodList

+ func (fdbCluster *FdbCluster) GetPodsNames() []string

+ func (fdbCluster *FdbCluster) GetPodsWithRole(role fdbv1beta2.ProcessRole) []corev1.Pod

+ func (fdbCluster *FdbCluster) GetProcessCount(targetRole fdbv1beta2.ProcessRole) int

+ func (fdbCluster *FdbCluster) GetProcessCounts() (fdbv1beta2.ProcessCounts, error)

+ func (fdbCluster *FdbCluster) GetResourceLabels() map[string]string

+ func (fdbCluster *FdbCluster) GetServices() *corev1.ServiceList

+ func (fdbCluster *FdbCluster) GetSidecarImageForVersion(version string) string

+ func (fdbCluster *FdbCluster) GetStatelessPods() *corev1.PodList

+ func (fdbCluster *FdbCluster) GetStoragePods() *corev1.PodList

+ func (fdbCluster *FdbCluster) GetStorageServerPerPod() int

+ func (fdbCluster *FdbCluster) GetVolumeClaimsForProcesses(processClass fdbv1beta2.ProcessClass) *corev1.PersistentVolumeClaimList

+ func (fdbCluster *FdbCluster) GetVolumeSize(processClass fdbv1beta2.ProcessClass) (resource.Quantity, error)

+ func (fdbCluster *FdbCluster) HasHeadlessService() bool

+ func (fdbCluster *FdbCluster) HasTLSEnabled() bool

+ func (fdbCluster *FdbCluster) IsAvailable() bool

+ func (fdbCluster *FdbCluster) Name() string

+ func (fdbCluster *FdbCluster) Namespace() string

+ func (fdbCluster *FdbCluster) ReplacePod(pod corev1.Pod, waitForReconcile bool)

+ func (fdbCluster *FdbCluster) ReplacePods(pods []corev1.Pod)

+ func (fdbCluster *FdbCluster) RunFdbCliCommandInOperator(command string, printOutput bool, timeout int) (string, string)

+ func (fdbCluster *FdbCluster) RunFdbCliCommandInOperatorWithoutRetry(command string, printOutput bool, timeout int) (string, string, error)

+ func (fdbCluster *FdbCluster) SetAutoReplacements(enabled bool, detectionTime time.Duration) error

+ func (fdbCluster *FdbCluster) SetAutoReplacementsWithWait(enabled bool, detectionTime time.Duration, wait bool) error

+ func (fdbCluster *FdbCluster) SetBuggifyBlockRemoval(blockRemovals []fdbv1beta2.ProcessGroupID)

+ func (fdbCluster *FdbCluster) SetCrashLoopContainers(crashLoopContainers []fdbv1beta2.CrashLoopContainerObject, ...)

+ func (fdbCluster *FdbCluster) SetCustomParameters(processClass fdbv1beta2.ProcessClass, ...) error

+ func (fdbCluster *FdbCluster) SetDatabaseConfiguration(config fdbv1beta2.DatabaseConfiguration, waitForReconcile bool) error

+ func (fdbCluster *FdbCluster) SetEmptyMonitorConf(enable bool) error

+ func (fdbCluster *FdbCluster) SetFinalizerForPvc(finalizers []string, pvc corev1.PersistentVolumeClaim) error

+ func (fdbCluster *FdbCluster) SetIgnoreDuringRestart(processes []fdbv1beta2.ProcessGroupID)

+ func (fdbCluster *FdbCluster) SetIgnoreMissingProcessesSeconds(duration time.Duration) error

+ func (fdbCluster *FdbCluster) SetKillProcesses(allowKill bool)

+ func (fdbCluster *FdbCluster) SetPodAsUnschedulable(pod corev1.Pod) error

+ func (fdbCluster *FdbCluster) SetProcessGroupPrefix(prefix string) error

+ func (fdbCluster *FdbCluster) SetPublicIPSource(publicIPSource fdbv1beta2.PublicIPSource) error

+ func (fdbCluster *FdbCluster) SetSkipReconciliation(skip bool) error

+ func (fdbCluster *FdbCluster) SetStorageServerPerPod(serverPerPod int) error

+ func (fdbCluster *FdbCluster) SetTLS(enableMainContainerTLS bool, enableSidecarContainerTLS bool) error

+ func (fdbCluster *FdbCluster) SetUseDNSInClusterFile(useDNSInClusterFile bool) error

+ func (fdbCluster *FdbCluster) SetVolumeSize(processClass fdbv1beta2.ProcessClass, size resource.Quantity) error

+ func (fdbCluster *FdbCluster) Update() error

+ func (fdbCluster *FdbCluster) UpdateClusterSpec()

+ func (fdbCluster *FdbCluster) UpdateClusterSpecWithSpec(desiredSpec *fdbv1beta2.FoundationDBClusterSpec)

+ func (fdbCluster *FdbCluster) UpdateContainerImage(pod *corev1.Pod, containerName string, image string)

+ func (fdbCluster *FdbCluster) UpdateCoordinatorSelection(setting []fdbv1beta2.CoordinatorSelectionSetting) error

+ func (fdbCluster *FdbCluster) UpdateLogProcessCount(newLogProcessCount int) error

+ func (fdbCluster *FdbCluster) UpdateStorageClass(storageClass string, processClass fdbv1beta2.ProcessClass) error

+ func (fdbCluster *FdbCluster) UpgradeCluster(version string, waitForReconciliation bool) error

+ func (fdbCluster *FdbCluster) WaitForPodRemoval(pod *corev1.Pod) error

+ func (fdbCluster *FdbCluster) WaitForReconciliation(options ...func(*ReconciliationOptions)) error

+ func (fdbCluster *FdbCluster) WaitUntilAvailable() error

+ func (fdbCluster *FdbCluster) WaitUntilExists()

+ func (fdbCluster FdbCluster) GetCommandlineForProcessesPerClass() map[fdbv1beta2.ProcessClass][]string

+ func (fdbCluster FdbCluster) GetStatus() *fdbv1beta2.FoundationDBStatus

+ func (fdbCluster FdbCluster) InvariantClusterStatusAvailable() error

+ func (fdbCluster FdbCluster) InvariantClusterStatusAvailableWithThreshold(availabilityThreshold time.Duration) error

+ func (fdbCluster FdbCluster) StatusInvariantChecker(name string, threshold time.Duration, ...) error

+ type HaFdbCluster struct

+ func (haFDBCluster *HaFdbCluster) Delete()

+ func (haFDBCluster *HaFdbCluster) DumpState()

+ func (haFDBCluster *HaFdbCluster) GetAllClusters() []*FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetCluster(suffix string) *FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetNamespaceSelector() v1alpha1.PodSelectorSpec

+ func (haFDBCluster *HaFdbCluster) GetNamespaces() []string

+ func (haFDBCluster *HaFdbCluster) GetPrimary() *FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetPrimarySatellite() *FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetRemote() *FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetRemoteSatellite() *FdbCluster

+ func (haFDBCluster *HaFdbCluster) GetSatellite() *FdbCluster

+ func (haFDBCluster *HaFdbCluster) SetCustomParameters(processClass fdbv1beta2.ProcessClass, ...) error

+ func (haFDBCluster *HaFdbCluster) SetDatabaseConfiguration(config fdbv1beta2.DatabaseConfiguration)

+ func (haFDBCluster *HaFdbCluster) UpgradeCluster(version string, waitForReconciliation bool) error

+ func (haFDBCluster *HaFdbCluster) UpgradeClusterWithTimeout(version string, waitForReconciliation bool, timeout int64) error

+ func (haFDBCluster *HaFdbCluster) WaitForReconciliation(options ...func(*ReconciliationOptions)) error

+ type HaMode int

+ const HaFourZoneDoubleSat

+ const HaFourZoneDoubleSatRF4

+ const HaFourZoneSingleSat

+ const HaModeNone

+ const HaThreeZoneDoubleSat

+ type ReconciliationOption func(*ReconciliationOptions)

+ func CreationTrackerLoggerOption(creationTrackerLogger CreationTrackerLogger) ReconciliationOption

+ func MinimumGenerationOption(minimumGeneration int64) ReconciliationOption

+ func PollTimeInSecondsOption(pollTimeInSeconds int64) ReconciliationOption

+ func SoftReconcileOption(enable bool) ReconciliationOption

+ func TimeOutInSecondsOption(timeOutInSeconds int64) ReconciliationOption

+ type ReconciliationOptions struct

+ func MakeReconciliationOptionsStruct(options ...func(*ReconciliationOptions)) *ReconciliationOptions

+ type RoleInfo struct

+ ID string

+ Role string

+ type ShutdownHooks struct

+ func (shutdown *ShutdownHooks) Defer(f func() error)

+ func (shutdown *ShutdownHooks) InvokeShutdownHandlers()

+ type SidecarConfig struct

+ BaseImage string

+ FDBVersion fdbv1beta2.Version

+ SidecarTag string

+ type UpgradeTestConfiguration struct

+ InitialVersion fdbv1beta2.Version

+ TargetVersion fdbv1beta2.Version

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