Documentation
¶
Index ¶
- func BuildDimensions(mTags map[string]string) []*cloudwatch.Dimension
- func GetUniqueRollupList(inputLists [][]string) [][]string
- type Aggregator
- type CloudWatch
- func (c *CloudWatch) BuildMetricDatum(point telegraf.Metric) []*cloudwatch.MetricDatum
- func (c *CloudWatch) Close() error
- func (c *CloudWatch) Connect() error
- func (c *CloudWatch) Description() string
- func (c *CloudWatch) ProcessRollup(rawDimension []*cloudwatch.Dimension) [][]*cloudwatch.Dimension
- func (c *CloudWatch) SampleConfig() string
- func (c *CloudWatch) Write(metrics []telegraf.Metric) error
- func (c *CloudWatch) WriteToCloudWatch(req interface{})
- type MetricDatumBatch
- type MetricDecorationConfig
- type MetricDecorations
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildDimensions ¶
func BuildDimensions(mTags map[string]string) []*cloudwatch.Dimension
Make a list of Dimensions by using a Point's tags. CloudWatch supports up to 10 dimensions per metric so we only keep up to the first 10 alphabetically. This always includes the "host" tag if it exists.
func GetUniqueRollupList ¶
Types ¶
type Aggregator ¶
func NewAggregator ¶
func NewAggregator(metricChan chan<- telegraf.Metric, shutdownChan <-chan struct{}, wg *sync.WaitGroup) Aggregator
type CloudWatch ¶
type CloudWatch struct {
Region string `toml:"region"`
EndpointOverride string `toml:"endpoint_override"`
AccessKey string `toml:"access_key"`
SecretKey string `toml:"secret_key"`
RoleARN string `toml:"role_arn"`
Profile string `toml:"profile"`
Filename string `toml:"shared_credential_file"`
Token string `toml:"token"`
ForceFlushInterval internal.Duration `toml:"force_flush_interval"` // unit is second
MaxDatumsPerCall int `toml:"max_datums_per_call"`
MaxValuesPerDatum int `toml:"max_values_per_datum"`
MetricConfigs []MetricDecorationConfig `toml:"metric_decoration"`
RollupDimensions [][]string `toml:"rollup_dimensions"`
Namespace string `toml:"namespace"` // CloudWatch Metrics Namespace
Log telegraf.Logger `toml:"-"`
// contains filtered or unexported fields
}
func (*CloudWatch) BuildMetricDatum ¶
func (c *CloudWatch) BuildMetricDatum(point telegraf.Metric) []*cloudwatch.MetricDatum
Create MetricDatums according to metric roll up requirement for each field in a Point. Only fields with values that can be converted to float64 are supported. Non-supported fields are skipped.
func (*CloudWatch) Close ¶
func (c *CloudWatch) Close() error
func (*CloudWatch) Connect ¶
func (c *CloudWatch) Connect() error
func (*CloudWatch) Description ¶
func (c *CloudWatch) Description() string
func (*CloudWatch) ProcessRollup ¶
func (c *CloudWatch) ProcessRollup(rawDimension []*cloudwatch.Dimension) [][]*cloudwatch.Dimension
func (*CloudWatch) SampleConfig ¶
func (c *CloudWatch) SampleConfig() string
func (*CloudWatch) WriteToCloudWatch ¶
func (c *CloudWatch) WriteToCloudWatch(req interface{})
type MetricDatumBatch ¶
type MetricDatumBatch struct {
MaxDatumsPerCall int
Partition []*cloudwatch.MetricDatum
BeginTime time.Time
Size int
// contains filtered or unexported fields
}
type MetricDecorationConfig ¶
type MetricDecorations ¶
type MetricDecorations struct {
// contains filtered or unexported fields
}
func NewMetricDecorations ¶
func NewMetricDecorations(metricConfigs []MetricDecorationConfig) (*MetricDecorations, error)
Click to show internal directories.
Click to hide internal directories.