store

Documentation

Index

• func NewLoader(lg *zap.Logger, cfg LoaderCfg) *loader
• func NewWriter(cfg WriterCfg) *writer
• type LoaderCfg
• type Meta
  • func NewMeta(duration time.Duration, cmds, filteredCmds uint64) *Meta
  • func (m *Meta) Read(path string) error
  • func (m *Meta) Write(path string) error
• type Writer
• type WriterCfg

Functions

func NewLoader

func NewLoader(lg *zap.Logger, cfg LoaderCfg) *loader

func NewWriter

func NewWriter(cfg WriterCfg) *writer

Types

type LoaderCfg

type LoaderCfg struct {
	Dir string
}

type Meta

type Meta struct {
	Version      string
	Duration     time.Duration
	Cmds         uint64
	FilteredCmds uint64
}

func NewMeta

func NewMeta(duration time.Duration, cmds, filteredCmds uint64) *Meta

func (*Meta) Read

func (m *Meta) Read(path string) error

func (*Meta) Write

func (m *Meta) Write(path string) error

type Writer

type Writer interface {
	Write([]byte) error
	Close() error
}

type WriterCfg

type WriterCfg struct {
	Dir      string
	FileSize int
}