Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

reader

package

Go to main page

Versions in this module

v1

v1.5.5

May 18, 2020

Changes in this version

+ const DefautFileRetention

+ const DoneFileName

+ const FtSaveLogPath

+ func AndCondition(f1, f2 func(os.FileInfo) bool) func(os.FileInfo) bool

+ func CompressedFile(path string) bool

+ func GetLogPathAbs(conf conf.MapConf) (logpath, oldLogPath string, err error)

+ func GetMaxFile(logdir string, condition func(os.FileInfo) bool, ...) (chosen os.FileInfo, err error)

+ func GetMetaOption(conf conf.MapConf) (string, string, string, error)

+ func GetMinFile(logdir string, condition func(os.FileInfo) bool, ...) (os.FileInfo, error)

+ func IgnoreFileSuffixes(file string, suffixes []string) bool

+ func IgnoreHidden(file string, ignoreHidden bool) bool

+ func InRunTime(hour, minute int, runTime RunTime) bool

+ func JoinFileInode(filename, inode string) string

+ func NoCondition(f os.FileInfo) bool

+ func NotCondition(f1 func(os.FileInfo) bool) func(os.FileInfo) bool

+ func OrCondition(f1, f2 func(os.FileInfo) bool) func(os.FileInfo) bool

+ func ParseLoopDuration(cronSched string) (dur time.Duration, err error)

+ func ParseNumber(str string) (number int, err error)

+ func ParseTime(timeStr string) (hour, minute int, err error)

+ func RegisterConstructor(typ string, c Constructor)

+ func ValidFileRegex(file, validFilePattern string) bool

+ type Constructor func(*Meta, conf.MapConf) (Reader, error)

+ type DaemonReader interface

+ Start func() error

+ type DataReader interface

+ ReadData func() (Data, int64, error)

type Meta

+ Dir string

+ LastKey string

+ Readlimit int

+ TagFile string

+ func NewMetaWithRunnerName(runnerName, metadir, filedonedir, logpath, mode, tagfile string, ...) (m *Meta, err error)

+ func (m *Meta) AddSubMeta(key string, meta *Meta) error

+ func (m *Meta) AppendDoneFileInode(path string, inode uint64) (err error)

+ func (m *Meta) CheckExpiredSubMetas(expire time.Duration)

+ func (m *Meta) CleanExpiredSubMetas(expire time.Duration)

+ func (m *Meta) Delete() error

+ func (m *Meta) GetDoneFileContent() ([]string, error)

+ func (m *Meta) GetDoneFileInode(inodeSensitive bool) map[string]bool

+ func (m *Meta) GetEncodeTag() string

+ func (m *Meta) IsStatisticFileExist() bool

+ func (m *Meta) IsStatisticFileNotExist() bool

+ func (m *Meta) ReadDBDoneFile(database string) (content []string, err error)

+ func (m *Meta) ReadRecordsFile(recordsFile string) ([]string, error)

+ func (m *Meta) RemoveSubMeta(key string)

+ type NewSourceRecorder interface

+ NewSourceIndex func() []SourceIndex

+ type OnceReader interface

+ ReadDone func() bool

type Reader

+ func NewReader(conf conf.MapConf, errDirectReturn bool) (reader Reader, err error)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (reg *Registry) NewReader(conf conf.MapConf, errDirectReturn bool) (reader Reader, err error)

+ func (reg *Registry) NewReaderWithMeta(conf conf.MapConf, meta *Meta, errDirectReturn bool) (Reader, error)

+ func (reg *Registry) RegisterReader(readerType string, constructor Constructor) error

+ type RunTime struct

+ EndHour int

+ EndMin int

+ StartHour int

+ StartMin int

+ func ParseRunTime(runTimeStr string) (runTime RunTime, err error)

+ func ParseRunTimeWithMode(mode string, v interface{}) (runTime RunTime, err error)

+ func (r RunTime) Equal() bool

+ func (r RunTime) GreaterThanStart(hour, minute int) bool

+ func (r RunTime) LessThanEnd(hour, minute int) bool

