pumps

Aug 12, 2024

Changes in this version

+ type KinesisConf struct

+ BatchSize int

+ EnvPrefix string

+ Region string

+ StreamName string

+ type KinesisPump struct

+ func (p *KinesisPump) GetEnvPrefix() string

+ func (p *KinesisPump) GetName() string

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

+ func (p *KinesisPump) New() Pump

+ func (p *KinesisPump) WriteData(ctx context.Context, records []interface{}) error

Mar 1, 2024

Changes in this version

+ var BuildDate string

+ var BuiltBy string

+ var SQSDefaultENV = PUMPS_ENV_PREFIX + "_SQS" + PUMPS_ENV_META_PREFIX

+ var SQSPrefix = "sqs-pump"

+ var Version = "v1.9.0"

type GraphSQLAggregatePump

+ func (s *GraphSQLAggregatePump) GetEnvPrefix() string

type ResurfacePump

+ func (rp *ResurfacePump) Flush() error

+ func (rp *ResurfacePump) Shutdown() error

+ type SQSConf struct

+ AWSDelaySeconds int32

+ AWSEndpoint string

+ AWSKey string

+ AWSMessageGroupID string

+ AWSMessageIDDeduplicationEnabled bool

+ AWSRegion string

+ AWSSQSBatchLimit int

+ AWSSecret string

+ AWSToken string

+ EnvPrefix string

+ QueueName string

+ type SQSPump struct

+ SQSClient SQSSendMessageBatchAPI

+ SQSConf *SQSConf

+ SQSQueueURL *string

+ func (s *SQSPump) GetEnvPrefix() string

+ func (s *SQSPump) GetName() string

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

+ func (s *SQSPump) New() Pump

+ func (s *SQSPump) NewSQSPublisher() (c *sqs.Client, err error)

+ func (s *SQSPump) WriteData(ctx context.Context, data []interface{}) error

+ type SQSSendMessageBatchAPI interface

+ GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ SendMessageBatch func(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)

type SplunkPumpConfig

+ MaxRetries uint64

Aug 29, 2023

Changes in this version

type PrometheusConf

+ TrackAllPaths bool

type SQLAggregatePumpConf

+ OmitIndexCreation bool

Jun 20, 2023

Changes in this version

type BaseMongoConf

+ MongoDirectConnection bool

Apr 28, 2023

Changes in this version

+ const GraphSQLPrefix

+ const GraphSQLTable

+ var CommonTagsCount = 5

+ var DefaultRPCCallTimeout = 10

+ var ErrRPCLogin = errors.New("RPC login incorrect")

+ var GraphSQLDefaultENV = PUMPS_ENV_PREFIX + "_GRAPH_SQL" + PUMPS_ENV_META_PREFIX

+ var SQLGraphAggregateDefaultENV = PUMPS_ENV_PREFIX + "_SQLGRAPHAGGREGATE" + PUMPS_ENV_META_PREFIX

+ var ThresholdLenTagList = 1000

type BaseMongoConf

+ MongoDriverType string

type CommonPumpConfig

+ func (p *CommonPumpConfig) GetDecodedRequest() bool

+ func (p *CommonPumpConfig) GetDecodedResponse() bool

+ func (p *CommonPumpConfig) SetDecodingRequest(decoding bool)

+ func (p *CommonPumpConfig) SetDecodingResponse(decoding bool)

type GraphMongoPump

+ func (g *GraphMongoPump) SetDecodingRequest(decoding bool)

+ func (g *GraphMongoPump) SetDecodingResponse(decoding bool)

+ type GraphSQLAggregatePump struct

+ SQLConf *SQLAggregatePumpConf

+ func (s *GraphSQLAggregatePump) DoAggregatedWriting(ctx context.Context, table, orgID string, ag *analytics.GraphRecordAggregate) error

+ func (s *GraphSQLAggregatePump) GetName() string

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

+ func (s *GraphSQLAggregatePump) New() Pump

+ func (s *GraphSQLAggregatePump) WriteData(ctx context.Context, data []interface{}) error

+ type GraphSQLConf struct

+ TableName string

+ type GraphSQLPump struct

+ Conf *GraphSQLConf

