mtree

package
v1.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 30, 2025 License: PostgreSQL Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TempOffset = 1000000
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CompareRangesResult

type CompareRangesResult struct {
	Diffs     map[string]map[string][]map[string]any
	TotalDiff int
	Err       error
}

type CompareRangesWorkItem

type CompareRangesWorkItem struct {
	Node1  map[string]any
	Node2  map[string]any
	Ranges [][2][]any
}

type LeafHashResult

type LeafHashResult struct {
	BlockID int64
	Hash    []byte
	Err     error
}

type MerkleTreeTask

type MerkleTreeTask struct {
	types.Task
	types.DerivedFields

	QualifiedTableName string
	DBName             string
	Nodes              string
	ClientRole         string
	InvokeMethod       string

	Analyse           bool
	Rebalance         bool
	RecreateObjects   bool // TBD
	BlockSize         int
	MaxCpuRatio       float64
	BatchSize         int
	Output            string
	QuietMode         bool
	RangesFile        string
	WriteRanges       bool
	OverrideBlockSize bool
	Mode              string
	NoCDC             bool
	SkipDBUpdate      bool

	TaskStore     *taskstore.Store
	TaskStorePath string

	DiffResult types.DiffOutput

	StartTime      time.Time
	SpockNodeNames map[string]string

	Ctx context.Context
	// contains filtered or unexported fields
}

func NewMerkleTreeTask

func NewMerkleTreeTask() *MerkleTreeTask

func (*MerkleTreeTask) BuildMtree

func (m *MerkleTreeTask) BuildMtree() (err error)

func (*MerkleTreeTask) CompareRanges

func (m *MerkleTreeTask) CompareRanges(workItems []CompareRangesWorkItem)

func (*MerkleTreeTask) DiffMtree

func (m *MerkleTreeTask) DiffMtree() (err error)

func (*MerkleTreeTask) GetClusterName

func (m *MerkleTreeTask) GetClusterName() string

func (*MerkleTreeTask) GetClusterNodes

func (m *MerkleTreeTask) GetClusterNodes() []map[string]any

func (*MerkleTreeTask) GetDBName

func (m *MerkleTreeTask) GetDBName() string

func (*MerkleTreeTask) GetNode

func (m *MerkleTreeTask) GetNode(nodeName string) (map[string]interface{}, error)

func (*MerkleTreeTask) GetNodeList

func (m *MerkleTreeTask) GetNodeList() []string

func (*MerkleTreeTask) GetNodes

func (m *MerkleTreeTask) GetNodes() string

func (*MerkleTreeTask) MtreeInit

func (m *MerkleTreeTask) MtreeInit() (err error)

func (*MerkleTreeTask) MtreeTeardown

func (m *MerkleTreeTask) MtreeTeardown() (err error)

func (*MerkleTreeTask) MtreeTeardownTable

func (m *MerkleTreeTask) MtreeTeardownTable() (err error)

func (*MerkleTreeTask) RunChecks

func (m *MerkleTreeTask) RunChecks(skipValidation bool) error

func (*MerkleTreeTask) SetClusterNodes

func (m *MerkleTreeTask) SetClusterNodes(cn []map[string]any)

func (*MerkleTreeTask) SetDBName

func (m *MerkleTreeTask) SetDBName(name string)

func (*MerkleTreeTask) SetDatabase

func (m *MerkleTreeTask) SetDatabase(db types.Database)

func (*MerkleTreeTask) SetNodeList

func (m *MerkleTreeTask) SetNodeList(nl []string)

func (*MerkleTreeTask) UpdateMtree

func (m *MerkleTreeTask) UpdateMtree(skipAllChecks bool) (err error)

func (*MerkleTreeTask) Validate

func (m *MerkleTreeTask) Validate() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL