csv_backend

Documentation

Index

• Constants
• func NewSnapshotReader(baseFs afero.Fs, logger *zerolog.Logger) (workers.SnapshotReader, error)
• func NewSnapshotWriter(baseFs afero.Fs, inChan chan common.Snapshot, saveEvents bool) workers.SnapshotWriter

Constants

const (
	EventsBasePath    = "events"
	EventsFileMatchRe = `^(\w+)\/(.*?)\/(\d{4})\/(\d{2})\/(\d{2})\/([A-Z]+-[A-Z]+)\.csv\.gz$`
)

Functions

func NewSnapshotReader

func NewSnapshotReader(baseFs afero.Fs, logger *zerolog.Logger) (workers.SnapshotReader, error)

func NewSnapshotWriter

func NewSnapshotWriter(baseFs afero.Fs, inChan chan common.Snapshot, saveEvents bool) workers.SnapshotWriter