pumps

package

Go to main page

Versions in this module

v0

v0.8.5

Apr 6, 2020

Changes in this version

+ type BaseMongoConf struct

+ MongoDBType MongoType

+ MongoSSLAllowInvalidHostnames bool

+ MongoSSLCAFile string

+ MongoSSLInsecureSkipVerify bool

+ MongoSSLPEMKeyfile string

+ MongoURL string

+ MongoUseSSL bool

type CSVPump

+ func (c *CSVPump) GetTimeout() int

+ func (c *CSVPump) SetTimeout(timeout int)

type DogStatsdPump

+ func (s *DogStatsdPump) GetTimeout() int

+ func (s *DogStatsdPump) SetTimeout(timeout int)

type DummyPump

+ func (p *DummyPump) GetTimeout() int

+ func (p *DummyPump) SetTimeout(timeout int)

+ type ElasticsearchBulkConfig struct

+ BulkActions int

+ BulkSize int

+ FlushInterval int

+ Workers int

type ElasticsearchConf

+ BulkConfig ElasticsearchBulkConfig

+ DisableBulk bool

type ElasticsearchPump

+ func (e *ElasticsearchPump) GetTimeout() int

+ func (e *ElasticsearchPump) SetTimeout(timeout int)

type GraylogPump

+ func (p *GraylogPump) GetTimeout() int

+ func (p *GraylogPump) SetTimeout(timeout int)

type HybridPump

+ func (p *HybridPump) GetTimeout() int

+ func (p *HybridPump) SetTimeout(timeout int)

type InfluxPump

+ func (i *InfluxPump) GetTimeout() int

+ func (i *InfluxPump) SetTimeout(timeout int)

type KafkaPump

+ func (k *KafkaPump) GetTimeout() int

+ func (k *KafkaPump) SetTimeout(timeout int)

type LogzioPump

+ func (p *LogzioPump) GetTimeout() int

+ func (p *LogzioPump) SetTimeout(timeout int)

type MoesifPump

+ func (p *MoesifPump) GetTimeout() int

+ func (p *MoesifPump) SetTimeout(timeout int)

type MongoAggregatePump

+ func (m *MongoAggregatePump) GetTimeout() int

+ func (m *MongoAggregatePump) SetTimeout(timeout int)

type MongoPump

+ func (m *MongoPump) GetTimeout() int

+ func (m *MongoPump) SetTimeout(timeout int)

type MongoSelectivePump

+ func (m *MongoSelectivePump) GetTimeout() int

+ func (m *MongoSelectivePump) SetTimeout(timeout int)

+ type MongoType int

+ const AWSDocumentDB

+ const StandardMongo

type PrometheusPump

+ func (p *PrometheusPump) GetTimeout() int

+ func (p *PrometheusPump) SetTimeout(timeout int)

type Pump

+ GetTimeout func() int

+ SetTimeout func(timeout int)

type SegmentPump

+ func (s *SegmentPump) GetTimeout() int

+ func (s *SegmentPump) SetTimeout(timeout int)

type SplunkPump

+ func (s *SplunkPump) GetTimeout() int

+ func (s *SplunkPump) SetTimeout(timeout int)

type StatsdPump

+ func (s *StatsdPump) GetTimeout() int

+ func (s *StatsdPump) SetTimeout(timeout int)

v0.8.4

Jan 30, 2020

Changes in this version

+ const GiB

+ const KiB

+ const LogzioPumpName

+ const LogzioPumpPrefix

+ const MiB

+ const TiB

+ var AvailablePumps map[string]Pump

+ var COMMON_TAGS_COUNT = 5

+ var THRESHOLD_LEN_TAG_LIST = 1000

+ func NewLogzioClient(conf *LogzioPumpConfig) (*lg.LogzioSender, error)

+ 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(data []interface{}) error

+ type DogStatsdConf struct

+ Address string

+ AsyncUDS bool