+ func (g *GraphSQLPump) GetEnvPrefix() string

+ func (g *GraphSQLPump) GetName() string

+ func (g *GraphSQLPump) Init(conf interface{}) error

+ func (g *GraphSQLPump) New() Pump

+ func (g *GraphSQLPump) SetLogLevel(level logrus.Level)

+ func (g *GraphSQLPump) WriteData(ctx context.Context, data []interface{}) error

type HybridPump

+ func (p *HybridPump) RPCLogin() error

+ func (p *HybridPump) Shutdown() error

+ type HybridPumpConf struct

+ APIKey string

+ Aggregated bool

+ CallTimeout int

+ ConnectionString string

+ EnvPrefix string

+ IgnoreTagPrefixList []string

+ RPCKey string

+ RPCPoolSize int

+ SSLInsecureSkipVerify bool

+ StoreAnalyticsPerMinute bool

+ TrackAllPaths bool

+ UseSSL bool

+ func (conf *HybridPumpConf) CheckDefaults()

type MongoAggregatePump

+ func (m *MongoAggregatePump) SetDecodingRequest(decoding bool)

+ func (m *MongoAggregatePump) SetDecodingResponse(decoding bool)

type MongoPump

+ func (m *MongoPump) SetDecodingRequest(decoding bool)

+ func (m *MongoPump) SetDecodingResponse(decoding bool)

type MongoSelectivePump

+ func (m *MongoSelectivePump) SetDecodingRequest(decoding bool)

+ func (m *MongoSelectivePump) SetDecodingResponse(decoding bool)

type Pump

+ GetDecodedRequest func() bool

+ GetDecodedResponse func() bool

+ SetDecodingRequest func(bool)

+ SetDecodingResponse func(bool)

+ type ResurfacePump struct

+ func (rp *ResurfacePump) GetEnvPrefix() string

+ func (rp *ResurfacePump) GetName() string

+ func (rp *ResurfacePump) Init(config interface{}) error

+ func (rp *ResurfacePump) New() Pump

+ func (rp *ResurfacePump) WriteData(ctx context.Context, data []interface{}) error

+ type ResurfacePumpConfig struct

+ EnvPrefix string

+ Queue []string

+ Rules string

+ URL string

type SQLAggregatePump

+ func (c *SQLAggregatePump) SetDecodingRequest(decoding bool)

+ func (c *SQLAggregatePump) SetDecodingResponse(decoding bool)

type SQLPump

+ func (c *SQLPump) SetDecodingRequest(decoding bool)

+ func (c *SQLPump) SetDecodingResponse(decoding bool)

Dec 2, 2022

Changes in this version

+ const AWSDBError

+ const CosmosDBError

type BaseMongoConf

+ MongoSessionConsistency string

+ func (b *BaseMongoConf) SetMongoConsistency(session *mgo.Session)

type CommonPumpConfig

+ func (p *CommonPumpConfig) GetIgnoreFields() []string

+ func (p *CommonPumpConfig) SetIgnoreFields(fields []string)

+ func (p *CommonPumpConfig) SetLogLevel(level logrus.Level)

+ type CustomMetrics []PrometheusMetric

+ func (metrics *CustomMetrics) Set(data string) error

type ElasticsearchConf

+ SSLCertFile string

+ SSLInsecureSkipVerify bool

+ SSLKeyFile string

+ UseSSL bool

type ElasticsearchPump

+ func (e *ElasticsearchPump) GetTLSConfig() (*tls.Config, error)

+ type GraphMongoPump struct

+ func (g *GraphMongoPump) GetEnvPrefix() string

+ func (g *GraphMongoPump) GetName() string

+ func (g *GraphMongoPump) Init(config interface{}) error

+ func (g *GraphMongoPump) New() Pump

+ func (g *GraphMongoPump) WriteData(ctx context.Context, data []interface{}) error

type MongoAggregateConf

+ AggregationTime int

+ EnableAggregateSelfHealing bool

type MongoAggregatePump

+ func (m *MongoAggregatePump) SetAggregationTime()

+ func (m *MongoAggregatePump) ShouldSelfHeal(err error) bool

type MongoType

+ const CosmosDB