+ type RunTimeReader interface

+ SetRunTime func(mode string, v interface{}) error

+ type SourceIndex struct

+ Index int

+ Source string

type Statistic

+ ParseErrors ErrorStatistic

+ ReadErrors ErrorStatistic

+ SendErrors map[string]ErrorStatistic

+ TransCnt map[string][2]int64

+ TransformErrors map[string]ErrorStatistic

v1.4.7

Apr 17, 2018

Changes in this version

+ const DataTypeChannel

+ const DataTypeList

+ const DataTypePatterChannel

+ const DataTypeSet

+ const DataTypeString

+ const DateTypeHash

+ const DateTypeSortedSet

+ const DefaultHttpServiceAddress

+ const DefaultHttpServicePath

+ const DefaultMaxBodySize

+ const DefaultMaxBytesPerFile

+ const DefaultSyncDirectory

+ const DefaultSyncEvery

+ const DefaultSyncMetaStore

+ const DefaultWriteSpeedLimit

+ const DirMode

+ const FileMode

+ const KeyAWSAccessKey

+ const KeyAWSProfile

+ const KeyAWSSecretKey

+ const KeyAWSToken

+ const KeyBufSize

+ const KeyCacheTTL

+ const KeyCollectInterval

+ const KeyDataSourceTag

+ const KeyDelay

+ const KeyDimension

+ const KeyESHost

+ const KeyESIndex

+ const KeyESKeepAlive

+ const KeyESReadBatch

+ const KeyESType

+ const KeyESVersion

+ const KeyEncoding

+ const KeyErrDirectReturn

+ const KeyExecInterpreter

+ const KeyExpire

+ const KeyFileDone

+ const KeyHeadPattern

+ const KeyHttpServiceAddress

+ const KeyHttpServicePath

+ const KeyIgnoreFileSuffix

+ const KeyIgnoreHiddenFile

+ const KeyKafkaGroupID

+ const KeyKafkaTopic

+ const KeyKafkaZookeeper

+ const KeyKafkaZookeeperChroot

+ const KeyKafkaZookeeperTimeout

+ const KeyLogPath

+ const KeyMaxOpenFiles

+ const KeyMetaPath

+ const KeyMetrics

+ const KeyMode

+ const KeyMongoCert

+ const KeyMongoCollection

+ const KeyMongoCron

+ const KeyMongoDatabase

+ const KeyMongoExecOnstart

+ const KeyMongoFilters

+ const KeyMongoHost

+ const KeyMongoOffsetKey

+ const KeyMongoReadBatch

+ const KeyMssqlCron

+ const KeyMssqlDataBase

+ const KeyMssqlDataSource

+ const KeyMssqlExecOnStart

+ const KeyMssqlOffsetKey

+ const KeyMssqlReadBatch

+ const KeyMssqlSQL

+ const KeyMysqlCron

+ const KeyMysqlDataBase

+ const KeyMysqlDataSource

+ const KeyMysqlExecOnStart

+ const KeyMysqlOffsetKey

+ const KeyMysqlReadBatch

+ const KeyMysqlSQL

+ const KeyNamespace

+ const KeyNewFileNewLine

+ const KeyPGsqlCron

+ const KeyPGsqlDataBase

+ const KeyPGsqlDataSource

+ const KeyPGsqlExecOnStart

+ const KeyPGsqlOffsetKey

+ const KeyPGsqlReadBatch

+ const KeyPGsqlSQL

+ const KeyPeriod

+ const KeyRateLimit

+ const KeyReadIOLimit

+ const KeyRedisAddress

+ const KeyRedisDB

+ const KeyRedisDataType

+ const KeyRedisHashArea

+ const KeyRedisKey

+ const KeyRedisPassword

+ const KeyRegion

+ const KeyRoleArn

+ const KeyS3AccessKey

+ const KeyS3Bucket

+ const KeyS3Prefix

+ const KeyS3Region

+ const KeyS3SecretKey

+ const KeySQLSchema

+ const KeyScriptCron

