Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pacer

package

Go to main page

Versions in this module

v1

v1.48.0

Jun 15, 2019

v1.47.0

Apr 13, 2019

Changes in this version

+ func IsRetryAfter(err error) (retryAfter time.Duration, isRetryAfter bool)

+ func RetryAfterError(err error, retryAfter time.Duration) error

+ type AmazonCloudDrive struct

+ func NewAmazonCloudDrive(opts ...AmazonCloudDriveOption) *AmazonCloudDrive

+ func (c *AmazonCloudDrive) Calculate(state State) time.Duration

+ func (c *AmazonCloudDrive) Update(opts ...AmazonCloudDriveOption)

+ type AmazonCloudDriveOption interface

+ ApplyAmazonCloudDrive func(*AmazonCloudDrive)

+ type AttackConstant uint

+ func (o AttackConstant) ApplyDefault(c *Default)

+ func (o AttackConstant) ApplyS3(c *S3)

+ type Burst int

+ func (o Burst) ApplyGoogleDrive(c *GoogleDrive)

+ type Calculator interface

+ Calculate func(state State) time.Duration

+ type DecayConstant uint

+ func (o DecayConstant) ApplyDefault(c *Default)

+ func (o DecayConstant) ApplyS3(c *S3)

+ type Default struct

+ func NewDefault(opts ...DefaultOption) *Default

+ func (c *Default) Calculate(state State) time.Duration

+ func (c *Default) Update(opts ...DefaultOption)

+ type DefaultOption interface

+ ApplyDefault func(*Default)

+ type GoogleDrive struct

+ func NewGoogleDrive(opts ...GoogleDriveOption) *GoogleDrive

+ func (c *GoogleDrive) Calculate(state State) time.Duration

+ func (c *GoogleDrive) Update(opts ...GoogleDriveOption)

+ type GoogleDriveOption interface

+ ApplyGoogleDrive func(*GoogleDrive)

+ type InvokerFunc func(try, tries int, f Paced) (bool, error)

+ type MaxSleep time.Duration

+ func (o MaxSleep) ApplyDefault(c *Default)

+ func (o MaxSleep) ApplyS3(c *S3)

+ type MinSleep time.Duration

+ func (o MinSleep) ApplyAmazonCloudDrive(c *AmazonCloudDrive)

+ func (o MinSleep) ApplyDefault(c *Default)

+ func (o MinSleep) ApplyGoogleDrive(c *GoogleDrive)

+ func (o MinSleep) ApplyS3(c *S3)

+ type Option func(*pacerOptions)

+ func CalculatorOption(c Calculator) Option

+ func InvokerOption(invoker InvokerFunc) Option

+ func MaxConnectionsOption(maxConnections int) Option

+ func RetriesOption(retries int) Option

type Pacer

+ func (p *Pacer) ModifyCalculator(f func(Calculator))

+ func (p *Pacer) SetCalculator(c Calculator)

+ type S3 struct

+ func NewS3(opts ...S3Option) *S3

+ func (c *S3) Calculate(state State) time.Duration

+ func (c *S3) Update(opts ...S3Option)

+ type S3Option interface

+ ApplyS3 func(*S3)

+ type State struct

+ ConsecutiveRetries int

+ LastError error

+ SleepTime time.Duration

v1.46.0

Feb 9, 2019

Changes in this version

+ const S3Pacer

type Pacer

+ func (p *Pacer) SetBurst(n int) *Pacer

v1.43.1

Sep 7, 2018

Changes in this version

+ const AmazonCloudDrivePacer

+ const DefaultPacer

+ const GoogleDrivePacer

+ type Paced func() (bool, error)

+ type Pacer struct

+ func New() *Pacer

+ func (p *Pacer) Call(fn Paced) (err error)

+ func (p *Pacer) CallNoRetry(fn Paced) error

+ func (p *Pacer) GetSleep() time.Duration

+ func (p *Pacer) SetAttackConstant(attack uint) *Pacer

+ func (p *Pacer) SetDecayConstant(decay uint) *Pacer

+ func (p *Pacer) SetMaxConnections(n int) *Pacer

+ func (p *Pacer) SetMaxSleep(t time.Duration) *Pacer

+ func (p *Pacer) SetMinSleep(t time.Duration) *Pacer

+ func (p *Pacer) SetPacer(t Type) *Pacer

+ func (p *Pacer) SetRetries(retries int) *Pacer

+ func (p *Pacer) SetSleep(t time.Duration) *Pacer

+ type TokenDispenser struct

+ func NewTokenDispenser(n int) *TokenDispenser

+ func (td *TokenDispenser) Get()

+ func (td *TokenDispenser) Put()

+ type Type int