migrate

Documentation

Index

• func AddRule(rule Rule)
• func AwsCsmRule(conf map[string]interface{}) error
• func CloudWatchLogsRule(conf map[string]interface{}) error
• func CommonConfigRule(conf map[string]interface{}) error
• func DiskIORule(conf map[string]interface{}) error
• func Ec2TaggerRule(conf map[string]interface{}) error
• func EthtoolRule(conf map[string]interface{}) error
• func InputDiskRule(conf map[string]interface{}) error
• func IsOldConfig(path string) (bool, error)
• func LogFileRule(conf map[string]interface{}) error
• func LogTargetRule(conf map[string]interface{}) error
• func Migrate(conf map[string]interface{}) error
• func MigrateFile(path string) (string, error)
• func NetRule(conf map[string]interface{}) error
• func ProcStatRule(conf map[string]interface{}) error
• func WindowsEventLogRule(conf map[string]interface{}) error
• type Rule

Functions

func AddRule

func AddRule(rule Rule)

func AwsCsmRule

func AwsCsmRule(conf map[string]interface{}) error

[agent]

• enable_csm_reflection = true [[inputs.awscsm_listener]]
• data_format = "aws_csm"

func CloudWatchLogsRule

func CloudWatchLogsRule(conf map[string]interface{}) error

[outputs]

[[outputs.cloudwatchlogs]]

- destination = "cloudwatchlogs"

func CommonConfigRule

func CommonConfigRule(conf map[string]interface{}) error

[agent]

- aws_ca_bundle = "/etc/test/ca_bundle.pem" - http_proxy = "http://127.0.0.1:3280" - https_proxy = "https://127.0.0.1:3280" - no_proxy = "254.1.1.1"

func DiskIORule

func DiskIORule(conf map[string]interface{}) error

[inputs]
  [[inputs.diskio]]
    fieldpass = ["io_time", "write_bytes", "read_bytes", "writes", "reads"]

• report_deltas = true [inputs.diskio.tags] metricPath = "metrics"

• report_deltas = "true"

  [processors]

+ [[processors.delta]]

func Ec2TaggerRule

func Ec2TaggerRule(conf map[string]interface{}) error

[processors] [[processors.ec2tagger]] * refresh_interval_seconds = "0s" // changed from 'refresh_interval_seconds = "2147483647s"'

func EthtoolRule

func EthtoolRule(conf map[string]interface{}) error

[inputs]
  [[inputs.ethtool]]

• fieldpass = ["bw_in_allowance_exceeded", "bw_out_allowance_exceeded", "pps_allowance_exceeded", "conntrack_allowance_exceeded", "linklocal_allowance_exceeded"] interface_include = ["eth0", "eth1"]
• metrics_include = ["bw_in_allowance_exceeded", "bw_out_allowance_exceeded", "pps_allowance_exceeded", "conntrack_allowance_exceeded", "linklocal_allowance_exceeded"] [inputs.ethtool.tags] metricPath = "metrics"

func InputDiskRule

func InputDiskRule(conf map[string]interface{}) error

[inputs] [[inputs.disk]] - drop_device = false + tagexclude = ["mode"]

func IsOldConfig

func IsOldConfig(path string) (bool, error)

func LogFileRule

func LogFileRule(conf map[string]interface{}) error

[inputs]

[[inputs.tail]]

+ destination = "cloudwatchlogs" - data_format = "value" - data_type = "string" - name_override = "raw_log_line"

func LogTargetRule

func LogTargetRule(conf map[string]interface{}) error

[agent] + logtarget = "lumberjack"

func Migrate

func Migrate(conf map[string]interface{}) error

func MigrateFile

func MigrateFile(path string) (string, error)

func NetRule

func NetRule(conf map[string]interface{}) error

[[inputs.net]]
  fieldpass = ["bytes_sent", "bytes_recv", "drop_in", "drop_out"]
  interfaces = ["eth0"]

• report_deltas = true [inputs.net.tags] "aws:StorageResolution" = "true" metricPath = "metrics"

• report_deltas = "true"

  [processors]

+ [[processors.delta]]

func ProcStatRule

func ProcStatRule(conf map[string]interface{}) error

[inputs]
[[inputs.procstat]]
  fieldpass = ["cpu_usage", "memory_rss"]
  pid_file = "/var/run/example1.pid"
  pid_finder = "native"

+ tagexclude = ["user", "result"]

func WindowsEventLogRule

func WindowsEventLogRule(conf map[string]interface{}) error

[inputs]

[[inputs.windows_event_log]]

+ destination = "cloudwatchlogs"

Types

type Rule

type Rule func(map[string]interface{}) error