agent

Documentation

Index

• func Cancel(err error) error
• func DoRetry(minDelay, maxDelay time.Duration, fn func() error) error
• func DoRetryAttempts(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(tick 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 DoRetry

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

func DoRetryAttempts

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

Types

type Agent

type Agent struct {
	CPUProfile          bool
	CPUProfileDuration  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(tick 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)