aos

Documentation

Index

• type Aos
  • func (aos *Aos) Description() string
  • func (aos *Aos) Gather(_ telegraf.Accumulator) error
  • func (aos *Aos) RefreshData()
  • func (aos *Aos) SampleConfig() string
  • func (aos *Aos) Start(acc telegraf.Accumulator) error
  • func (aos *Aos) Stop()
• type StreamAos
  • func (ssl *StreamAos) ExtractAlertData(alertType string, tags map[string]string, alertData interface{}, raised bool)
  • func (ssl *StreamAos) ExtractProbeData(newProbeMessage interface{}, originName string)
  • func (ssl *StreamAos) GetTags(deviceKey string) map[string]string
  • func (ssl *StreamAos) MsgReader(r io.Reader)

Types

type Aos

type Aos struct {
	Port          int
	Address       string
	StreamingType []string

	AosServer   string
	AosPort     int
	AosLogin    string
	AosPassword string
	AosProtocol string

	RefreshInterval int

	telegraf.Accumulator
	io.Closer
	// contains filtered or unexported fields
}

---------------------------------------------------------------- Aos "Class" ----------------------------------------------------------------

func (*Aos) Description

func (aos *Aos) Description() string

func (*Aos) Gather

func (aos *Aos) Gather(_ telegraf.Accumulator) error

func (*Aos) RefreshData

func (aos *Aos) RefreshData()

Continuous Query that will refresh data every 15 sec

func (*Aos) SampleConfig

func (aos *Aos) SampleConfig() string

func (*Aos) Start

func (aos *Aos) Start(acc telegraf.Accumulator) error

func (*Aos) Stop

func (aos *Aos) Stop()

type StreamAos

type StreamAos struct {
	net.Listener
	*Aos
}

---------------------------------------------------------------- StreamAos "Class" ----------------------------------------------------------------

func (*StreamAos) ExtractAlertData

func (ssl *StreamAos) ExtractAlertData(alertType string, tags map[string]string, alertData interface{}, raised bool)

func (*StreamAos) ExtractProbeData

func (ssl *StreamAos) ExtractProbeData(newProbeMessage interface{}, originName string)

func (*StreamAos) GetTags

func (ssl *StreamAos) GetTags(deviceKey string) map[string]string

func (*StreamAos) MsgReader

func (ssl *StreamAos) MsgReader(r io.Reader)