systemmonitoring

Documentation

Index

• Constants
• func New(ctx context.Context, gatewayCfg *gwTY.Config) (providerTY.Plugin, error)
• type Provider
  • func (p *Provider) Close() error
  • func (p *Provider) ConvertToMessages(rawMsg *msgTY.RawMessage) ([]*msgTY.Message, error)
  • func (p *Provider) HostID() (string, error)
  • func (p *Provider) Name() string
  • func (p *Provider) Post(msg *msgTY.Message) error
  • func (p *Provider) Start(rxMessageFunc func(rawMsg *msgTY.RawMessage) error) error

Constants

const (
	KiB = 1 << (10 * (iota + 1)) // Kibibytes
	MiB = 1 << (10 * (iota + 1)) // Mibibytes
	GiB = 1 << (10 * (iota + 1)) // Gibibytes
	TiB = 1 << (10 * (iota + 1)) // Tebibytes
	PiB = 1 << (10 * (iota + 1)) // Pebibytes
	EiB = 1 << (10 * (iota + 1)) // Exbibytes
)

const (
	NodeDetailMetricInterval = "5m"
)

const (
	PluginSystemMonitoring = "system_monitoring"
)

Functions

func New

func New(ctx context.Context, gatewayCfg *gwTY.Config) (providerTY.Plugin, error)

system monitoring provider

Types

type Provider

type Provider struct {
	Config        config.Config
	HostConfig    *config.HostConfig
	GatewayConfig *gwTY.Config
	NodeID        string
	// contains filtered or unexported fields
}

Provider data

func (*Provider) Close

func (p *Provider) Close() error

Close func

func (*Provider) ConvertToMessages

func (p *Provider) ConvertToMessages(rawMsg *msgTY.RawMessage) ([]*msgTY.Message, error)

ConvertToMessages implementation

func (*Provider) HostID

func (p *Provider) HostID() (string, error)

func (*Provider) Name

func (p *Provider) Name() string

func (*Provider) Post

func (p *Provider) Post(msg *msgTY.Message) error

Post func

func (*Provider) Start

func (p *Provider) Start(rxMessageFunc func(rawMsg *msgTY.RawMessage) error) error

Start func