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
98120eb3
ROOT
/
go
/
store
/
datas
/
pull
/
pull_test.go
Search
History
650 lines
|
ISO-8859-1
|
19 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
datasetID
TestLocalToLocalPulls
(t *testing.T)
TestRemoteToLocalPulls
(t *testing.T)
TestLocalToRemotePulls
(t *testing.T)
TestRemoteToRemotePulls
(t *testing.T)
PullSuite
suite.Suite
sinkCS
:
*chunks.TestStoreView
sourceCS
:
*chunks.TestStoreView
sinkVRW
:
types.ValueReadWriter
sourceVRW
:
types.ValueReadWriter
sinkDB
:
datas.Database
sourceDB
:
datas.Database
commitReads
:
int
makeTestStoreViews
()
:
(ts1, ts2 *chunks.TestStoreView)
LocalToLocalSuite
PullSuite
RemoteToLocalSuite
PullSuite
LocalToRemoteSuite
PullSuite
RemoteToRemoteSuite
PullSuite
progressTracker
Ch
:
chan PullProgress
doneCh
:
chan []PullProgress
startProgressTracker
()
:
*progressTracker
buildListOfHeight
(height int, vrw types.ValueReadWriter)
:
types.List
TestFailingTableFile
fileID
:
string
numChunks
:
int
TestTableFile
fileID
:
string
numChunks
:
int
data
:
[]byte
TestTableFileWriter
fileID
:
string
numChunks
:
int
writer
:
*bytes.Buffer
ttfs
:
*TestTableFileStore
TestTableFileStore
root
:
hash.Hash
tableFiles
:
map[string]*TestTableFile
mu
:
sync.Mutex
_
:
nbs.TableFileStore
FlakeyTestTableFileStore
TestTableFileStore
GoodNow
:
bool
TestClone
(t *testing.T)
mustList
(l types.List, err error)
:
types.List
mustValue
(val types.Value, err error)
:
types.Value
mustGetCommittedValue
(vr types.ValueReader, c types.Value)
:
types.Value
mustGetValue
(v types.Value, found bool, err error)
:
types.Value
mustRef
(ref types.Ref, err error)
:
types.Ref
mustHeadAddr
(ds datas.Dataset)
:
hash.Hash
*LocalToLocalSuite
SetupTest
()
*RemoteToLocalSuite
SetupTest
()
*LocalToRemoteSuite
SetupTest
()
*RemoteToRemoteSuite
SetupTest
()
*PullSuite
TearDownTest
()
TestPullEverything
()
TestPullMultiGeneration
()
TestPullDivergentHistory
()
TestPullUpdates
()
commitToSource
(v types.Value, p []hash.Hash)
:
hash.Hash
commitToSink
(v types.Value, p []hash.Hash)
:
hash.Hash
*progressTracker
Validate
(suite *PullSuite)
*TestFailingTableFile
FileID
()
:
string
NumChunks
()
:
int
Open
(ctx context.Context)
:
(io.ReadCloser, uint64, error)
*TestTableFile
FileID
()
:
string
NumChunks
()
:
int
Open
(ctx context.Context)
:
(io.ReadCloser, uint64, error)
*TestTableFileWriter
Write
(data []byte)
:
(int, error)
Close
(ctx context.Context)
:
error
*TestTableFileStore
Sources
(ctx context.Context)
:
(hash.Hash, []nbs.TableFile, []nbs.TableFile, error)
Size
(ctx context.Context)
:
(uint64, error)
WriteTableFile
(ctx context.Context, fileId string, numChunks int, contentHash []byte, getRd func() (io.ReadCloser, uint64, error))
:
error
AddTableFilesToManifest
(ctx context.Context, fileIdToNumChunks map[string]int)
:
error
SetRootChunk
(ctx context.Context, root, previous hash.Hash)
:
error
SupportedOperations
()
:
nbs.TableFileStoreOps
PruneTableFiles
(ctx context.Context)
:
error
OnlinePruneTableFiles
(ctx context.Context)
:
error
*FlakeyTestTableFileStore
Sources
(ctx context.Context)
:
(hash.Hash, []nbs.TableFile, []nbs.TableFile, error)
All occurrences
Please wait...
Page is in error, reload to recover
