crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
88ec14b1
ROOT
/
go
/
libraries
/
doltcore
/
diff
/
async_differ.go
Search
History
302 lines
|
ISO-8859-1
|
8 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
NewRowDiffer
(ctx context.Context, format *types.NomsBinFormat, fromSch, toSch schema.Schema, buf int)
:
RowDiffer
AsyncDiffer
diffChan
:
chan diff.Difference
bufferSize
:
int
eg
:
*errgroup.Group
egCtx
:
context.Context
egCancel
:
func()
diffStats
:
map[types.DiffChangeType]uint64
_
:
RowDiffer
NewAsyncDiffer
(bufferedDiffs int)
:
*AsyncDiffer
tableDontDescendLists
(v1, v2 types.Value)
:
bool
forever
:
<-chan time.Time
diffPredicate
alwaysTruePredicate
:
diffPredicate
hasChangeTypePredicate
(changeType types.DiffChangeType)
:
diffPredicate
keylessDiffer
AsyncDiffer
df
:
diff.Difference
copiesLeft
:
uint64
_
:
RowDiffer
convertDiff
(df diff.Difference)
:
(diff.Difference, uint64, error)
EmptyRowDiffer
Start
(ctx context.Context, from, to types.Map)
StartWithRange
(ctx context.Context, from, to types.Map, start types.Value, inRange types.ValueInRange)
GetDiffs
(numDiffs int, timeout time.Duration)
:
([]*diff.Difference, bool, error)
GetDiffsWithFilter
(numDiffs int, timeout time.Duration, filterByChangeType types.DiffChangeType)
:
([]*diff.Difference, bool, error)
Close
()
:
error
_
:
RowDiffer
*AsyncDiffer
Start
(ctx context.Context, from, to types.Map)
StartWithRange
(ctx context.Context, from, to types.Map, start types.Value, inRange types.ValueInRange)
start
(ctx context.Context, diffFunc func(ctx context.Context) error)
Close
()
:
error
getDiffs
(numDiffs int, timeoutChan <-chan time.Time, pred diffPredicate)
:
([]*diff.Difference, bool, error)
GetDiffs
(numDiffs int, timeout time.Duration)
:
([]*diff.Difference, bool, error)
GetDiffsWithFilter
(numDiffs int, timeout time.Duration, filterByChangeType types.DiffChangeType)
:
([]*diff.Difference, bool, error)
GetDiffsWithoutTimeoutWithFilter
(numDiffs int, filterByChangeType types.DiffChangeType)
:
([]*diff.Difference, bool, error)
GetDiffsWithoutTimeout
(numDiffs int)
:
([]*diff.Difference, bool, error)
*keylessDiffer
getDiffs
(numDiffs int, timeoutChan <-chan time.Time, pred diffPredicate)
:
([]*diff.Difference, bool, error)
GetDiffs
(numDiffs int, timeout time.Duration)
:
([]*diff.Difference, bool, error)
GetDiffsWithFilter
(numDiffs int, timeout time.Duration, filterByChangeType types.DiffChangeType)
:
([]*diff.Difference, bool, error)
All occurrences
Please wait...
Page is in error, reload to recover