+ const KeyScriptExecOnStart

+ const KeySharedCredentialFile

+ const KeySnmpReaderAgents

+ const KeySnmpReaderAuthPassword

+ const KeySnmpReaderAuthProtocol

+ const KeySnmpReaderCommunity

+ const KeySnmpReaderContextName

+ const KeySnmpReaderEngineBoots

+ const KeySnmpReaderEngineID

+ const KeySnmpReaderEngineTime

+ const KeySnmpReaderFields

+ const KeySnmpReaderInterval

+ const KeySnmpReaderMaxRepetitions

+ const KeySnmpReaderName

+ const KeySnmpReaderPrivPassword

+ const KeySnmpReaderPrivProtocol

+ const KeySnmpReaderRetries

+ const KeySnmpReaderSecLevel

+ const KeySnmpReaderSecName

+ const KeySnmpReaderTables

+ const KeySnmpReaderTimeOut

+ const KeySnmpReaderVersion

+ const KeySnmpTableName

+ const KeySocketKeepAlivePeriod

+ const KeySocketMaxConnections

+ const KeySocketReadBufferSize

+ const KeySocketReadTimeout

+ const KeySocketServiceAddress

+ const KeyStatInterval

+ const KeySyncConcurrent

+ const KeySyncDirectory

+ const KeySyncInterval

+ const KeySyncMetastore

+ const KeyTagFile

+ const KeyTimeoutDuration

+ const KeyTimestamp

+ const KeyValidFilePattern

+ const KeyWhence

+ const Loop

+ const MaxHeadPatternBufferSize

+ const ModeCloudTrail

+ const ModeCloudWatch

+ const ModeDir

+ const ModeElastic

+ const ModeFile

+ const ModeFileAuto

+ const ModeHttp

+ const ModeKafka

+ const ModeMetrics

+ const ModeMongo

+ const ModeMssql

+ const ModeMysql

+ const ModePG

+ const ModeRedis

+ const ModeScript

+ const ModeSnmp

+ const ModeSocket

+ const ModeTailx

+ const MongoDefaultOffsetKey

+ const ReadModeHeadPatternRegexp

+ const ReadModeHeadPatternString

+ const SQL_SPLITER

+ const StatusInit

+ const StatusRunning

+ const StatusStopped

+ const StatusStopping

+ const WhenceNewest

+ const WhenceOldest

+ var ElasticVersion3 = "3.x"

+ var ElasticVersion5 = "5.x"

+ var ElasticVersion6 = "6.x"

+ var ErrBufferFull = errors.New("bufio: buffer full")

+ var ErrFileNotDir = errors.New("file is not directory")

+ var ErrFileNotRegular = errors.New("file is not regular")

+ var ErrInvalidUnreadByte = errors.New("bufio: invalid use of UnreadByte")

+ var ErrInvalidUnreadRune = errors.New("bufio: invalid use of UnreadRune")

+ var ErrMetaFileRead = errors.New("cannot read meta file")

+ var ErrNegativeCount = errors.New("bufio: negative count")

+ var ErrNoFileChosen = errors.New("no files found")

+ var ErrStopped = errors.New("runner stopped")

+ var ModeKeyOptions = map[string][]Option

+ var ModeUsages = []KeyValue

+ var OptionBuffSize = Option

+ var OptionDataSourceTag = Option

+ var OptionEncoding = Option

+ var OptionHeadPattern = Option

+ var OptionKeyNewFileNewLine = Option

+ var OptionKeyValidFilePattern = Option

+ var OptionMetaPath = Option

+ var OptionReadIoLimit = Option

+ var OptionSQLSchema = Option

+ var OptionWhence = Option

+ var WaitNoSuchFile = time.Second

+ func Errorf(err error, msg string, format ...interface{}) error

+ func HeadPatternMode(mode string, v interface{}) (reg *regexp.Regexp, err error)

+ func SelectMetrics(c *CloudWatch) ([]*cloudwatch.Metric, error)

+ type ActiveReader struct

