 Documentation
      ¶
      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.