Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchConcurrent ¶
func BatchLinear ¶
func SleepWithExponentialBackoff ¶
SleepWithExponentialBackoff sleeps for a duration calculated using exponential backoff and jitter, based on the retry count. The base sleep time and maximum sleep time are provided as inputs. retryCount determines the exponential backoff multiplier.
Types ¶
type OperationPool ¶
type OperationPool struct {
// contains filtered or unexported fields
}
func NewOperationPool ¶
func (*OperationPool) GetOperation ¶
func (p *OperationPool) GetOperation(id string) *SerialOperation
func (*OperationPool) RunOrContinue ¶
func (p *OperationPool) RunOrContinue(id string)
func (*OperationPool) SetTenants ¶
func (p *OperationPool) SetTenants(tenants []*dbsqlc.Tenant)
type SerialOperation ¶
type SerialOperation struct {
// contains filtered or unexported fields
}
SerialOperation represents a method that can only run serially.
func (*SerialOperation) Run ¶
func (o *SerialOperation) Run(ql *zerolog.Logger)
func (*SerialOperation) RunOrContinue ¶
func (o *SerialOperation) RunOrContinue(ql *zerolog.Logger)
Source Files
Click to show internal directories.
Click to hide internal directories.