mpawskinesisstreams

package
v0.29.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 26, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Examples

Constants

This section is empty.

Variables

This section is empty.

Functions

func Do

func Do()

Do the plugin

Types

type KinesisStreamsPlugin

type KinesisStreamsPlugin struct {
	Name   string
	Prefix string

	AccessKeyID     string
	SecretAccessKey string
	Region          string
	CloudWatch      *cloudwatch.CloudWatch
}

KinesisStreamsPlugin mackerel plugin for aws kinesis

func (KinesisStreamsPlugin) FetchMetrics

func (p KinesisStreamsPlugin) FetchMetrics() (map[string]interface{}, error)

FetchMetrics fetch the metrics

func (KinesisStreamsPlugin) GraphDefinition

func (p KinesisStreamsPlugin) GraphDefinition() map[string]mp.Graphs

GraphDefinition of KinesisStreamsPlugin

Example
var kinesis KinesisStreamsPlugin
kinesis.Prefix = "my-stream"
helper := mp.NewMackerelPlugin(kinesis)
helper.OutputDefinitions()
Output:

# mackerel-agent-plugin
{"graphs":{"my-stream.bytes":{"label":"My Stream Bytes","unit":"integer","metrics":[{"name":"GetRecordsBytes","label":"GetRecords","stacked":false},{"name":"IncomingBytes","label":"Total Incoming","stacked":false},{"name":"PutRecordBytes","label":"PutRecord","stacked":false},{"name":"PutRecordsBytes","label":"PutRecords","stacked":false}]},"my-stream.iteratorage":{"label":"My Stream Read Delay","unit":"integer","metrics":[{"name":"GetRecordsDelayAverageMilliseconds","label":"Average","stacked":false},{"name":"GetRecordsDelayMaxMilliseconds","label":"Max","stacked":false},{"name":"GetRecordsDelayMinMilliseconds","label":"Min","stacked":false}]},"my-stream.latency":{"label":"My Stream Operation Latency","unit":"integer","metrics":[{"name":"GetRecordsLatency","label":"GetRecords","stacked":false},{"name":"PutRecordLatency","label":"PutRecord","stacked":false},{"name":"PutRecordsLatency","label":"PutRecords","stacked":false}]},"my-stream.pending":{"label":"My Stream Pending Operations","unit":"integer","metrics":[{"name":"ReadThroughputExceeded","label":"Read","stacked":false},{"name":"WriteThroughputExceeded","label":"Write","stacked":false}]},"my-stream.records":{"label":"My Stream Records","unit":"integer","metrics":[{"name":"GetRecordsRecords","label":"GetRecords","stacked":false},{"name":"IncomingRecords","label":"Total Incoming","stacked":false},{"name":"PutRecordsRecords","label":"PutRecords","stacked":false}]},"my-stream.success":{"label":"My Stream Operation Success","unit":"integer","metrics":[{"name":"GetRecordsSuccess","label":"GetRecords","stacked":false},{"name":"PutRecordSuccess","label":"PutRecord","stacked":false},{"name":"PutRecordsSuccess","label":"PutRecords","stacked":false}]}}}

func (KinesisStreamsPlugin) MetricKeyPrefix

func (p KinesisStreamsPlugin) MetricKeyPrefix() string

MetricKeyPrefix interface for PluginWithPrefix

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL