sender

package

Go to main page

Versions in this module

v1

v1.3.1

Sep 13, 2017

Changes in this version

+ const KeyFtStrategyConcurrent

type FtSender

+ func (ft *FtSender) Reset() error

v1.3.0

Sep 5, 2017

Changes in this version

type FtSender

+ func (ft *FtSender) Stats() utils.StatsInfo

type PandoraSender

+ func (s *PandoraSender) Stats() utils.StatsInfo

+ type StatsSender interface

+ Close func() error

+ Name func() string

+ Send func([]Data) error

+ Stats func() utils.StatsInfo

v1.2.4

Aug 29, 2017

v1.2.3

Aug 16, 2017

Changes in this version

+ var ModeKeyOptions = map[string][]utils.Option

+ var ModeUsages = []utils.KeyValue

v1.2.2

Aug 1, 2017

Changes in this version

+ const KeyFtMemoryChannel

+ const KeyFtMemoryChannelSize

+ func ConvertDatasBack(ins []Data) []map[string]interface

type Data

+ func ConvertDatas(ins []map[string]interface{}) []Data

+ type FtOption struct

v1.2.1

Jul 18, 2017

Changes in this version

+ const KeyForceMicrosecond

v1.1.0

Jun 27, 2017

Changes in this version

+ const DefaultFtSyncEvery

+ const KeyElasticAlias

+ const KeyElasticHost

+ const KeyElasticIndex

+ const KeyElasticType

+ const KeyFaultTolerant

+ const KeyFileSenderPath

+ const KeyFlowRateLimit

+ const KeyFtProcs

+ const KeyFtSaveLogPath

+ const KeyFtStrategy

+ const KeyFtStrategyAlwaysSave

+ const KeyFtStrategyBackupOnly

+ const KeyFtSyncEvery

+ const KeyFtWriteLimit

+ const KeyInfluxdbDB

+ const KeyInfluxdbFields

+ const KeyInfluxdbHost

+ const KeyInfluxdbMeasurement

+ const KeyInfluxdbRetetion

+ const KeyInfluxdbTags

+ const KeyInfluxdbTimestamp

+ const KeyInfluxdbTimestampPrecision

+ const KeyMongodbAccKey

+ const KeyMongodbCollection

+ const KeyMongodbDB

+ const KeyMongodbHost

+ const KeyMongodbUpdateKey

+ const KeyName

+ const KeyPandoraAk

+ const KeyPandoraAutoCreate

+ const KeyPandoraEnableLogDB

+ const KeyPandoraGzip

+ const KeyPandoraHost

+ const KeyPandoraLogDBHost

+ const KeyPandoraLogDBName

+ const KeyPandoraRegion

+ const KeyPandoraRepoName

+ const KeyPandoraSchema

+ const KeyPandoraSchemaFree

+ const KeyPandoraSchemaUpdateInterval

+ const KeyPandoraSk

+ const KeyPandoraUUID

+ const KeyRequestRateLimit

+ const KeyRunnerName

+ const KeySenderType

+ const PandoraTypeArray

+ const PandoraTypeBool

+ const PandoraTypeDate

+ const PandoraTypeFloat

+ const PandoraTypeLong

+ const PandoraTypeMap

+ const PandoraTypeString

+ const PandoraUUID

+ const TypeDiscard

+ const TypeElastic

+ const TypeFile

+ const TypeInfluxdb

+ const TypeMock

+ const TypeMongodbAccumulate

+ const TypePandora

+ const UnderfinedRunnerName

+ var Codes = map[byte][]byte

+ var ErrNotAsyncSender = errors.New("This Sender does not support for Async Push")

+ var PandoraMaxBatchSize = 2 * 1024 * 1024

+ func JSONLineMarshalFunc(datas []Data) ([]byte, error)

+ func MakeKey(name []byte, tags Tags) []byte

+ func String(in string) string

+ func UnescapeString(in string) string

+ type Data map[string]interface

+ type DiscardSender struct

+ func (s *DiscardSender) Close() error

+ func (s *DiscardSender) Name() string

+ func (s *DiscardSender) Send(d []Data) error

+ func (s *DiscardSender) SendCount() int

+ type ElasticsearchSender struct

+ func (this *ElasticsearchSender) Close() error

+ func (this *ElasticsearchSender) Name() string

+ func (this *ElasticsearchSender) Send(data []Data) (err error)

+ type FileSender struct

+ func (fs *FileSender) Close() error

+ func (fs *FileSender) Name() string

+ func (fs *FileSender) Send(datas []Data) error

+ type FtSender struct

+ func NewFtSender(sender Sender, conf conf.MapConf) (*FtSender, error)

+ func (ft *FtSender) Close() error

+ func (ft *FtSender) Name() string

+ func (ft *FtSender) Send(datas []Data) error

+ type InfluxdbSender struct

+ func (s *InfluxdbSender) Close() error

+ func (s *InfluxdbSender) Name() string

+ func (s *InfluxdbSender) Send(datas []Data) error

+ type MockSender struct

+ func (mock *MockSender) Close() error

+ func (mock *MockSender) Name() string

+ func (mock *MockSender) Send(d []Data) error

+ func (mock *MockSender) SendCount() int

+ type MongoAccSender struct

+ func (s *MongoAccSender) Close() error

+ func (s *MongoAccSender) Name() string

+ func (s *MongoAccSender) Send(datas []Data) (se error)

+ type PandoraOption struct

+ type PandoraSender struct

+ UserSchema UserSchema

+ func (s *PandoraSender) Close() error

+ func (s *PandoraSender) Name() string

+ func (s *PandoraSender) Send(datas []Data) (se error)

+ func (s *PandoraSender) UpdateSchemas()

+ type Point struct

+ Fields map[string]interface{}

+ Measurement string

+ Tags map[string]string

+ Time int64

+ func (p *Point) GetFields() []byte

+ func (p *Point) Key() []byte

+ func (p *Point) String() string

+ type Points []Point

+ func (ps Points) Buffer() []byte

+ type Sender interface

+ Close func() error

+ Name func() string

+ Send func([]Data) error

+ func NewDiscardSender(c conf.MapConf) (Sender, error)

+ func NewElasticSender(conf conf.MapConf) (sender Sender, err error)

+ func NewFileSender(conf conf.MapConf) (sender Sender, err error)

+ func NewInfluxdbSender(c conf.MapConf) (s Sender, err error)

+ func NewMockSender(c conf.MapConf) (Sender, error)

+ func NewMongodbAccSender(conf conf.MapConf) (sender Sender, err error)

+ func NewPandoraSender(conf conf.MapConf) (sender Sender, err error)

+ type SenderRegistry struct

+ func NewSenderRegistry() *SenderRegistry

+ func (r *SenderRegistry) NewSender(conf conf.MapConf) (sender Sender, err error)

+ func (registry *SenderRegistry) RegisterSender(senderType string, constructor func(conf.MapConf) (Sender, error)) error

+ type Tags map[string]string

+ func (t Tags) HashKey() []byte

+ type UserSchema struct

+ DefaultAll bool

+ Fields map[string]string

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