agent

Documentation

Index

• type Agent
  • func New(ff ...Setter) (*Agent, error)
  • func (a *Agent) Start(ctx context.Context)
  • func (a *Agent) Stop()
• type Option
• type ReceiveProfileReq
• type Setter
  • func WithAllocsProfiling(en bool) Setter
  • func WithBlockProfiling(en bool) Setter
  • func WithBreakPeriod(d time.Duration) Setter
  • func WithCPUProfiling(en bool, d time.Duration) Setter
  • func WithCollectorAddr(addr string) Setter
  • func WithGoroutineProfiling(en bool) Setter
  • func WithHeapProfiling(en bool) Setter
  • func WithMutexProfiling(en bool) Setter
  • func WithService(service string, serviceVersion string) Setter
  • func WithThreadCreateProfiling(en bool) Setter

Types

type Agent

type Agent struct {
	// contains filtered or unexported fields
}

func New

func New(ff ...Setter) (*Agent, error)

func (*Agent) Start

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

func (*Agent) Stop

func (a *Agent) Stop()

type Option

type Option struct {
	CollectorAddr  string
	Service        string
	ServiceVersion string

	BreakPeriod           time.Duration
	CPUProfiling          bool `profile:"cpu"`
	CPUProfilingPeriod    time.Duration
	HeapProfiling         bool `profile:"heap"`
	AllocsProfiling       bool `profile:"allocs"`
	BlockProfiling        bool `profile:"block"`
	MutexProfiling        bool `profile:"mutex"`
	GoroutineProfiling    bool `profile:"goroutine"`
	ThreadCreateProfiling bool `profile:"threadcreate"`
	// contains filtered or unexported fields
}

type ReceiveProfileReq

type ReceiveProfileReq struct {
	Service        string `json:"service"`
	ServiceVersion string `json:"service_version"`
	Host           string `json:"host"`
	GoVersion      string `json:"go_version"`
	ProfileType    string `json:"profile_type"`
	Profile        string `json:"profile"`
	SendTime       int64  `json:"send_time"`
	CreateTime     int64  `json:"create_time"`
}

type Setter

type Setter func(o *Option) error

func WithAllocsProfiling

func WithAllocsProfiling(en bool) Setter

func WithBlockProfiling

func WithBlockProfiling(en bool) Setter

func WithBreakPeriod

func WithBreakPeriod(d time.Duration) Setter

func WithCPUProfiling

func WithCPUProfiling(en bool, d time.Duration) Setter

func WithCollectorAddr

func WithCollectorAddr(addr string) Setter

func WithGoroutineProfiling

func WithGoroutineProfiling(en bool) Setter

func WithHeapProfiling

func WithHeapProfiling(en bool) Setter

func WithMutexProfiling

func WithMutexProfiling(en bool) Setter

func WithService

func WithService(service string, serviceVersion string) Setter

func WithThreadCreateProfiling

func WithThreadCreateProfiling(en bool) Setter