type PrometheusConf

+ AggregateObservations bool

+ DisabledMetrics []string

type PrometheusMetric

+ func (pm *PrometheusMetric) Expose() error

+ func (pm *PrometheusMetric) Inc(values ...string) error

+ func (pm *PrometheusMetric) Observe(requestTime int64, values ...string) error

type PrometheusPump

+ func (p *PrometheusPump) CreateBasicMetrics()

+ func (p *PrometheusPump) InitCustomMetrics()

type Pump

+ GetIgnoreFields func() []string

+ SetIgnoreFields func([]string)

+ SetLogLevel func(logrus.Level)

type TimestreamPump

+ func (t *TimestreamPump) NewTimestreamWriter() (c *timestreamwrite.Client, err error)

Jun 27, 2022

Changes in this version

+ var Commit string

+ var VERSION = "v1.6.0"

+ func LoadHeadersFromRawRequest(rawRequest string) (http.Header, error)

+ func LoadHeadersFromRawResponse(rawResponse string) (http.Header, error)

+ func Min(a, b int) int

type BaseMongoConf

+ OmitIndexCreation bool

type MoesifPump

+ func (p *MoesifPump) Shutdown() error

type PrometheusConf

+ CustomMetrics []PrometheusMetric

+ type PrometheusMetric struct

+ Buckets []float64

+ Help string

+ Labels []string

+ MetricType string

+ Name string

+ func (pm *PrometheusMetric) GetLabelsValues(decoded analytics.AnalyticsRecord) []string

+ func (pm *PrometheusMetric) InitVec() error

type StatsdConf

+ SeparatedMethod bool

+ type TimestreamPump struct

+ func (t *TimestreamPump) BuildTimestreamInputIterator(data []interface{}) (func() (records []types.Record, hasNext bool), bool)

+ func (t *TimestreamPump) GetAnalyticsRecordDimensions(decoded *analytics.AnalyticsRecord) (dimensions []types.Dimension)

+ func (t *TimestreamPump) GetAnalyticsRecordMeasures(decoded *analytics.AnalyticsRecord) (measureValues []types.MeasureValue)

+ func (t *TimestreamPump) GetEnvPrefix() string

+ func (t *TimestreamPump) GetName() string

+ func (t *TimestreamPump) Init(config interface{}) error

+ func (t *TimestreamPump) MapAnalyticRecord2TimestreamMultimeasureRecord(decoded *analytics.AnalyticsRecord) types.Record

+ func (t *TimestreamPump) New() Pump

+ func (t *TimestreamPump) NewTimesteramWriter() (c *timestreamwrite.Client, err error)

+ func (t *TimestreamPump) WriteData(ctx context.Context, data []interface{}) error

+ type TimestreamPumpConf struct

+ AWSRegion string

+ DatabaseName string

+ Dimensions []string

+ EnvPrefix string

+ Measures []string

+ NameMappings map[string]string

+ ReadGeoFromRequest bool

+ TableName string

+ WriteRateLimit bool

+ WriteZeroValues bool

+ type TimestreamWriteRecordsAPI interface

+ WriteRecords func(ctx context.Context, params *timestreamwrite.WriteRecordsInput, ...) (*timestreamwrite.WriteRecordsOutput, error)

Jan 24, 2022

Changes in this version

+ type Influx2Conf struct

+ Addr string

+ BucketName string

+ CreateMissingBucket bool

+ EnvPrefix string

+ Fields []string

+ Flush bool

+ NewBucketConfig NewBucket

+ OrgName string

+ Tags []string

+ Token string

+ type Influx2Pump struct

+ func (i *Influx2Pump) GetEnvPrefix() string

+ func (i *Influx2Pump) GetName() string

+ func (i *Influx2Pump) Init(config interface{}) error

+ func (i *Influx2Pump) New() Pump

+ func (i *Influx2Pump) Shutdown() error

+ func (i *Influx2Pump) WriteData(ctx context.Context, data []interface{}) error

type MongoAggregatePump

+ func (m *MongoAggregatePump) DoAggregatedWriting(ctx context.Context, orgID string, ...) error

+ type NewBucket struct

+ Description string

