awscsm

Documentation

Index

• type CSM
  • func (c *CSM) Close() error
  • func (c *CSM) Connect() error
  • func (c *CSM) Description() string
  • func (c *CSM) SampleConfig() string
  • func (c *CSM) Write(ms []telegraf.Metric) error
• type CSMWriter
  • func NewCSMWriter(svc csmiface.CSMAPI, env csm.HostEnvironment) *CSMWriter
  • func (writer *CSMWriter) Write(metrics metametrics.Metrics) error

Types

type CSM

type CSM struct {
	Region          string `toml:"region"`
	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"`
	MemoryLimitInMb int    `toml:"memory_limit_in_mb"`
	LogLevel        int    `toml:"log_level"`

	EndpointOverride string `toml:"endpoint_override"`
	// contains filtered or unexported fields
}

CSM structure houses the configuration retrieved from the configuration file. This also contains the sdkmetrics dataplane client which will be used to put aggregated metrics to.

func (*CSM) Close

func (c *CSM) Close() error

Close will flush remaining metrics in the queue

func (*CSM) Connect

func (c *CSM) Connect() error

Connect will bootstrap the client and add the user agent handler.

func (*CSM) Description

func (c *CSM) Description() string

Description will return the description of the CSM output plugin

func (*CSM) SampleConfig

func (c *CSM) SampleConfig() string

SampleConfig returns the sample config

func (*CSM) Write

func (c *CSM) Write(ms []telegraf.Metric) error

Write ...

type CSMWriter

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

CSMWriter used for the metametrics listener

func NewCSMWriter

func NewCSMWriter(svc csmiface.CSMAPI, env csm.HostEnvironment) *CSMWriter

NewCSMWriter return a new CSM writer

func (*CSMWriter) Write

func (writer *CSMWriter) Write(metrics metametrics.Metrics) error