internal

README

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)

Documentation

Index

• Constants
• Variables
• func Log(ctx context.Context, level slog.Level, msg string, args ...interface{})
• func LookupPrefix(ctx context.Context, all config.T, prefix string) (context.Context, config.Prefix, error)
• func OpenDatabase(ctx context.Context, cfg config.Prefix, readonly bool) (database.DB, error)
• func OpenPrefixAndDatabase(ctx context.Context, all config.T, prefix string, readonly bool) (context.Context, config.Prefix, database.DB, error)
• func PrefixInfoAsFSInfo(pi prefixinfo.T, name string) fs.FileInfo
• func UseBadgerDB()
• type ScanDB
  • func NewScanDB(ctx context.Context, cfg config.Prefix) (ScanDB, error)
• type TimeRangeFlags
  • func (tr *TimeRangeFlags) FromTo() (from, to time.Time, set bool, err error)

Constants

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

Variables

var (
	Verbosity = LogError
	LogDir    string
)

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
}

func NewScanDB

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"`
}

func (*TimeRangeFlags) FromTo

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