beater

package

v0.0.0-...-8a44fb0 Latest Latest Go to latest Published: Jul 24, 2022 License: MIT, MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var Registrar *registrar.Registrar

func AckEvents(data []interface{})

AckEvents 用于处理libeat发送事件后的回调，确保事件至少发送一次

type LogBeat struct {
	Name string
	// contains filtered or unexported fields
}

LogBeat package cadvisor

func New(rawConfig *beat.Config) (*LogBeat, error)

New create cadvisor beat

func (bt *LogBeat) Close() error

Close cadvisor storage interface

func (bt *LogBeat) PublishEvent(event beat.MapStr) bool

PublishEvent ISender interface

func (bt *LogBeat) Reload(c *beat.Config)

Reload beater interface

func (bt *LogBeat) Run() error

Run beater interface

func (bt *LogBeat) Stop()

Stop beater interface

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

Manager: 任务管理 1. 读取采集任务 2. 管理任务生命周期：创建、删除

func NewManager(config cfg.Config, beatDone chan struct{}) (*Manager, error)

create new manager

func (m *Manager) Reload(config cfg.Config)

Reload : diff config, create, remove, update jobs

func (m *Manager) Start() error

Run start and link modules

func (m *Manager) Stop() error

Close manager when program quit