+ func NewActiveReader(originPath, realPath, whence string, meta *Meta, msgChan chan<- Result) (ar *ActiveReader, err error)

+ func (ar *ActiveReader) Close() error

+ func (ar *ActiveReader) Lag() (rl *LagInfo, err error)

+ func (ar *ActiveReader) Run()

+ func (ar *ActiveReader) Status() StatsInfo

+ func (ar *ActiveReader) SyncMeta() string

+ type BufReader struct

+ func NewReaderSize(rd FileReader, meta *Meta, size int) (*BufReader, error)

+ func (b *BufReader) Close() error

+ func (b *BufReader) Lag() (rl *LagInfo, err error)

+ func (b *BufReader) Name() string

+ func (b *BufReader) ReadLine() (ret string, err error)

+ func (b *BufReader) ReadPattern() (string, error)

+ func (b *BufReader) ReadString(delim byte) (ret string, err error)

+ func (b *BufReader) SetMode(mode string, v interface{}) (err error)

+ func (b *BufReader) Source() string

+ func (b *BufReader) Status() StatsInfo

+ func (b *BufReader) SyncMeta()

+ type CloudTrailReader struct

+ func (ctr *CloudTrailReader) Close() error

+ type CloudWatch struct

+ CacheTTL time.Duration

+ CollectInterval time.Duration

+ DataChan chan models.Data

+ Delay time.Duration

+ Metrics []*Metric

+ Namespace string

+ Period time.Duration

+ RateLimit int64

+ Region string

+ StopChan chan struct{}

+ func (c *CloudWatch) Close() error

+ func (c *CloudWatch) Gather() error

+ func (c *CloudWatch) Name() string

+ func (c *CloudWatch) ReadLine() (line string, err error)

+ func (c *CloudWatch) SetMode(mode string, v interface{}) error

+ func (c *CloudWatch) Source() string

+ func (c *CloudWatch) Start() error

+ func (c *CloudWatch) SyncMeta()

+ type CollectionFilter map[string]interface

+ type CredentialConfig struct

+ AccessKey string

+ Filename string

+ Profile string

+ Region string

+ RoleARN string

+ SecretKey string

+ Token string

+ func (c *CredentialConfig) Credentials() (client.ConfigProvider, error)

+ type Dimension struct

+ Name string

+ Value string

+ type ElasticReader struct

+ func (er *ElasticReader) Close() (err error)

+ func (er *ElasticReader) Name() string

+ func (er *ElasticReader) ReadLine() (data string, err error)

+ func (er *ElasticReader) SetMode(mode string, v interface{}) error

+ func (er *ElasticReader) Source() string

+ func (er *ElasticReader) Start()

+ func (er *ElasticReader) Status() StatsInfo

+ func (er *ElasticReader) SyncMeta()

+ type Field struct

+ Conversion string

+ IsTag bool

+ Name string

+ Oid string

+ OidIndexSuffix string

+ type FileReader interface

+ Close func() error

+ Name func() string

+ Read func(p []byte) (n int, err error)

+ Source func() string

+ SyncMeta func() error

+ type HttpReader struct

+ func (h *HttpReader) Close() error

+ func (h *HttpReader) Name() string

+ func (h *HttpReader) ReadLine() (data string, err error)

+ func (h *HttpReader) SetMode(mode string, v interface{}) error

+ func (h *HttpReader) Source() string

+ func (h *HttpReader) Start() error

+ func (h *HttpReader) SyncMeta()

+ type KafkaReader struct

+ Consumer *consumergroup.ConsumerGroup

+ ConsumerGroup string

+ Topics []string

+ Whence string

+ ZookeeperChroot string

+ ZookeeperPeers []string

+ ZookeeperTimeout time.Duration

+ func (kr *KafkaReader) Close() (err error)

+ func (kr *KafkaReader) Lag() (rl *LagInfo, err error)

+ func (kr *KafkaReader) Name() string

+ func (kr *KafkaReader) ReadLine() (data string, err error)

+ func (kr *KafkaReader) SetMode(mode string, v interface{}) error

