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.