Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultKubernetesTimeout = 2 * time.Second DefaultArangoDTimeout = time.Second * 5 DefaultArangoDAgencyTimeout = time.Second * 10 DefaultArangoDCheckTimeout = time.Second * 2 DefaultReconciliationTimeout = time.Minute DefaultForcePodDeletionGracePeriodTimeout = 15 * time.Minute DefaultPodSchedulingGracePeriod = 15 * time.Second BackupDefaultArangoClientTimeout = 30 * time.Second BackupUploadArangoClientTimeout = 300 * time.Second // DefaultOutSyncedShardRebuildTimeout // timeout after which particular out-synced shard is considered as failed and rebuild is triggered DefaultOutSyncedShardRebuildTimeout = time.Minute * 60 // DefaultOutSyncedShardRebuildRetryTimeout timeout after which rebuild shards retry flow is triggered DefaultOutSyncedShardRebuildRetryTimeout = time.Hour * 4 DefaultKubernetesRequestBatchSize = 256 DefaultBackupConcurrentUploads = 4 DefaultOperatorUpdateRetryCount = 25 DefaultOperatorUpdateRetryDelay = time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GlobalBackup ¶
type GlobalBackup interface {
ConcurrentUploads() Int
}
type GlobalKubernetes ¶
type GlobalKubernetes interface {
RequestBatchSize() Int64
}
type GlobalRetry ¶
type GlobalTimeouts ¶
type GlobalTimeouts interface {
Reconciliation() Timeout
ShardRebuild() Timeout
ShardRebuildRetry() Timeout
Kubernetes() Timeout
ArangoD() Timeout
ArangoDCheck() Timeout
Agency() Timeout
ForcePodDeletionGracePeriodTimeout() Timeout
PodSchedulingGracePeriod() Timeout
BackupArangoClientTimeout() Timeout
BackupArangoClientUploadTimeout() Timeout
}
func GetGlobalTimeouts ¶
func GetGlobalTimeouts() GlobalTimeouts
type Globals ¶
type Globals interface {
Timeouts() GlobalTimeouts
Kubernetes() GlobalKubernetes
Backup() GlobalBackup
Retry() GlobalRetry
}
func GetGlobals ¶
func GetGlobals() Globals
type Timeout ¶
type Timeout interface {
Set(duration time.Duration)
Get() time.Duration
WithTimeout(ctx context.Context) (context.Context, context.CancelFunc)
Run(run TimeoutRunFunc) error
RunWithTimeout(ctx context.Context, run TimeoutRunFunc) error
}
func NewTimeout ¶
type TimeoutRunFunc ¶
Click to show internal directories.
Click to hide internal directories.