wal

Documentation

Index

• func ValidateConfig(c *Config) error
• type Config
• type WAL
  • func New(c *Config) (*WAL, error)
  • func (w *WAL) ClearFolder(dir string) error
  • func (w *WAL) GetFilepath() string
  • func (w *WAL) LocalBackend() *local.Backend
  • func (w *WAL) NewBlock(id uuid.UUID, tenantID string, dataEncoding string) (common.WALBlock, error)
  • func (w *WAL) RescanBlocks(additionalStartSlack time.Duration, log log.Logger) ([]common.WALBlock, error)

Functions

func ValidateConfig

func ValidateConfig(c *Config) error

Types

type Config

type Config struct {
	Filepath          string `yaml:"path"`
	CompletedFilepath string
	BlocksFilepath    string
	Encoding          backend.Encoding `yaml:"v2_encoding"`
	SearchEncoding    backend.Encoding `yaml:"search_encoding"`
	IngestionSlack    time.Duration    `yaml:"ingestion_time_range_slack"`
	Version           string           `yaml:"version,omitempty"`
}

type WAL

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

func New

func New(c *Config) (*WAL, error)

func (*WAL) ClearFolder

func (w *WAL) ClearFolder(dir string) error

func (*WAL) GetFilepath

func (w *WAL) GetFilepath() string

func (*WAL) LocalBackend

func (w *WAL) LocalBackend() *local.Backend

func (*WAL) NewBlock

func (w *WAL) NewBlock(id uuid.UUID, tenantID string, dataEncoding string) (common.WALBlock, error)

func (*WAL) RescanBlocks

func (w *WAL) RescanBlocks(additionalStartSlack time.Duration, log log.Logger) ([]common.WALBlock, error)

RescanBlocks returns a slice of append blocks from the wal folder