MCPcopy
hub / github.com/cubefs/cubefs / IBlobNode

Interface IBlobNode

blobstore/blobnode/client/blobnode_cli.go:32–38  ·  view source on GitHub ↗

IBlobNode define the interface of blobnode used for worker

Source from the content-addressed store, hash-verified

30
31// IBlobNode define the interface of blobnode used for worker
32type IBlobNode interface {
33 StatChunk(ctx context.Context, location proto.VunitLocation) (ci *ChunkInfo, err error)
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
40// BlobNodeClient blobnode client
41type BlobNodeClient struct {

Callers 22

TestSetChunkStatusFunction · 0.65
getChunksStatFunction · 0.65
StatChunkMethod · 0.65
TestShardDeleteFunction · 0.65
listShardsInfoMethod · 0.65
StatShardMethod · 0.65
ListShardsMethod · 0.65
TestMigrateExecTaskletFunction · 0.65
downloadShardMethod · 0.65
testDirectGetShardFunction · 0.65
TestDownloadFunction · 0.65
MigrateBidsFunction · 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

no test coverage detected