dbtracker

package

v1.6.2 Latest Latest Go to latest Published: Apr 10, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

View Source

const (
	TrackMinInterval = 60 * time.Second
	TopTablesN       = 20
)

This section is empty.

This section is empty.

type ChangeEmitter interface {
	Emit(change schema.Change, dbSystem, targetAddr string)
}

type CollectFunc func(ctx context.Context) (schema.Snapshot, map[string]*DBSizeSnapshot, error)

type DBSizeSnapshot struct {
	DatabaseSize float64
	Tables       []TableSizeEntry
}

type TableGrowthEntry struct {
	schema.TableKey
	Growth float64
}

type TableSizeEntry struct {
	schema.TableKey
	Size float64
}

type Tracker struct {
	DBSizes map[string]*DBSizeSnapshot

	TableGrowth []TableGrowthEntry
	// contains filtered or unexported fields
}

func NewTracker(dbSystem string, trackSchema, trackSizes bool, collect CollectFunc, logger logger.Logger) *Tracker

func (t *Tracker) Track(ctx context.Context, emitter ChangeEmitter, targetAddr string)