Documentation
¶
Index ¶
- type Config
- type InfluxDBOutput
- func (i *InfluxDBOutput) Close() error
- func (i *InfluxDBOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
- func (i *InfluxDBOutput) RegisterMetrics(reg *prometheus.Registry)
- func (i *InfluxDBOutput) SetClusterName(name string)
- func (i *InfluxDBOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...)
- func (i *InfluxDBOutput) SetLogger(logger *log.Logger)
- func (i *InfluxDBOutput) SetName(name string)
- func (i *InfluxDBOutput) SetTargetsConfig(map[string]*types.TargetConfig)
- func (k *InfluxDBOutput) String() string
- func (i *InfluxDBOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)
- func (i *InfluxDBOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
URL string `mapstructure:"url,omitempty"`
Org string `mapstructure:"org,omitempty"`
Bucket string `mapstructure:"bucket,omitempty"`
Token string `mapstructure:"token,omitempty"`
BatchSize uint `mapstructure:"batch-size,omitempty"`
FlushTimer time.Duration `mapstructure:"flush-timer,omitempty"`
UseGzip bool `mapstructure:"use-gzip,omitempty"`
EnableTLS bool `mapstructure:"enable-tls,omitempty"`
HealthCheckPeriod time.Duration `mapstructure:"health-check-period,omitempty"`
Debug bool `mapstructure:"debug,omitempty"`
AddTarget string `mapstructure:"add-target,omitempty"`
TargetTemplate string `mapstructure:"target-template,omitempty"`
EventProcessors []string `mapstructure:"event-processors,omitempty"`
EnableMetrics bool `mapstructure:"enable-metrics,omitempty"`
OverrideTimestamps bool `mapstructure:"override-timestamps,omitempty"`
GnmiCacheConfig *cache.GnmiCacheConfig `mapstructure:"cache,omitempty"`
CacheFlushTimer time.Duration `mapstructure:"cache-flush-timer,omitempty"`
}
type InfluxDBOutput ¶
type InfluxDBOutput struct {
Cfg *Config
// contains filtered or unexported fields
}
func (*InfluxDBOutput) Close ¶
func (i *InfluxDBOutput) Close() error
func (*InfluxDBOutput) RegisterMetrics ¶ added in v0.7.0
func (i *InfluxDBOutput) RegisterMetrics(reg *prometheus.Registry)
func (*InfluxDBOutput) SetClusterName ¶ added in v0.8.0
func (i *InfluxDBOutput) SetClusterName(name string)
func (*InfluxDBOutput) SetEventProcessors ¶ added in v0.6.0
func (i *InfluxDBOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, tcs map[string]*types.TargetConfig, acts map[string]map[string]interface{})
func (*InfluxDBOutput) SetLogger ¶ added in v0.5.2
func (i *InfluxDBOutput) SetLogger(logger *log.Logger)
func (*InfluxDBOutput) SetName ¶ added in v0.7.0
func (i *InfluxDBOutput) SetName(name string)
func (*InfluxDBOutput) SetTargetsConfig ¶ added in v0.18.0
func (i *InfluxDBOutput) SetTargetsConfig(map[string]*types.TargetConfig)
func (*InfluxDBOutput) String ¶
func (k *InfluxDBOutput) String() string
func (*InfluxDBOutput) WriteEvent ¶ added in v0.7.0
func (i *InfluxDBOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)
Source Files
Click to show internal directories.
Click to hide internal directories.