+ func (kr *KafkaReader) Source() string

+ func (kr *KafkaReader) Start()

+ func (kr *KafkaReader) Status() StatsInfo

+ func (kr *KafkaReader) SyncMeta()

+ type LagReader interface

+ Lag func() (*LagInfo, error)

+ type LastSync struct

+ type Meta struct

+ RunnerName string

+ func NewMeta(metadir, filedonedir, logpath, mode, tagfile string, donefileRetention int) (m *Meta, err error)

+ func NewMetaWithConf(conf conf.MapConf) (meta *Meta, err error)

+ func (m *Meta) AppendDeleteFile(path string) (err error)

+ func (m *Meta) AppendDoneFile(path string) (err error)

+ func (m *Meta) BufFile() string

+ func (m *Meta) BufMetaFile() string

+ func (m *Meta) CacheLineFile() string

+ func (m *Meta) Clear() error

+ func (m *Meta) DeleteDoneFile(path string) error

+ func (m *Meta) DeleteFile() string

+ func (m *Meta) DoneFile() string

+ func (m *Meta) DoneFilePath() string

+ func (m *Meta) ExtraInfo() map[string]string

+ func (m *Meta) FtSaveLogPath() string

+ func (m *Meta) GetDataSourceTag() string

+ func (m *Meta) GetDoneFiles() (doneFiles []File, err error)

+ func (m *Meta) GetEncodingWay() (e string)

+ func (m *Meta) GetMode() string

+ func (m *Meta) GetTagFile() string

+ func (m *Meta) GetTags() map[string]interface{}

+ func (m *Meta) IsDoneFile(file string) bool

+ func (m *Meta) IsExist() bool

+ func (m *Meta) IsFileMode() bool

+ func (m *Meta) IsNotExist() bool

+ func (m *Meta) IsNotValid() bool

+ func (m *Meta) IsValid() bool

+ func (m *Meta) LogPath() string

+ func (m *Meta) MetaFile() string

+ func (m *Meta) ReadBuf(buf []byte) (n int, err error)

+ func (m *Meta) ReadBufMeta() (r, w, bufsize int, err error)

+ func (m *Meta) ReadCacheLine() ([]byte, error)

+ func (m *Meta) ReadOffset() (currFile string, offset int64, err error)

+ func (m *Meta) ReadStatistic() (stat Statistic, err error)

+ func (m *Meta) Reset() error

+ func (m *Meta) SetEncodingWay(e string)

+ func (m *Meta) StatisticFile() string

+ func (m *Meta) WriteBuf(buf []byte, r, w, bufsize int) (err error)

+ func (m *Meta) WriteCacheLine(lines string) error

+ func (m *Meta) WriteOffset(currFile string, offset int64) (err error)

+ func (m *Meta) WriteStatistic(stat *Statistic) error

+ type Metric struct

+ Dimensions []*Dimension

+ MetricNames []string

+ type MetricCache struct

+ Fetched time.Time

+ Metrics []*cloudwatch.Metric

+ TTL time.Duration

+ func (c *MetricCache) IsValid() bool

+ type MongoReader struct

+ Cron *cron.Cron

+ func (mr *MongoReader) Close() (err error)

+ func (mr *MongoReader) LoopRun()

+ func (mr *MongoReader) Name() string

+ func (mr *MongoReader) ReadLine() (data string, err error)

+ func (mr *MongoReader) SetMode(mode string, v interface{}) error

+ func (mr *MongoReader) Source() string

+ func (mr *MongoReader) Start()

+ func (mr *MongoReader) Status() StatsInfo

+ func (mr *MongoReader) SyncMeta()

+ type MultiReader struct

+ func (mr *MultiReader) Close() (err error)

+ func (mr *MultiReader) Expire()

+ func (mr *MultiReader) Lag() (rl *LagInfo, err error)

+ func (mr *MultiReader) Name() string

+ func (mr *MultiReader) ReadLine() (data string, err error)

+ func (mr *MultiReader) Reset() (err error)

