service

Documentation

Index

• type Agent
  • func New(l *zap.Logger) *Agent
  • func (a *Agent) Close() error
  • func (a *Agent) Start() error
• type Collector
• type Etcd
  • func (e *Etcd) Close()
  • func (e *Etcd) Get()
  • func (e *Etcd) Init() error
  • func (e *Etcd) Put(key, value string, ttl int64) error
  • func (e *Etcd) Start() error
• type Pinpoint
  • func (p *Pinpoint) AgentInfo() error
  • func (p *Pinpoint) AgentSpan() error
  • func (p *Pinpoint) AgentStat() error
  • func (p *Pinpoint) Close() error
  • func (p *Pinpoint) Start() error
• type SyncCall
  • func NewSyncCall() *SyncCall
• type System
  • func (s *System) Close() error
  • func (s *System) Start() error

Types

type Agent

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

Agent ...

func New

func New(l *zap.Logger) *Agent

New new agent

func (*Agent) Close

func (a *Agent) Close() error

Close 关闭

func (*Agent) Start

func (a *Agent) Start() error

Start 启动

type Collector

type Collector struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Collector 收集器

type Etcd

type Etcd struct {
	Client *clientv3.Client
	Grant  *clientv3.LeaseGrantResponse
	StopC  chan bool
}

Etcd struct,report udp listen addr

func (*Etcd) Close

func (e *Etcd) Close()

Close stop ereport

func (*Etcd) Get

func (e *Etcd) Get()

Get Get

func (*Etcd) Init

func (e *Etcd) Init() error

Init init Etcd

func (*Etcd) Put

func (e *Etcd) Put(key, value string, ttl int64) error

Put put

func (*Etcd) Start

func (e *Etcd) Start() error

Start start ereport thread

type Pinpoint

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

Pinpoint p数据采集

func (*Pinpoint) AgentInfo

func (p *Pinpoint) AgentInfo() error

AgentInfo ...

func (*Pinpoint) AgentSpan

func (p *Pinpoint) AgentSpan() error

AgentSpan ...

func (*Pinpoint) AgentStat

func (p *Pinpoint) AgentStat() error

AgentStat ...

func (*Pinpoint) Close

func (p *Pinpoint) Close() error

Close 关闭pinpoint采集服务

func (*Pinpoint) Start

func (p *Pinpoint) Start() error

Start 启动pinpoint采集服务

type SyncCall

type SyncCall struct {
	sync.RWMutex
	Chans map[uint32]chan *network.TracePack
}

SyncCall ...

func NewSyncCall

func NewSyncCall() *SyncCall

NewSyncCall ...

type System

type System struct {
}

System 系统信息采集服务

func (*System) Close

func (s *System) Close() error

Close 关闭系统采集服务

func (*System) Start

func (s *System) Start() error

Start 启动系统采集服务