Versions in this module Expand all Collapse all v1 v1.5.0 Aug 4, 2023 Changes in this version + const DeleteByIdOpt + const DeleteByJobUidOpt + const DriverBadger + const DriverSqlite + const TimeFormatPattern + const UpdateNameByJobWatchIdOpt + const UpsertOffsetByJobWatchIdOpt + func SetConfig(dbConfig DbConfig) + func StopDbHandler() + type DbConfig struct + BufferSize int + CleanInactiveTimeout time.Duration + CleanScanInterval time.Duration + File string + FlushTimeout time.Duration + func GetConfig() DbConfig + func (d *DbConfig) SetDefaults() + type DbHandler struct + State chan *State + func GetOrCreateShareDbHandler() *DbHandler + func NewDbHandler(config DbConfig) *DbHandler + func (d *DbHandler) FindAll() []reg.Registry + func (d *DbHandler) FindBy(jobUid string, sourceName string, pipelineName string) reg.Registry + func (d *DbHandler) HandleOpt(opt DbOpt) + func (d *DbHandler) Stop() + func (d *DbHandler) String() string + type DbOpt struct + Immediately bool + OptType DbOptType + R reg.Registry + type DbOptType int + type State struct + CollectTime time.Time + ContentBytes int64 + Epoch *pipeline.Epoch + EventUid string + Filename string + JobFields map[string]interface{} + JobIndex uint32 + JobUid string + LineNumber int64 + NextOffset int64 + Offset int64 + PipelineName string + SourceName string + Tags string + WatchUid string + func (s *State) AppendTags(tag string) v1.5.0-rc.0 Jul 13, 2023
Go to main page