+ RetentionRules []RetentionRule

+ type RetentionRule struct

+ EverySeconds int64

+ ShardGroupDurationSeconds int64

+ Type string

type SQLAggregatePump

+ func (c *SQLAggregatePump) DoAggregatedWriting(ctx context.Context, table, orgID string, ...) error

Sep 23, 2021

Changes in this version

+ var SQLAggregateDefaultENV = PUMPS_ENV_PREFIX + "_SQLAGGREGATE" + PUMPS_ENV_META_PREFIX

+ var SQLAggregatePumpPrefix = "SQL-aggregate-pump"

+ var SQLDefaultENV = PUMPS_ENV_PREFIX + "_SQL" + PUMPS_ENV_META_PREFIX

+ var SQLDefaultQueryBatchSize = 1000

+ var SQLPrefix = "SQL-pump"

+ func Dialect(cfg *SQLConf) (gorm.Dialector, error)

type CommonPumpConfig

+ func (p *CommonPumpConfig) GetMaxRecordSize() int

+ func (p *CommonPumpConfig) SetMaxRecordSize(size int)

+ func (p *CommonPumpConfig) Shutdown() error

type DogStatsdPump

+ func (s *DogStatsdPump) Shutdown() error

+ type Elasticsearch7Operator struct

type ElasticsearchPump

+ func (e *ElasticsearchPump) Shutdown() error

+ type MysqlConfig struct

+ DefaultStringSize uint

+ DisableDatetimePrecision bool

+ DontSupportRenameColumn bool

+ DontSupportRenameIndex bool

+ SkipInitializeWithVersion bool

+ type PostgresConfig struct

+ PreferSimpleProtocol bool

type Pump

+ GetMaxRecordSize func() int

+ SetMaxRecordSize func(size int)

+ Shutdown func() error

+ type SQLAggregatePump struct

+ SQLConf *SQLAggregatePumpConf

+ func (c *SQLAggregatePump) GetEnvPrefix() string

+ func (c *SQLAggregatePump) GetName() string

+ func (c *SQLAggregatePump) Init(conf interface{}) error

+ func (c *SQLAggregatePump) New() Pump

+ func (c *SQLAggregatePump) WriteData(ctx context.Context, data []interface{}) error

+ type SQLAggregatePumpConf struct

+ EnvPrefix string

+ IgnoreAggregationsList []string

+ IgnoreTagPrefixList []string

+ StoreAnalyticsPerMinute bool

+ ThresholdLenTagList int

+ TrackAllPaths bool

+ type SQLConf struct

+ BatchSize int

+ ConnectionString string

+ EnvPrefix string

+ LogLevel string

+ Mysql MysqlConfig

+ Postgres PostgresConfig

+ TableSharding bool

+ Type string

+ type SQLPump struct

+ IsUptime bool

+ SQLConf *SQLConf

+ func (c *SQLPump) GetEnvPrefix() string

+ func (c *SQLPump) GetName() string

+ func (c *SQLPump) Init(conf interface{}) error

+ func (c *SQLPump) New() Pump

+ func (c *SQLPump) WriteData(ctx context.Context, data []interface{}) error

+ func (c *SQLPump) WriteUptimeData(data []interface{})

type SplunkPump

+ func (p *SplunkPump) FilterTags(filteredTags []string) []string

type SplunkPumpConfig

+ BatchMaxContentLength int

+ EnableBatch bool

+ IgnoreTagPrefixList []string

+ type UptimePump interface

+ GetName func() string

+ Init func(interface{}) error

+ WriteUptimeData func(data []interface{})

Jun 8, 2021

Changes in this version

+ type StdOutConf struct

+ EnvPrefix string

+ Format string

+ LogFieldName string

+ type StdOutPump struct

+ func (s *StdOutPump) GetEnvPrefix() string

+ func (s *StdOutPump) GetName() string

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

+ func (s *StdOutPump) New() Pump

+ func (s *StdOutPump) WriteData(ctx context.Context, data []interface{}) error

Apr 22, 2021

Changes in this version

+ const PUMPS_ENV_META_PREFIX

+ const PUMPS_ENV_PREFIX

type BaseMongoConf

