internal

Package cloudeng.io/cmd/idu/internal

import cloudeng.io/cmd/idu/internal

Constants

LogPrefix, LogProgress, LogError

LogPrefix = slog.Level(-1)
LogProgress = slog.LevelInfo
LogError = slog.LevelError

Variables

LogDir

LogDir string

Verbosity

Verbosity slog.Level = LogError

Functions

Func Log

func Log(ctx context.Context, level slog.Level, msg string, args ...interface{})

Func LookupPrefix

func LookupPrefix(ctx context.Context, all config.T, prefix string) (context.Context, config.Prefix, error)

Func OpenDatabase

func OpenDatabase(ctx context.Context, cfg config.Prefix, readonly bool) (database.DB, error)

Func OpenPrefixAndDatabase

func OpenPrefixAndDatabase(ctx context.Context, all config.T, prefix string, readonly bool) (context.Context, config.Prefix, database.DB, error)

Func PrefixInfoAsFSInfo

func PrefixInfoAsFSInfo(pi prefixinfo.T, name string) fs.FileInfo

PrefixInfoAsFSInfo returns a fs.FileInfo for the supplied PrefixInfo.

Func UseBadgerDB

func UseBadgerDB()

Types

Type ScanDB

type ScanDB interface {
	GetPrefixInfo(ctx context.Context, key string, pi *prefixinfo.T) (bool, error)
	SetPrefixInfo(ctx context.Context, key string, unchanged bool, pi *prefixinfo.T) error
	LogError(ctx context.Context, key string, when time.Time, detail []byte) error
	LogAndClose(ctx context.Context, start, stop time.Time, detail []byte) error
	DeletePrefix(ctx context.Context, prefix string) error
	DeleteErrors(ctx context.Context, prefix string) error
	Close(ctx context.Context) error
}

Functions

func NewScanDB(ctx context.Context, cfg config.Prefix) (ScanDB, error)

Type TimeRangeFlags

type TimeRangeFlags struct {
	Since time.Duration `subcmd:"since,0s,'display entries since the specified duration, it takes precedence over from/to'"`
	From  flags.Time    `subcmd:"from,,display entries starting at this time/date"`
	To    flags.Time    `subcmd:"to,,display entries ending at this time/date"`
}

Methods

func (tr *TimeRangeFlags) FromTo() (from, to time.Time, set bool, err error)