+ func (mr *MultiReader) SetMode(mode string, value interface{}) (err error)

+ func (mr *MultiReader) Source() string

+ func (mr *MultiReader) Start()

+ func (mr *MultiReader) StatLogPath()

+ func (mr *MultiReader) Status() StatsInfo

+ func (mr *MultiReader) SyncMeta()

+ type NestedError struct

+ Err error

+ NestedErr error

+ func (ne NestedError) Error() string

+ type RTable struct

+ Name string

+ Rows []RTableRow

+ Time string

+ type RTableRow struct

+ Fields map[string]interface{}

+ Tags map[string]string

+ type Reader interface

+ Close func() error

+ Name func() string

+ ReadLine func() (string, error)

+ SetMode func(mode string, v interface{}) error

+ Source func() string

+ SyncMeta func()

+ func NewCloudTrailReader(meta *Meta, conf conf.MapConf) (Reader, error)

+ func NewCloudWatchReader(meta *Meta, conf conf.MapConf) (c Reader, err error)

+ func NewESReader(meta *Meta, conf conf.MapConf) (er Reader, err error)

+ func NewFileAutoReader(meta *Meta, conf conf.MapConf) (reader Reader, err error)

+ func NewFileBufReader(conf conf.MapConf, errDirectReturn bool) (reader Reader, err error)

+ func NewFileDirReader(meta *Meta, conf conf.MapConf) (reader Reader, err error)

+ func NewHttpReader(meta *Meta, conf conf.MapConf) (Reader, error)

+ func NewKafkaReader(meta *Meta, conf conf.MapConf) (kr Reader, err error)

+ func NewMongoReader(meta *Meta, conf conf.MapConf) (mr Reader, err error)

+ func NewMultiReader(meta *Meta, conf conf.MapConf) (mr Reader, err error)

+ func NewRedisReader(meta *Meta, conf conf.MapConf) (rr Reader, err error)

+ func NewSQLReader(meta *Meta, conf conf.MapConf) (ret Reader, err error)

+ func NewScriptReader(meta *Meta, conf conf.MapConf) (sr Reader, err error)

+ func NewSingleFileReader(meta *Meta, conf conf.MapConf) (reader Reader, err error)

+ func NewSnmpReader(meta *Meta, c conf.MapConf) (s Reader, err error)

+ func NewSocketReader(meta *Meta, conf conf.MapConf) (Reader, error)

+ type ReaderRegistry struct

+ func NewReaderRegistry() *ReaderRegistry

+ func (r *ReaderRegistry) NewReader(conf conf.MapConf, errDirectReturn bool) (reader Reader, err error)

+ func (r *ReaderRegistry) NewReaderWithMeta(conf conf.MapConf, meta *Meta, errDirectReturn bool) (reader Reader, err error)

+ func (registry *ReaderRegistry) RegisterReader(readerType string, constructor func(*Meta, conf.MapConf) (Reader, error)) error

+ type RedisOptionn struct

+ type RedisReader struct

+ func (rr *RedisReader) Close() (err error)

+ func (rr *RedisReader) Name() string

+ func (rr *RedisReader) ReadLine() (data string, err error)

+ func (rr *RedisReader) SetMode(mode string, v interface{}) error

+ func (rr *RedisReader) Source() string

+ func (rr *RedisReader) Start()

+ func (rr *RedisReader) Status() StatsInfo

+ func (rr *RedisReader) SyncMeta()

+ type Result struct

+ type ScriptReader struct

+ Cron *cron.Cron

+ func (sr *ScriptReader) Close() (err error)

+ func (sr *ScriptReader) LoopRun()

+ func (sr *ScriptReader) Name() string

+ func (sr *ScriptReader) ReadLine() (data string, err error)

+ func (sr *ScriptReader) SetMode(mode string, v interface{}) error

+ func (sr *ScriptReader) Source() string

+ func (sr *ScriptReader) Start()

+ func (sr *ScriptReader) SyncMeta()

+ type SeqFile struct

