beater

Documentation

Index

• Variables
• func AckEvents(data []interface{})
• func GetRawConfig() (*common.Config, error)
• type LogBeat
  • func New(rawConfig *beat.Config) (*LogBeat, error)
  • func (bt *LogBeat) Close() error
  • func (bt *LogBeat) ParseConfig(rawConfig *beat.Config) error
  • func (bt *LogBeat) PublishEvent(event beat.MapStr) bool
  • func (bt *LogBeat) Reload(c *beat.Config)
  • func (bt *LogBeat) Run() error
  • func (bt *LogBeat) Stop()
• type Manager
  • func NewManager(config cfg.Config, beatDone chan struct{}) (*Manager, error)
  • func (m *Manager) Reload(config cfg.Config)
  • func (m *Manager) Start() error
  • func (m *Manager) Stop() error

Variables

var Registrar *registrar.Registrar

Functions

func AckEvents

func AckEvents(data []interface{})

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

func GetRawConfig

func GetRawConfig() (*common.Config, error)

GetRawConfig Get raw main config

Types

type LogBeat

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

LogBeat package cadvisor

func New

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

New create cadvisor beat

func (*LogBeat) Close

func (bt *LogBeat) Close() error

Close cadvisor storage interface

func (*LogBeat) ParseConfig

func (bt *LogBeat) ParseConfig(rawConfig *beat.Config) error

func (*LogBeat) PublishEvent

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

PublishEvent ISender interface

func (*LogBeat) Reload

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

Reload beater interface

func (*LogBeat) Run

func (bt *LogBeat) Run() error

Run beater interface

func (*LogBeat) Stop

func (bt *LogBeat) Stop()

Stop beater interface

type Manager

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

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

func NewManager

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

NewManager create new manager

func (*Manager) Reload

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

Reload diff config, create, remove, update jobs

func (*Manager) Start

func (m *Manager) Start() error

Start Run start and link modules

func (*Manager) Stop

func (m *Manager) Stop() error

Stop Close manager when program quit