MCPcopy
hub / github.com/cubefs/cubefs / GetShard

Method GetShard

blobstore/blobnode/client/blobnode_cli.go:36–36  ·  view source on GitHub ↗
(ctx context.Context, location proto.VunitLocation, bid proto.BlobID, ioType api.IOType)

Source from the content-addressed store, hash-verified

34 StatShard(ctx context.Context, location proto.VunitLocation, bid proto.BlobID) (si *ShardInfo, err error)
35 ListShards(ctx context.Context, location proto.VunitLocation) (shards []*ShardInfo, err error)
36 GetShard(ctx context.Context, location proto.VunitLocation, bid proto.BlobID, ioType api.IOType) (body io.ReadCloser, crc32 uint32, err error)
37 PutShard(ctx context.Context, location proto.VunitLocation, bid proto.BlobID, size int64, body io.Reader, ioType api.IOType) (err error)
38}
39

Callers 7

TestMigrateExecTaskletFunction · 0.65
downloadShardMethod · 0.65
testDirectGetShardFunction · 0.65
TestDownloadFunction · 0.65
MigrateBidsFunction · 0.65
TestShardRangeGetFunction · 0.65
GetShardMethod · 0.65

Implementers 6

clientblobstore/api/blobnode/client.go
MockStorageAPIblobstore/testing/mocks/api_blobnode.g
MockStorageAPIMockRecorderblobstore/testing/mocks/api_blobnode.g
MockGetterblobstore/blobnode/worker_for_test.go
mBlobNodeCliblobstore/blobnode/worker_service_test
BlobNodeClientblobstore/blobnode/client/blobnode_cli

Calls

no outgoing calls

Tested by 4

TestMigrateExecTaskletFunction · 0.52
testDirectGetShardFunction · 0.52
TestDownloadFunction · 0.52
TestShardRangeGetFunction · 0.52