agent

Mar 16, 2020

Changes in this version

+ func Cancel(err error) error

+ func Do(minDelay, maxDelay time.Duration, fn func() error) error

+ func DoAttempts(minDelay, maxDelay time.Duration, attempts int, fn func() error) error

+ type Agent struct

+ BlockProfile bool

+ CPUProfile bool

+ CPUProfileDuration time.Duration

+ GoroutineProfile bool

+ HeapProfile bool

+ MutexProfile bool

+ ThreadcreateProfile bool

+ TraceProfile bool

+ TraceProfileDuration time.Duration

+ func New(addr, service string, opts ...Option) *Agent

+ func Start(addr, service string, opts ...Option) (*Agent, error)

+ func (a *Agent) Start(ctx context.Context) error

+ func (a *Agent) Stop() error

+ type Option func(a *Agent)

+ func WithBlockProfile() Option

+ func WithCPUProfile(duration time.Duration) Option

+ func WithGoroutineProfile() Option

+ func WithHTTPClient(c *http.Client) Option

+ func WithHeapProfile() Option

+ func WithLabels(args ...string) Option

+ func WithLogger(logf func(string, ...interface{})) Option

+ func WithMutexProfile() Option

+ func WithThreadcreateProfile() Option

+ func WithTickInterval(interval time.Duration) Option

+ func WithTraceProfile(duration time.Duration) Option

+ type Retry struct

+ MaxAttempts int

+ MaxDelay time.Duration

+ MinDelay time.Duration

+ func (r *Retry) Check(err error) (bool, error)

+ func (r *Retry) Do(fn func() error) (err error)