+ EnvPrefix string

type CSVConf

+ EnvPrefix string

type CSVPump

+ func (c *CSVPump) GetEnvPrefix() string

type CommonPumpConfig

+ func (p *CommonPumpConfig) GetEnvPrefix() string

type DogStatsdConf

+ EnvPrefix string

type DogStatsdPump

+ func (s *DogStatsdPump) GetEnvPrefix() string

type ElasticsearchConf

+ EnvPrefix string

type ElasticsearchPump

+ func (e *ElasticsearchPump) GetEnvPrefix() string

type GraylogConf

+ EnvPrefix string

type GraylogPump

+ func (p *GraylogPump) GetEnvPrefix() string

type InfluxConf

+ EnvPrefix string

type InfluxPump

+ func (i *InfluxPump) GetEnvPrefix() string

type KafkaConf

+ EnvPrefix string

type KafkaPump

+ func (k *KafkaPump) GetEnvPrefix() string

type LogzioPump

+ func (p *LogzioPump) GetEnvPrefix() string

type LogzioPumpConfig

+ EnvPrefix string

type MoesifConf

+ EnvPrefix string

type MoesifPump

+ func (p *MoesifPump) GetEnvPrefix() string

type MongoAggregatePump

+ func (m *MongoAggregatePump) GetEnvPrefix() string

type MongoPump

+ IsUptime bool

+ func (m *MongoPump) GetEnvPrefix() string

type MongoSelectivePump

+ func (m *MongoSelectivePump) GetEnvPrefix() string

type PrometheusConf

+ EnvPrefix string

type PrometheusPump

+ func (p *PrometheusPump) GetEnvPrefix() string

type Pump

+ GetEnvPrefix func() string

type SegmentConf

+ EnvPrefix string

type SegmentPump

+ func (s *SegmentPump) GetEnvPrefix() string

type SplunkPump

+ func (p *SplunkPump) GetEnvPrefix() string

type SplunkPumpConfig

+ EnvPrefix string

+ Fields []string

+ ObfuscateAPIKeysLength int

type StatsdConf

+ EnvPrefix string

type StatsdPump

+ func (s *StatsdPump) GetEnvPrefix() string

type SyslogConf

+ EnvPrefix string

type SyslogPump

+ func (s *SyslogPump) GetEnvPrefix() string

Feb 4, 2021

Changes in this version

+ type ApiKeyTransport struct

+ APIKey string

+ APIKeyID string

+ func (t *ApiKeyTransport) RoundTrip(r *http.Request) (*http.Response, error)

type BaseMongoConf

+ func (b *BaseMongoConf) GetBlurredURL() string

+ 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 DogStatsdConf

+ Tags []string

type ElasticsearchConf

+ AuthAPIKey string

+ AuthAPIKeyID string

+ Password string

+ Username string

type KafkaConf

+ Algorithm string

+ Password string

+ SASLMechanism string

+ SSLCertFile string

+ SSLKeyFile string

+ Username string

type MoesifConf

+ ApplicationID string

+ AuthorizationHeaderName string

+ AuthorizationUserIdField string

+ BulkConfig map[string]interface{}

+ CompanyIDHeader string

+ DisableCaptureRequestBody bool

+ DisableCaptureResponseBody bool

+ EnableBulk bool

+ RequestBodyMasks []string

+ RequestHeaderMasks []string

+ ResponseBodyMasks []string

+ ResponseHeaderMasks []string

+ UserIDHeader string

type MongoAggregateConf

+ IgnoreAggregationsList []string

type Pump

+ GetOmitDetailedRecording func() bool

+ SetOmitDetailedRecording func(bool)

type SplunkPumpConfig

+ ObfuscateAPIKeys bool

+ 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

Jul 16, 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) GetFilters() analytics.AnalyticsFilters

+ func (c *CSVPump) GetTimeout() int

+ func (c *CSVPump) SetFilters(filters analytics.AnalyticsFilters)

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

type DogStatsdPump

+ func (s *DogStatsdPump) GetFilters() analytics.AnalyticsFilters

+ func (s *DogStatsdPump) GetTimeout() int

+ func (s *DogStatsdPump) SetFilters(filters analytics.AnalyticsFilters)

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

