agent

Documentation

Index

• Constants
• Variables
• func Capture(conf *AgentConf)
• type AgentConf
  • func NewConf() *AgentConf
  • func (d *AgentConf) MergeWithFileAtPath(path string) error
  • func (d *AgentConf) MergeWithReader(src io.Reader) error
• type MetricData
  • func (h *MetricData) Datum() cloudwatch.MetricDatum
  • func (h *MetricData) Key() string
  • func (h *MetricData) Update(point *MetricData)
• type Samples

Constants

const (
	OP_AVG = "avg"
	OP_SUM = "sum"
	OP_MAX = "max"
	OP_MIN = "min"
)

Variables

var L, _ = syslog.New(syslog.LOG_INFO, "SYCWAGENT")

var (
	VERSION string
)

var W sync.WaitGroup

Functions

func Capture

func Capture(conf *AgentConf)

Start the data capture

The agent will listen for incoming messages on port 1234 (by default) via UDP/IP socket

Types

type AgentConf

type AgentConf struct {
	Key     string
	Secret  string
	Region  string
	Address string
	Port    int
	Loop    int
}

func NewConf

func NewConf() *AgentConf

Prepare a new agent configuration

The default parameters are

• REGION: eu-west-1
• ADDRESS: 127.0.0.1
• PORT: 1234
• LOOP: 60

func (*AgentConf) MergeWithFileAtPath

func (d *AgentConf) MergeWithFileAtPath(path string) error

Merge default configuration with a JSON configuration

func (*AgentConf) MergeWithReader

func (d *AgentConf) MergeWithReader(src io.Reader) error

Merge default configuration with a JSON configuration

type MetricData

type MetricData struct {
	Namespace string
	Metric    string
	Unit      string
	Value     float64
	Op        string
}

func (*MetricData) Datum

func (h *MetricData) Datum() cloudwatch.MetricDatum

func (*MetricData) Key

func (h *MetricData) Key() string

func (*MetricData) Update

func (h *MetricData) Update(point *MetricData)

type Samples

type Samples struct {
	sync.Mutex
	// contains filtered or unexported fields
}