+ AsyncUDSWriteTimeout int

+ Buffered bool

+ BufferedMaxMessages int

+ Namespace string

+ SampleRate float64

+ type DogStatsdPump struct

+ func (s *DogStatsdPump) GetName() string

+ func (s *DogStatsdPump) Init(conf interface{}) error

+ func (s *DogStatsdPump) New() Pump

+ func (s *DogStatsdPump) WriteData(data []interface{}) error

+ type DummyPump struct

+ func (p *DummyPump) GetName() string

+ func (p *DummyPump) Init(conf interface{}) error

+ func (p *DummyPump) New() Pump

+ func (p *DummyPump) WriteData(data []interface{}) error

+ type Elasticsearch3Operator struct

+ type Elasticsearch5Operator struct

+ type Elasticsearch6Operator struct

+ type ElasticsearchConf struct

+ DecodeBase64 bool

+ DocumentType string

+ ElasticsearchURL string

+ EnableSniffing bool

+ ExtendedStatistics bool

+ GenerateID bool

+ IndexName string

+ RollingIndex bool

+ Version 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(data []interface{}) error

+ type GraylogConf struct

+ GraylogHost string

+ GraylogPort int

+ Tags []string

+ type GraylogPump struct

+ func (p *GraylogPump) GetName() string

+ func (p *GraylogPump) Init(conf interface{}) error

+ func (p *GraylogPump) New() Pump

+ func (p *GraylogPump) WriteData(data []interface{}) error

+ type GroupLoginRequest struct

+ GroupID string

+ UserKey string

+ type HybridPump struct

+ func (p *HybridPump) GetName() string

+ func (p *HybridPump) Init(config interface{}) error

+ func (p *HybridPump) New() Pump

