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
e7321e3c
ROOT
/
go
/
store
/
nbs
/
aws_table_persister.go
Search
History
581 lines
|
ISO-8859-1
|
17 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
minS3PartSize
maxS3PartSize
maxS3Parts
maxDynamoChunks
maxDynamoItemSize
defaultS3PartSize
awsTablePersister
s3
:
s3svc
bucket
:
string
rl
:
chan struct{}
ddb
:
*ddbTableStore
limits
:
awsLimits
ns
:
string
q
:
MemoryQuotaProvider
Open
(ctx context.Context, name addr, chunkCount uint32, stats *Stats)
:
(chunkSource, error)
Exists
(ctx context.Context, name addr, chunkCount uint32, stats *Stats)
:
(bool, error)
key
(k string)
:
string
Persist
(ctx context.Context, mt *memTable, haver chunkReader, stats *Stats)
:
(chunkSource, error)
multipartUpload
(ctx context.Context, data []byte, key string)
:
error
startMultipartUpload
(ctx context.Context, key string)
:
(string, error)
abortMultipartUpload
(ctx context.Context, key, uploadID string)
:
error
completeMultipartUpload
(ctx context.Context, key, uploadID string, mpu *s3.CompletedMultipartUpload)
:
error
uploadParts
(ctx context.Context, data []byte, key, uploadID string)
:
(*s3.CompletedMultipartUpload, error)
ConjoinAll
(ctx context.Context, sources chunkSources, stats *Stats)
:
(chunkSource, error)
executeCompactionPlan
(ctx context.Context, plan compactionPlan, key string)
:
error
assembleTable
(ctx context.Context, plan compactionPlan, key, uploadID string)
:
(*s3.CompletedMultipartUpload, error)
uploadPartCopy
(ctx context.Context, src string, srcStart, srcEnd int64, key, uploadID string, partNum int64)
:
(etag string, err error)
uploadPart
(ctx context.Context, data []byte, key, uploadID string, partNum int64)
:
(etag string, err error)
PruneTableFiles
(ctx context.Context, contents manifestContents, t time.Time)
:
error
awsLimits
partTarget
:
uint64
partMin
:
uint64
partMax
:
uint64
itemMax
:
int
chunkMax
:
uint32
tableFitsInDynamo
(name addr, dataLen int, chunkCount uint32)
:
bool
tableMayBeInDynamo
(chunkCount uint32)
:
bool
s3UploadedPart
idx
:
int64
etag
:
string
getNumParts
(dataLen, minPartSize uint64)
:
uint64
partsByPartNum
Len
()
:
int
Less
(i, j int)
:
bool
Swap
(i, j int)
copyPart
name
:
string
srcOffset
:
int64
srcLen
:
int64
manualPart
srcR
:
io.Reader
dstStart
:
int64
dstEnd
:
int64
dividePlan
(ctx context.Context, plan compactionPlan, minPartSize, maxPartSize uint64)
:
(copies []copyPart, manuals []manualPart, buff []byte, err error)
splitOnMaxSize
(dataLen, maxPartSize uint64)
:
[]int64
All occurrences
Please wait...
Page is in error, reload to recover
