Documentation ¶
Index ¶
- Variables
- func Run(ctx context.Context, configPath string) error
- func RunAtOnce(ctx context.Context, configPath string) error
- type CheckPlugin
- type CheckResult
- type CloudWatchMetricPlugin
- func (mp *CloudWatchMetricPlugin) Command() []string
- func (mp *CloudWatchMetricPlugin) Enqueue(metrics []*Metric)
- func (mp *CloudWatchMetricPlugin) ID() string
- func (mp *CloudWatchMetricPlugin) Interval() time.Duration
- func (cmp *CloudWatchMetricPlugin) ParseMetricLine(b string) (*Metric, error)
- func (mp *CloudWatchMetricPlugin) Timeout() time.Duration
- type Config
- type Dimension
- type MackerelMetricPlugin
- func (mp *MackerelMetricPlugin) Command() []string
- func (mp *MackerelMetricPlugin) Enqueue(metrics []*Metric)
- func (mp *MackerelMetricPlugin) ID() string
- func (mp *MackerelMetricPlugin) Interval() time.Duration
- func (mp *MackerelMetricPlugin) ParseMetricLine(b string) (*Metric, error)
- func (mp *MackerelMetricPlugin) Timeout() time.Duration
- type Metric
- type MetricPlugin
- type PluginConfig
- type ServiceMetric
Constants ¶
This section is empty.
Variables ¶
Functions ¶
Types ¶
type CheckPlugin ¶
type CheckPlugin struct { ID string Namespace string Command []string Timeout time.Duration Interval time.Duration Dimensions [][]types.Dimension }
func (*CheckPlugin) Execute ¶
func (cp *CheckPlugin) Execute(ctx context.Context) (CheckResult, error)
func (*CheckPlugin) Run ¶
func (cp *CheckPlugin) Run(ctx context.Context, wg *sync.WaitGroup, ch chan *cloudwatch.PutMetricDataInput)
func (*CheckPlugin) RunAtOnce ¶ added in v0.4.0
func (cp *CheckPlugin) RunAtOnce(ctx context.Context, ch chan *cloudwatch.PutMetricDataInput) error
type CheckResult ¶
type CheckResult int
const ( CheckOK CheckResult = iota CheckFailed CheckWarning CheckUnknown )
func (CheckResult) NewMetricDatum ¶
func (r CheckResult) NewMetricDatum(ds []types.Dimension, ts time.Time) types.MetricDatum
func (CheckResult) String ¶
func (i CheckResult) String() string
type CloudWatchMetricPlugin ¶ added in v0.1.0
type CloudWatchMetricPlugin struct { Dimensions [][]types.Dimension Ch chan *cloudwatch.PutMetricDataInput // contains filtered or unexported fields }
func (*CloudWatchMetricPlugin) Command ¶ added in v0.1.0
func (mp *CloudWatchMetricPlugin) Command() []string
func (*CloudWatchMetricPlugin) Enqueue ¶ added in v0.1.0
func (mp *CloudWatchMetricPlugin) Enqueue(metrics []*Metric)
func (*CloudWatchMetricPlugin) ID ¶ added in v0.1.0
func (mp *CloudWatchMetricPlugin) ID() string
func (*CloudWatchMetricPlugin) Interval ¶ added in v0.1.0
func (mp *CloudWatchMetricPlugin) Interval() time.Duration
func (*CloudWatchMetricPlugin) ParseMetricLine ¶ added in v0.1.0
func (cmp *CloudWatchMetricPlugin) ParseMetricLine(b string) (*Metric, error)
func (*CloudWatchMetricPlugin) Timeout ¶ added in v0.1.0
func (mp *CloudWatchMetricPlugin) Timeout() time.Duration
type Config ¶
type Config struct { Plugin map[string]map[string]*PluginConfig CheckPlugins map[string]*CheckPlugin MetricPlugins map[string]MetricPlugin }
type MackerelMetricPlugin ¶ added in v0.1.0
type MackerelMetricPlugin struct { Service string Ch chan ServiceMetric // contains filtered or unexported fields }
func (*MackerelMetricPlugin) Command ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) Command() []string
func (*MackerelMetricPlugin) Enqueue ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) Enqueue(metrics []*Metric)
func (*MackerelMetricPlugin) ID ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) ID() string
func (*MackerelMetricPlugin) Interval ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) Interval() time.Duration
func (*MackerelMetricPlugin) ParseMetricLine ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) ParseMetricLine(b string) (*Metric, error)
func (*MackerelMetricPlugin) Timeout ¶ added in v0.1.0
func (mp *MackerelMetricPlugin) Timeout() time.Duration
type Metric ¶
func (*Metric) NewMetricDatum ¶
func (m *Metric) NewMetricDatum(ds []types.Dimension) types.MetricDatum
type MetricPlugin ¶
type PluginConfig ¶
type PluginConfig struct { Namespace string Command string Timeout duration Interval duration Dimensions []*Dimension Destination string Service string }
func (*PluginConfig) NewCheckPlugin ¶
func (pc *PluginConfig) NewCheckPlugin(id string) (*CheckPlugin, error)
func (*PluginConfig) NewCloudWatchMetricPlugin ¶ added in v0.1.0
func (pc *PluginConfig) NewCloudWatchMetricPlugin(id string) (*CloudWatchMetricPlugin, error)
func (*PluginConfig) NewMackerelMetricPlugin ¶ added in v0.1.0
func (pc *PluginConfig) NewMackerelMetricPlugin(id string) (*MackerelMetricPlugin, error)
type ServiceMetric ¶ added in v0.1.0
type ServiceMetric struct { Service string MetricValues []*mackerel.MetricValue }
Click to show internal directories.
Click to hide internal directories.