Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2023 Changes in this version + const GiB + const KiB + const MiB + const TiB + type APIKeyTransport struct + APIKey string + APIKeyID string + func (t *APIKeyTransport) RoundTrip(r *http.Request) (*http.Response, error) + type BaseMongoConf struct + MongoDBType MongoType + MongoSSLAllowInvalidHostnames bool + MongoSSLCAFile string + MongoSSLInsecureSkipVerify bool + MongoSSLPEMKeyfile string + MongoURL string + MongoUseSSL bool + type CSVConf struct + CSVDir string + type CSVPump struct + func (c *CSVPump) GetName() string + func (c *CSVPump) Init(conf interface{}) error + func (c *CSVPump) New() Pump + func (c *CSVPump) WriteData(ctx context.Context, data []interface{}) error + type CommonPumpConfig struct + OmitDetailedRecording bool + func (p *CommonPumpConfig) GetFilters() analytics.AnalyticsFilters + func (p *CommonPumpConfig) GetOmitDetailedRecording() bool + func (p *CommonPumpConfig) GetTimeout() int + func (p *CommonPumpConfig) SetFilters(filters analytics.AnalyticsFilters) + func (p *CommonPumpConfig) SetOmitDetailedRecording(omitDetailedRecording bool) + func (p *CommonPumpConfig) SetTimeout(timeout int) + type DummyPump struct + func (p *DummyPump) GetName() string + func (p *DummyPump) Init(conf interface{}) error + func (p *DummyPump) New() Pump + func (p *DummyPump) WriteData(ctx context.Context, data []interface{}) error + type Elasticsearch7Operator struct + type ElasticsearchBulkConfig struct + BulkActions int + BulkSize int + FlushInterval int + Workers int + type ElasticsearchConf struct + AuthAPIKey string + AuthAPIKeyID string + BulkConfig ElasticsearchBulkConfig + DisableBulk bool + DocumentType string + ElasticsearchURL string + EnableSniffing bool + IndexName string + Password string + RollingIndex bool + Username string + type ElasticsearchOperator interface + type ElasticsearchPump struct + func (e *ElasticsearchPump) GetName() string + func (e *ElasticsearchPump) Init(config interface{}) error + func (e *ElasticsearchPump) New() Pump + func (e *ElasticsearchPump) WriteData(ctx context.Context, data []interface{}) error + type InfluxConf struct + Addr string + DatabaseName string + Fields []string + Password string + Tags []string + Username string + type InfluxPump struct + func (i *InfluxPump) GetName() string + func (i *InfluxPump) Init(config interface{}) error + func (i *InfluxPump) New() Pump + func (i *InfluxPump) WriteData(ctx context.Context, data []interface{}) error + type KafkaConf struct + Algorithm string + Broker []string + ClientID string + Compressed bool + MetaData map[string]string + Password string + SASLMechanism string + SSLCertFile string + SSLInsecureSkipVerify bool + SSLKeyFile string + Timeout time.Duration + Topic string + UseSSL bool + Username string + type KafkaPump struct + func (k *KafkaPump) GetName() string + func (k *KafkaPump) Init(config interface{}) error + func (k *KafkaPump) New() Pump + func (k *KafkaPump) WriteData(ctx context.Context, data []interface{}) error + type Message map[string]interface + type MongoConf struct + CollectionCapEnable bool + CollectionCapMaxSizeBytes int + CollectionName string + MaxDocumentSizeBytes int + MaxInsertBatchSizeBytes int + type MongoPump struct + func (m *MongoPump) AccumulateSet(data []interface{}) [][]interface{} + func (m *MongoPump) GetName() string + func (m *MongoPump) Init(config interface{}) error + func (m *MongoPump) New() Pump + func (m *MongoPump) WriteData(ctx context.Context, data []interface{}) error + type MongoType int + const AWSDocumentDB + const StandardMongo + type PrometheusConf struct + Addr string + Path string + type PrometheusPump struct + TotalStatusMetrics *prometheus.CounterVec + func (p *PrometheusPump) GetName() string + func (p *PrometheusPump) Init(conf interface{}) error + func (p *PrometheusPump) New() Pump + func (p *PrometheusPump) WriteData(ctx context.Context, data []interface{}) error + type Pump interface + GetFilters func() analytics.AnalyticsFilters + GetName func() string + GetOmitDetailedRecording func() bool + GetTimeout func() int + Init func(interface{}) error + New func() Pump + SetFilters func(analytics.AnalyticsFilters) + SetOmitDetailedRecording func(bool) + SetTimeout func(timeout int) + WriteData func(context.Context, []interface{}) error + func GetPumpByName(name string) (Pump, error) + type SyslogConf struct + LogLevel int + NetworkAddr string + Tag string + Transport string + type SyslogPump struct + func (s *SyslogPump) GetFilters() analytics.AnalyticsFilters + func (s *SyslogPump) GetName() string + func (s *SyslogPump) GetTimeout() int + func (s *SyslogPump) Init(config interface{}) error + func (s *SyslogPump) New() Pump + func (s *SyslogPump) SetFilters(filters analytics.AnalyticsFilters) + func (s *SyslogPump) SetTimeout(timeout int) + func (s *SyslogPump) WriteData(ctx context.Context, data []interface{}) error
Go to main page