type DummyPump

+ func (p *DummyPump) GetFilters() analytics.AnalyticsFilters

+ func (p *DummyPump) GetTimeout() int

+ func (p *DummyPump) SetFilters(filters analytics.AnalyticsFilters)

+ 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) GetFilters() analytics.AnalyticsFilters

+ func (e *ElasticsearchPump) GetTimeout() int

+ func (e *ElasticsearchPump) SetFilters(filters analytics.AnalyticsFilters)

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

type GraylogPump

+ func (p *GraylogPump) GetFilters() analytics.AnalyticsFilters

+ func (p *GraylogPump) GetTimeout() int

+ func (p *GraylogPump) SetFilters(filters analytics.AnalyticsFilters)

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

type HybridPump

+ func (p *HybridPump) GetFilters() analytics.AnalyticsFilters

+ func (p *HybridPump) GetTimeout() int

+ func (p *HybridPump) SetFilters(filters analytics.AnalyticsFilters)

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

type InfluxPump

+ func (i *InfluxPump) GetFilters() analytics.AnalyticsFilters

+ func (i *InfluxPump) GetTimeout() int

+ func (i *InfluxPump) SetFilters(filters analytics.AnalyticsFilters)

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

type KafkaPump

+ func (k *KafkaPump) GetFilters() analytics.AnalyticsFilters

+ func (k *KafkaPump) GetTimeout() int

+ func (k *KafkaPump) SetFilters(filters analytics.AnalyticsFilters)

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

type LogzioPump

+ func (p *LogzioPump) GetFilters() analytics.AnalyticsFilters

+ func (p *LogzioPump) GetTimeout() int

+ func (p *LogzioPump) SetFilters(filters analytics.AnalyticsFilters)

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

type MoesifPump

+ func (p *MoesifPump) GetFilters() analytics.AnalyticsFilters

+ func (p *MoesifPump) GetTimeout() int

+ func (p *MoesifPump) SetFilters(filters analytics.AnalyticsFilters)

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

type MongoAggregatePump

+ func (m *MongoAggregatePump) GetFilters() analytics.AnalyticsFilters

+ func (m *MongoAggregatePump) GetTimeout() int

+ func (m *MongoAggregatePump) SetFilters(filters analytics.AnalyticsFilters)

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

type MongoPump

+ func (m *MongoPump) GetFilters() analytics.AnalyticsFilters

+ func (m *MongoPump) GetTimeout() int

+ func (m *MongoPump) SetFilters(filters analytics.AnalyticsFilters)

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

type MongoSelectivePump

+ func (m *MongoSelectivePump) GetFilters() analytics.AnalyticsFilters

+ func (m *MongoSelectivePump) GetTimeout() int

+ func (m *MongoSelectivePump) SetFilters(filters analytics.AnalyticsFilters)

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

+ type MongoType int

+ const AWSDocumentDB

+ const StandardMongo

type PrometheusPump

+ func (p *PrometheusPump) GetFilters() analytics.AnalyticsFilters

+ func (p *PrometheusPump) GetTimeout() int

+ func (p *PrometheusPump) SetFilters(filters analytics.AnalyticsFilters)

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

type Pump

+ GetFilters func() analytics.AnalyticsFilters

+ GetTimeout func() int

+ SetFilters func(analytics.AnalyticsFilters)

+ SetTimeout func(timeout int)

type SegmentPump

+ func (s *SegmentPump) GetFilters() analytics.AnalyticsFilters

+ func (s *SegmentPump) GetTimeout() int

+ func (s *SegmentPump) SetFilters(filters analytics.AnalyticsFilters)

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

type SplunkPump

+ func (p *SplunkPump) GetFilters() analytics.AnalyticsFilters

+ func (p *SplunkPump) SetFilters(filters analytics.AnalyticsFilters)

+ func (s *SplunkPump) GetTimeout() int

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

type StatsdPump

+ func (s *StatsdPump) GetFilters() analytics.AnalyticsFilters

+ func (s *StatsdPump) GetTimeout() int

+ func (s *StatsdPump) SetFilters(filters analytics.AnalyticsFilters)

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

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