+ func NewSeqFile(meta *Meta, path string, ignoreHidden, newFileNewLine bool, suffixes []string, ...) (sf *SeqFile, err error)

+ func (sf *SeqFile) Close() (err error)

+ func (sf *SeqFile) Lag() (rl *LagInfo, err error)

+ func (sf *SeqFile) Name() string

+ func (sf *SeqFile) Read(p []byte) (n int, err error)

+ func (sf *SeqFile) Source() string

+ func (sf *SeqFile) SyncMeta() (err error)

+ type ServerReader interface

+ Close func() error

+ Name func() string

+ ReadLine func() (string, error)

+ Source func() string

+ Start func()

+ SyncMeta func()

+ type SingleFile struct

+ func NewSingleFile(meta *Meta, path, whence string, errDirectReturn bool) (sf *SingleFile, err error)

+ func (sf *SingleFile) Close() (err error)

+ func (sf *SingleFile) Lag() (rl *LagInfo, err error)

+ func (sf *SingleFile) Name() string

+ func (sf *SingleFile) Read(p []byte) (n int, err error)

+ func (sf *SingleFile) Reopen() (err error)

+ func (sf *SingleFile) Source() string

+ func (sf *SingleFile) SyncMeta() error

+ type SnmpReader struct

+ Agents []string

+ AuthPassword string

+ AuthProtocol string

+ Community string

+ ConnectionCache []snmpConnection

+ ContextName string

+ DataChan chan interface{}

+ EngineBoots uint32

+ EngineID string

+ EngineTime uint32

+ Fields []Field

+ Interval time.Duration

+ MaxRepetitions uint8

+ Meta *Meta

+ PrivPassword string

+ PrivProtocol string

+ Retries int

+ SecLevel string

+ SecName string

+ SnmpName string

+ Status int32

+ StopChan chan struct{}

+ Tables []Table

+ Timeout time.Duration

+ Version uint8

+ func (s *SnmpReader) Close() error

+ func (s *SnmpReader) Gather() (err error)

+ func (s *SnmpReader) Name() string

+ func (s *SnmpReader) ReadLine() (line string, err error)

+ func (s *SnmpReader) SetMode(mode string, v interface{}) error

+ func (s *SnmpReader) Source() string

+ func (s *SnmpReader) Start() error

+ func (s *SnmpReader) StoreData(data []map[string]interface{}) (err error)

+ func (s *SnmpReader) SyncMeta()

+ type SocketReader struct

+ Closer io.Closer

+ KeepAlivePeriod time.Duration

+ MaxConnections int

+ ReadBufferSize int

+ ReadChan chan string

+ ReadTimeout time.Duration

+ ServiceAddress string

+ func (sr *SocketReader) Close() (err error)

+ func (sr *SocketReader) Name() string

+ func (sr *SocketReader) ReadLine() (data string, err error)

+ func (sr *SocketReader) SetMode(mode string, v interface{}) error

+ func (sr *SocketReader) Source() string

+ func (sr *SocketReader) Start() error

+ func (sr *SocketReader) SyncMeta()

+ type SqlReader struct

+ Cron *cron.Cron

+ func (mr *SqlReader) Close() (err error)

+ func (mr *SqlReader) LoopRun()

+ func (mr *SqlReader) Name() string

+ func (mr *SqlReader) ReadLine() (data string, err error)

+ func (mr *SqlReader) SetMode(mode string, v interface{}) error

+ func (mr *SqlReader) Source() string

+ func (mr *SqlReader) Start()

+ func (mr *SqlReader) Status() StatsInfo

+ func (mr *SqlReader) SyncMeta()

+ type Statistic struct

+ ParserCnt [2]int64

+ ReaderCnt int64

+ SenderCnt map[string][2]int64

+ type StatsReader interface

+ Name func() string

+ Status func() StatsInfo

+ type Table struct

+ Fields []Field

+ IndexAsTag bool

+ InheritTags []string

+ Name string

+ Oid string

+ func (t Table) Build(gs snmpConnection, walk bool) (*RTable, error)