mock

package

Go to main page

Versions in this module

v1

v1.52.0

Nov 15, 2024

Changes in this version

type AdminClient

+ func (client *AdminClient) KillProcessesForUpgrade(addresses []fdbv1beta2.ProcessAddress) error

v1.51.0

Nov 1, 2024

v1.50.0

Oct 18, 2024

v1.49.0

Oct 4, 2024

v1.48.0

Sep 20, 2024

v1.47.0

Sep 5, 2024

Changes in this version

type DatabaseClientProvider

+ func (p DatabaseClientProvider) GetAdminClientWithLogger(cluster *fdbv1beta2.FoundationDBCluster, kubernetesClient client.Client, ...) (fdbadminclient.AdminClient, error)

+ func (p DatabaseClientProvider) GetLockClientWithLogger(cluster *fdbv1beta2.FoundationDBCluster, _ logr.Logger) (fdbadminclient.LockClient, error)

v1.46.0

Aug 23, 2024

v1.45.0

Aug 9, 2024

v1.44.0

Jul 26, 2024

v1.43.0

Jul 15, 2024

Changes in this version

type AdminClient

+ func (client *AdminClient) GetVersionFromReachableCoordinators() string

v1.42.0

Jun 28, 2024

v1.41.0

Jun 17, 2024

v1.40.0

Jun 3, 2024

v1.39.0

May 17, 2024

v1.38.0

May 8, 2024

v1.37.0

Apr 19, 2024

v1.36.0

Apr 5, 2024

v1.35.0

Mar 25, 2024

Changes in this version

type AdminClient

+ func (client *AdminClient) GetProcessesUnderMaintenance() (map[fdbv1beta2.ProcessGroupID]int64, error)

+ func (client *AdminClient) RemoveProcessesUnderMaintenance(ids []fdbv1beta2.ProcessGroupID) error

+ func (client *AdminClient) SetProcessesUnderMaintenance(ids []fdbv1beta2.ProcessGroupID, timestamp int64) error

v1.34.0

Mar 9, 2024

v1.33.0

Jan 29, 2024

v1.32.0

Jan 29, 2024

v1.31.0

Jan 12, 2024

v1.30.0

Dec 15, 2023

v1.29.0

Dec 1, 2023

v1.28.1

Nov 13, 2023

Changes in this version

type AdminClient

+ func (client *AdminClient) SetTimeout(_ time.Duration)

v1.28.0

Nov 8, 2023

v1.27.0

Oct 23, 2023

v1.26.0

Oct 9, 2023

v1.25.0

Sep 22, 2023

Changes in this version

type LockClient

+ func (client *LockClient) ReleaseLock() error

v1.24.0

Sep 5, 2023

v1.23.0

Aug 15, 2023

v1.22.0

Jul 28, 2023

v1.21.0

Jul 14, 2023

v1.20.1

Jul 6, 2023

Changes in this version

type AdminClient

+ func (client *AdminClient) WithValues(_ ...interface{})

v1.20.0

Jun 30, 2023

Changes in this version

type AdminClient

+ LagInfo map[string]fdbv1beta2.FoundationDBStatusLagInfo

+ Logs []fdbv1beta2.FoundationDBStatusLogInfo

+ TeamTracker []fdbv1beta2.FoundationDBStatusTeamTracker

+ func (client *AdminClient) GetLimitingDurabilityLag() (fdbv1beta2.FoundationDBStatusLagInfo, bool)

+ func (client *AdminClient) GetWorstDataLag() (fdbv1beta2.FoundationDBStatusLagInfo, bool)

+ func (client *AdminClient) GetWorstDurabilityLag() (fdbv1beta2.FoundationDBStatusLagInfo, bool)

+ func (client *AdminClient) MockError(err error)

+ func (client *AdminClient) SetLimitingDurabilityLag(lagInfo *fdbv1beta2.FoundationDBStatusLagInfo)

+ func (client *AdminClient) SetWorstDataLag(lagInfo *fdbv1beta2.FoundationDBStatusLagInfo)

+ func (client *AdminClient) SetWorstDurabilityLag(lagInfo *fdbv1beta2.FoundationDBStatusLagInfo)

v1.19.0

Jun 16, 2023

v1.18.0

Jun 1, 2023

v1.17.0

May 6, 2023

v1.16.0

Mar 26, 2023

Changes in this version

type AdminClient

+ func (client *AdminClient) MockMissingLocalities(processGroupID fdbv1beta2.ProcessGroupID, missingLocalities bool)

v1.15.0

Mar 14, 2023

v1.14.0

Feb 14, 2023

v1.13.0

Jan 31, 2023

Changes in this version

type AdminClient

+ VersionProcessGroups map[string]string

v1.12.0

Jan 17, 2023

v1.11.0

Dec 9, 2022

v1.10.0

Dec 5, 2022

Changes in this version

+ func ClearMockAdminClients()

+ func ClearMockLockClients()

+ func NewMockAdminClient(cluster *fdbv1beta2.FoundationDBCluster, kubeClient client.Client) (fdbadminclient.AdminClient, error)

