dbutils

Documentation

Index

• Constants
• func FormatMemStats(memstats runtime.MemStats) string
• func IsRetrieableCheckpoint(err error) bool
• func MakeDefaultSmallPool(name string) *containers.VectorPool
• func MakeDefaultTransientPool(name string) *containers.VectorPool
• func MakeLockFileName(dirname string, name string) string
• func PrintMemStats()
• type Runtime
  • func NewRuntime(opts ...RuntimeOption) *Runtime
  • func (r *Runtime) ExportLogtailStats() string
  • func (r *Runtime) PrintVectorPoolUsage()
• type RuntimeOption
  • func WithRuntimeObjectFS(fs *objectio.ObjectFS) RuntimeOption
  • func WithRuntimeOptions(opts *options.Options) RuntimeOption
  • func WithRuntimeScheduler(s tasks.TaskScheduler) RuntimeOption
  • func WithRuntimeSmallPool(vp *containers.VectorPool) RuntimeOption
  • func WithRuntimeTransferTable(tt *model.HashPageTable) RuntimeOption
  • func WithRuntimeTransientPool(vp *containers.VectorPool) RuntimeOption

Constants

const LockSuffix = ".lock"

Functions

func FormatMemStats

func FormatMemStats(memstats runtime.MemStats) string

func IsRetrieableCheckpoint

func IsRetrieableCheckpoint(err error) bool

func MakeDefaultSmallPool

func MakeDefaultSmallPool(name string) *containers.VectorPool

func MakeDefaultTransientPool

func MakeDefaultTransientPool(name string) *containers.VectorPool

func MakeLockFileName

func MakeLockFileName(dirname string, name string) string

func PrintMemStats

func PrintMemStats()

Types

type Runtime

type Runtime struct {
	Now        func() types.TS
	VectorPool struct {
		Small     *containers.VectorPool
		Transient *containers.VectorPool
	}

	Fs *objectio.ObjectFS

	TransferTable   *model.HashPageTable
	TransferDelsMap *model.TransDelsForBlks
	Scheduler       tasks.TaskScheduler

	Options *options.Options

	Logtail struct {
		CompactStats stats.Counter
	}
}

func NewRuntime

func NewRuntime(opts ...RuntimeOption) *Runtime

func (*Runtime) ExportLogtailStats

func (r *Runtime) ExportLogtailStats() string

func (*Runtime) PrintVectorPoolUsage

func (r *Runtime) PrintVectorPoolUsage()

type RuntimeOption

type RuntimeOption func(*Runtime)

func WithRuntimeObjectFS

func WithRuntimeObjectFS(fs *objectio.ObjectFS) RuntimeOption

func WithRuntimeOptions

func WithRuntimeOptions(opts *options.Options) RuntimeOption

func WithRuntimeScheduler

func WithRuntimeScheduler(s tasks.TaskScheduler) RuntimeOption

func WithRuntimeSmallPool

func WithRuntimeSmallPool(vp *containers.VectorPool) RuntimeOption

func WithRuntimeTransferTable

func WithRuntimeTransferTable(tt *model.HashPageTable) RuntimeOption

func WithRuntimeTransientPool

func WithRuntimeTransientPool(vp *containers.VectorPool) RuntimeOption