file

Documentation

Index

• type Config
  • func (c *Config) ConfigValidate() error
• type FileCache
  • func NewFileCache(c *Config) (f *FileCache, err error)
  • func (f *FileCache) ReadFromCache() (e *event.ProcessorEvent)
  • func (f *FileCache) WriteToCache(e *event.ProcessorEvent)
• type Index

Types

type Config

type Config struct {
	CacheFlushInterval xtime.Duration `tome:"cacheFlushInterval"`
	WriteBuffer        int            `tome:"writeBuffer"`
	Storage            string         `tome:"storage"`
	StorageMaxMB       int            `tome:"storageMaxMB"`
	FileBytes          int            `tome:"fileBytes"`
	Suffix             string         `tome:"suffix"`
	ReadBuffer         int            `tome:"readBuffer"`
	Index              string         `tome:"index"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type FileCache

type FileCache struct {
	// contains filtered or unexported fields
}

func NewFileCache

func NewFileCache(c *Config) (f *FileCache, err error)

func (*FileCache) ReadFromCache

func (f *FileCache) ReadFromCache() (e *event.ProcessorEvent)

func (*FileCache) WriteToCache

func (f *FileCache) WriteToCache(e *event.ProcessorEvent)

type Index

type Index struct {
	Name    string `json:"name"`
	Offset  int64  `json:"offset"`
	Updated string `json:"updated"`
}

Index index.