Documentation
¶
Index ¶
- Constants
- type CompareRangesResult
- type CompareRangesWorkItem
- type LeafHashResult
- type MerkleTreeTask
- func (m *MerkleTreeTask) BuildMtree() (err error)
- func (m *MerkleTreeTask) CompareRanges(workItems []CompareRangesWorkItem)
- func (m *MerkleTreeTask) DiffMtree() (err error)
- func (m *MerkleTreeTask) GetClusterName() string
- func (m *MerkleTreeTask) GetClusterNodes() []map[string]any
- func (m *MerkleTreeTask) GetDBName() string
- func (m *MerkleTreeTask) GetNode(nodeName string) (map[string]interface{}, error)
- func (m *MerkleTreeTask) GetNodeList() []string
- func (m *MerkleTreeTask) GetNodes() string
- func (m *MerkleTreeTask) MtreeInit() (err error)
- func (m *MerkleTreeTask) MtreeTeardown() (err error)
- func (m *MerkleTreeTask) MtreeTeardownTable() (err error)
- func (m *MerkleTreeTask) RunChecks(skipValidation bool) error
- func (m *MerkleTreeTask) SetClusterNodes(cn []map[string]any)
- func (m *MerkleTreeTask) SetDBName(name string)
- func (m *MerkleTreeTask) SetDatabase(db types.Database)
- func (m *MerkleTreeTask) SetNodeList(nl []string)
- func (m *MerkleTreeTask) UpdateMtree(skipAllChecks bool) (err error)
- func (m *MerkleTreeTask) Validate() error
Constants ¶
View Source
const (
TempOffset = 1000000
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompareRangesResult ¶
type CompareRangesWorkItem ¶
type LeafHashResult ¶
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
Click to show internal directories.
Click to hide internal directories.