file

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2020 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

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