+ func NewMockLockClient(cluster *fdbv1beta2.FoundationDBCluster) (fdbadminclient.LockClient, error)

+ type AdminClient struct

+ Backups map[string]fdbv1beta2.FoundationDBBackupStatusBackupDetails

+ Cluster *fdbv1beta2.FoundationDBCluster

+ DatabaseConfiguration *fdbv1beta2.DatabaseConfiguration

+ ExcludedAddresses []string

+ FrozenStatus *fdbv1beta2.FoundationDBStatus

+ KilledAddresses []string

+ Knobs []string

+ KubeClient client.Client

+ MaintenanceZone string

+ MaxZoneFailuresWithoutLosingAvailability *int

+ MaxZoneFailuresWithoutLosingData *int

+ ReincludedAddresses map[string]bool

+ func NewMockAdminClientUncast(cluster *fdbv1beta2.FoundationDBCluster, kubeClient client.Client) (*AdminClient, error)

+ func (client *AdminClient) CanSafelyRemove(addresses []fdbv1beta2.ProcessAddress) ([]fdbv1beta2.ProcessAddress, error)

+ func (client *AdminClient) ChangeCoordinators(addresses []fdbv1beta2.ProcessAddress) (string, error)

+ func (client *AdminClient) Close() error

+ func (client *AdminClient) ConfigureDatabase(configuration fdbv1beta2.DatabaseConfiguration, _ bool, version string) error

+ func (client *AdminClient) ExcludeProcesses(addresses []fdbv1beta2.ProcessAddress) error

+ func (client *AdminClient) FreezeStatus() error

+ func (client *AdminClient) GetBackupStatus() (*fdbv1beta2.FoundationDBLiveBackupStatus, error)

+ func (client *AdminClient) GetConnectionString() (string, error)

+ func (client *AdminClient) GetCoordinatorSet() (map[string]struct{}, error)

+ func (client *AdminClient) GetExclusions() ([]fdbv1beta2.ProcessAddress, error)

+ func (client *AdminClient) GetMaintenanceZone() (string, error)

+ func (client *AdminClient) GetProtocolVersion(version string) (string, error)

+ func (client *AdminClient) GetRestoreStatus() (string, error)

+ func (client *AdminClient) GetStatus() (*fdbv1beta2.FoundationDBStatus, error)

+ func (client *AdminClient) IncludeProcesses(addresses []fdbv1beta2.ProcessAddress) error

+ func (client *AdminClient) KillProcesses(addresses []fdbv1beta2.ProcessAddress) error

+ func (client *AdminClient) MockAdditionalProcesses(processes []fdbv1beta2.ProcessGroupStatus)

+ func (client *AdminClient) MockClientVersion(version string, clients []string)

+ func (client *AdminClient) MockIncorrectCommandLine(processGroupID string, incorrect bool)

+ func (client *AdminClient) MockLocalityInfo(processGroupID string, locality map[string]string)

+ func (client *AdminClient) MockMissingProcessGroup(processGroupID string, missing bool)

+ func (client *AdminClient) MockUptimeSecondsForMaintenanceZone(seconds float64)

+ func (client *AdminClient) ModifyBackup(snapshotPeriodSeconds int) error

+ func (client *AdminClient) PauseBackups() error

+ func (client *AdminClient) ResetMaintenanceMode() error

+ func (client *AdminClient) ResumeBackups() error

+ func (client *AdminClient) SetKnobs(knobs []string)

+ func (client *AdminClient) SetMaintenanceZone(zone string, _ int) error

+ func (client *AdminClient) StartBackup(url string, snapshotPeriodSeconds int) error

+ func (client *AdminClient) StartRestore(url string, _ []fdbv1beta2.FoundationDBKeyRange) error

+ func (client *AdminClient) StopBackup(url string) error

+ func (client *AdminClient) UnfreezeStatus()

+ func (client *AdminClient) VersionSupported(versionString string) (bool, error)

+ type DatabaseClientProvider struct

+ func (p DatabaseClientProvider) GetAdminClient(cluster *fdbv1beta2.FoundationDBCluster, kubernetesClient client.Client) (fdbadminclient.AdminClient, error)

+ func (p DatabaseClientProvider) GetLockClient(cluster *fdbv1beta2.FoundationDBCluster) (fdbadminclient.LockClient, error)

+ type LockClient struct

+ func NewMockLockClientUncast(cluster *fdbv1beta2.FoundationDBCluster) *LockClient

+ func (client *LockClient) AddPendingUpgrades(version fdbv1beta2.Version, processGroupIDs []string) error

+ func (client *LockClient) ClearPendingUpgrades() error

+ func (client *LockClient) Disabled() bool

+ func (client *LockClient) GetDenyList() ([]string, error)

+ func (client *LockClient) GetPendingUpgrades(version fdbv1beta2.Version) (map[string]bool, error)

+ func (client *LockClient) TakeLock() (bool, error)

+ func (client *LockClient) UpdateDenyList(locks []fdbv1beta2.LockDenyListEntry) error

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