agent

Documentation

Index

• 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
  • 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 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
  • func (r *Retry) Check(err error) (bool, error)
  • func (r *Retry) Do(fn func() error) (err error)

Functions

func Cancel

func Cancel(err error) error

func Do

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

func DoAttempts

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

Types

type Agent

type Agent struct {
	CPUProfile           bool
	CPUProfileDuration   time.Duration
	TraceProfile         bool
	TraceProfileDuration time.Duration
	HeapProfile          bool
	BlockProfile         bool
	MutexProfile         bool
	GoroutineProfile     bool
	ThreadcreateProfile  bool
	// contains filtered or unexported fields
}

func New

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

func Start

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

func (*Agent) Start

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

func (*Agent) Stop

func (a *Agent) Stop() error

type Option

type Option func(a *Agent)

func WithBlockProfile

func WithBlockProfile() Option

func WithCPUProfile

func WithCPUProfile(duration time.Duration) Option

func WithGoroutineProfile

func WithGoroutineProfile() Option

func WithHTTPClient

func WithHTTPClient(c *http.Client) Option

func WithHeapProfile

func WithHeapProfile() Option

func WithLabels

func WithLabels(args ...string) Option

func WithLogger

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

func WithMutexProfile

func WithMutexProfile() Option

func WithThreadcreateProfile

func WithThreadcreateProfile() Option

func WithTickInterval

func WithTickInterval(interval time.Duration) Option

func WithTraceProfile

func WithTraceProfile(duration time.Duration) Option

type Retry

type Retry struct {
	MinDelay    time.Duration
	MaxDelay    time.Duration
	MaxAttempts int
}

func (*Retry) Check

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

func (*Retry) Do

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