+ func (p *HybridPump) WriteData(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(data []interface{}) error

+ type Json map[string]interface

+ type KafkaConf struct

+ Broker []string

+ ClientId string

+ Compressed bool

+ MetaData map[string]string

+ SSLInsecureSkipVerify bool

+ Timeout time.Duration

+ Topic string

+ UseSSL bool

+ type KafkaPump struct

+ func (k *KafkaPump) GetName() string

+ func (k *KafkaPump) Init(config interface{}) error

+ func (k *KafkaPump) New() Pump

+ func (k *KafkaPump) WriteData(data []interface{}) error

+ type LogzioPump struct

+ func (p *LogzioPump) GetName() string

+ func (p *LogzioPump) Init(config interface{}) error

+ func (p *LogzioPump) New() Pump

+ func (p *LogzioPump) WriteData(data []interface{}) error

+ type LogzioPumpConfig struct

+ CheckDiskSpace bool

+ DiskThreshold int

+ DrainDuration string

+ QueueDir string

+ Token string

+ URL string

+ func NewLogzioPumpConfig() *LogzioPumpConfig

+ type MoesifConf struct

+ ApplicationId string

+ type MoesifPump struct

+ func (e *MoesifPump) New() Pump

+ func (p *MoesifPump) GetName() string

+ func (p *MoesifPump) Init(config interface{}) error

+ func (p *MoesifPump) WriteData(data []interface{}) error

+ type MongoAggregateConf struct

+ IgnoreTagPrefixList []string

+ MongoSSLInsecureSkipVerify bool

+ MongoURL string

+ MongoUseSSL bool

+ StoreAnalyticsPerMinute bool

+ ThresholdLenTagList int

+ TrackAllPaths bool

+ UseMixedCollection bool

+ type MongoAggregatePump struct

+ func (m *MongoAggregatePump) GetCollectionName(orgid string) (string, error)

+ func (m *MongoAggregatePump) GetName() string

+ func (m *MongoAggregatePump) HandleWriteErr(err error) error

+ func (m *MongoAggregatePump) Init(config interface{}) error

+ func (m *MongoAggregatePump) New() Pump

+ func (m *MongoAggregatePump) WriteData(data []interface{}) error

+ func (m *MongoAggregatePump) WriteUptimeData(data []interface{})

+ type MongoConf struct

+ CollectionCapEnable bool

+ CollectionCapMaxSizeBytes int

+ CollectionName string

+ MaxDocumentSizeBytes int

+ MaxInsertBatchSizeBytes int

+ MongoSSLInsecureSkipVerify bool

+ MongoURL string

+ MongoUseSSL bool

+ 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(data []interface{}) error

+ func (m *MongoPump) WriteUptimeData(data []interface{})

+ type MongoSelectiveConf struct

+ MaxDocumentSizeBytes int

+ MaxInsertBatchSizeBytes int

+ MongoSSLInsecureSkipVerify bool

+ MongoURL string

+ MongoUseSSL bool

+ type MongoSelectivePump struct

+ func (m *MongoSelectivePump) AccumulateSet(data []interface{}) [][]interface{}

+ func (m *MongoSelectivePump) GetCollectionName(orgid string) (string, error)

+ func (m *MongoSelectivePump) GetName() string

+ func (m *MongoSelectivePump) Init(config interface{}) error

+ func (m *MongoSelectivePump) New() Pump

+ func (m *MongoSelectivePump) WriteData(data []interface{}) error

+ func (m *MongoSelectivePump) WriteUptimeData(data []interface{})

+ type PrometheusConf struct

+ Addr string

+ Path string

+ type PrometheusPump struct

+ KeyStatusMetrics *prometheus.CounterVec

+ OauthStatusMetrics *prometheus.CounterVec

+ PathStatusMetrics *prometheus.CounterVec

+ TotalLatencyMetrics *prometheus.HistogramVec

+ TotalStatusMetrics *prometheus.CounterVec

+ func (p *PrometheusPump) GetName() string

+ func (p *PrometheusPump) Init(conf interface{}) error

+ func (p *PrometheusPump) New() Pump

+ func (p *PrometheusPump) WriteData(data []interface{}) error

+ type Pump interface

+ GetName func() string

+ Init func(interface{}) error

+ New func() Pump

+ WriteData func([]interface{}) error

+ func GetPumpByName(name string) (Pump, error)

+ type RawDecoded struct

+ type SegmentConf struct

+ WriteKey string

+ type SegmentPump struct

+ func (s *SegmentPump) GetName() string

+ func (s *SegmentPump) Init(config interface{}) error

+ func (s *SegmentPump) New() Pump

+ func (s *SegmentPump) ToJSONMap(obj interface{}) (map[string]interface{}, error)

+ func (s *SegmentPump) WriteData(data []interface{}) error

+ func (s *SegmentPump) WriteDataRecord(record analytics.AnalyticsRecord) error

+ type SplunkClient struct

+ CollectorURL string

+ TLSSkipVerify bool

+ Token string

+ func NewSplunkClient(token string, collectorURL string, skipVerify bool, certFile string, ...) (c *SplunkClient, err error)

+ func (c *SplunkClient) Send(event map[string]interface{}, ts time.Time) (*http.Response, error)

+ type SplunkPump struct

+ func (p *SplunkPump) GetName() string

+ func (p *SplunkPump) Init(config interface{}) error

+ func (p *SplunkPump) New() Pump

+ func (p *SplunkPump) WriteData(data []interface{}) error

+ type SplunkPumpConfig struct

+ CollectorToken string

+ CollectorURL string

+ SSLCertFile string

+ SSLInsecureSkipVerify bool

+ SSLKeyFile string

+ SSLServerName string

+ type StatsdConf struct

+ Address string

+ Fields []string

+ Tags []string

+ type StatsdPump struct

+ func (s *StatsdPump) GetName() string

+ func (s *StatsdPump) Init(config interface{}) error

+ func (s *StatsdPump) New() Pump

+ func (s *StatsdPump) WriteData(data []interface{}) error

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