MCPcopy Create free account

hub / github.com/MilenMT/torus / functions

Functions1,324 in github.com/MilenMT/torus

⨍ Functions 1,324◇ Types & classes 158
↓ 136 callersMethodIntn
(n int)
models/rpc.pb.go:1071
↓ 97 callersMethodSize
()
internal/nbd/nbd.go:78
↓ 89 callersMethodEqual
(that interface{})
models/torus.pb.go:827
↓ 89 callersMethodMarshal
()
ring.go:19
↓ 85 callersMethodUnmarshal
Unmarshal parses the bytes representation of the Blockset and stores the result in the Blockset.
blockset.go:33
↓ 84 callersMethodVerboseEqual
(that interface{})
models/torus.pb.go:775
↓ 65 callersMethodUnlock
()
block/metadata.go:24
↓ 62 callersMethodClose
()
storage.go:44
↓ 61 callersMethodLock
(lease int64)
block/metadata.go:23
↓ 54 callersFunctiondie
(why string, args ...interface{})
cmd/torusctl/common.go:18
↓ 45 callersMethodIntn
(n int)
models/torus.pb.go:1547
↓ 42 callersMethodVersion
()
ring.go:17
↓ 39 callersFunctionsovTorus
(x uint64)
models/torus.pb.go:1783
↓ 36 callersMethodClose
()
distributor/protocols/protocols.go:19
↓ 34 callersFunctionencodeVarintTorus
(dAtA []byte, offset int, v uint64)
models/torus.pb.go:1403
↓ 33 callersMethodWrite
(b []byte)
file.go:132
↓ 27 callersMethodString
String implements the fmt.Stringer interface.
blockset.go:44
↓ 26 callersMethodGetBlock
GetBlock returns the ith block in the Blockset.
blockset.go:17
↓ 25 callersFunctionMkKey
(s ...string)
metadata/etcd/helpers.go:10
↓ 23 callersFunctiononErr
(err error)
cmd/torusblk/flex.go:374
↓ 21 callersMethodAdd
(b *BlockHeader)
storage/block_device/blockHeader.go:108
↓ 20 callersMethodRead
(b []byte)
file.go:252
↓ 18 callersMethodUint32
()
models/torus.pb.go:1546
↓ 17 callersMethodClose
()
internal/nbd/nbd.go:79
↓ 17 callersMethodGetPeers
(key BlockRef)
ring.go:12
↓ 17 callersMethodMarshalTo
(dAtA []byte)
models/torus.pb.go:1266
↓ 17 callersMethodgetContext
Context-sensitive calls
metadata/etcd/etcd.go:170
↓ 16 callersMethodSync
()
block/aoe/device.go:20
↓ 16 callersMethodWriteBlock
(ctx context.Context, b BlockRef, data []byte)
storage.go:253
↓ 15 callersMethodVolume
()
storage.go:57
↓ 14 callersMethodGet
(key string)
distributor/lru.go:56
↓ 14 callersMethodSeek
(offset int64, whence int)
file.go:295
↓ 13 callersFunctionNewPopulatedBlockRef
(r randyTorus, easy bool)
models/torus.pb.go:1522
↓ 13 callersFunctionpshort
poke a short into p at off
block/aoe/device.go:62
↓ 12 callersMethodBlockSize
()
distributor/protocols/tdp/tdp_test.go:53
↓ 12 callersMethodFlush
()
storage.go:43
↓ 12 callersFunctionmustConnectToMDS
()
cmd/torusctl/common.go:23
↓ 11 callersMethodEqual
(b2 *BlockHeader)
storage/block_device/blockHeader.go:43
↓ 11 callersFunctionNewPopulatedBlockLayer
(r randyTorus, easy bool)
models/torus.pb.go:1436
↓ 11 callersFunctionNewPopulatedPeerInfo
(r randyTorus, easy bool)
models/torus.pb.go:1460
↓ 11 callersFunctionNewPopulatedRebalanceInfo
(r randyTorus, easy bool)
models/torus.pb.go:1480
↓ 11 callersMethodPeerList
()
ring.go:139
↓ 11 callersMethodToBytes
()
storage.go:61
↓ 11 callersFunctionreadConnIntoBuffer
(conn net.Conn, buf []byte)
distributor/protocols/tdp/tdp.go:134
↓ 10 callersMethodEqual
(that interface{})
models/rpc.pb.go:435
↓ 10 callersFunctionNewPopulatedBlockRequest
(r randyRpc, easy bool)
models/rpc.pb.go:980
↓ 10 callersFunctionNewPopulatedBlockResponse
(r randyRpc, easy bool)
models/rpc.pb.go:990
↓ 10 callersFunctionNewPopulatedINode
(r randyTorus, easy bool)
models/torus.pb.go:1412
↓ 10 callersFunctionNewPopulatedINodeRef
(r randyTorus, easy bool)
models/torus.pb.go:1532
↓ 10 callersFunctionNewPopulatedPutBlockRequest
(r randyRpc, easy bool)
models/rpc.pb.go:1003
↓ 10 callersFunctionNewPopulatedPutResponse
(r randyRpc, easy bool)
models/rpc.pb.go:1026
↓ 10 callersFunctionNewPopulatedRebalanceCheckRequest
(r randyRpc, easy bool)
models/rpc.pb.go:1035
↓ 10 callersFunctionNewPopulatedRebalanceCheckResponse
(r randyRpc, easy bool)
models/rpc.pb.go:1049
↓ 10 callersFunctionNewPopulatedRing
(r randyTorus, easy bool)
models/torus.pb.go:1493
↓ 10 callersFunctionNewPopulatedVolume
(r randyTorus, easy bool)
models/torus.pb.go:1449
↓ 10 callersMethodNumBlocks
()
storage.go:256
↓ 10 callersMethodOpenBlockFile
()
block/blockfile.go:14
↓ 10 callersMethodUUID
Returns a UUID based on the underlying datadir. Should be unique for every created datadir.
metadata.go:37
↓ 10 callersMethodgetContext
()
block/etcd.go:67
↓ 10 callersFunctionioctl
ioctl() helper function
internal/nbd/nbd.go:64
↓ 9 callersMethodBlockSize
()
storage.go:259
↓ 9 callersMethodGetData
(x string)
metadata/temp/temp.go:245
↓ 9 callersMethodGetRing
()
metadata.go:39
↓ 9 callersMethodGlobalMetadata
GlobalMetadata backing struct must be instantiated upon the service creation. If it can not be created the MetadataService creation must fail.
metadata.go:33
↓ 9 callersMethodLockData
()
metadata/temp/temp.go:237
↓ 9 callersMethodPutBlock
PutBlock puts a block with data `b` into the Blockset as its ith block. The block belongs to the given inode.
blockset.go:20
↓ 9 callersMethodString
()
storage/block_device_test.go:118
↓ 9 callersMethodUnlockData
()
metadata/temp/temp.go:241
↓ 9 callersFunctionsovRpc
(x uint64)
models/rpc.pb.go:1215
↓ 8 callersFunctionDial
(addr string, timeout time.Duration, blockSize uint64)
distributor/protocols/tdp/client.go:42
↓ 8 callersFunctionServe
(addr string, handler Handler, blocksize uint64)
distributor/protocols/tdp/tdp.go:55
↓ 8 callersMethodSetRing
(ring Ring)
metadata.go:42
↓ 8 callersMethodToProto
()
storage.go:72
↓ 8 callersFunctionencodeVarintRpc
(dAtA []byte, offset int, v uint64)
models/rpc.pb.go:971
↓ 8 callersFunctionmakeTestData
(size int)
distributor/protocols/tdp/tdp_test.go:98
↓ 8 callersFunctionskipTorus
(dAtA []byte)
models/torus.pb.go:3091
↓ 7 callersMethodCreateBlockVolume
(vol *models.Volume)
block/metadata.go:29
↓ 7 callersMethodServe
(iface *Interface)
block/aoe/aoe.go:116
↓ 7 callersFunctioncreateServer
()
cmd/torusctl/common.go:32
↓ 7 callersFunctionrandStringTorus
(r randyTorus)
models/torus.pb.go:1559
↓ 6 callersMethodGetSnapshots
()
block/metadata.go:33
↓ 6 callersMethodHas
(uuid string)
ring.go:52
↓ 6 callersMethodLength
Length returns the number of blocks in the Blockset.
blockset.go:13
↓ 6 callersMethodListenAddr
()
distributor/protocols/tdp/tdp.go:69
↓ 6 callersMethodMembers
()
ring.go:13
↓ 6 callersFunctionOpenBlockVolume
(s *torus.Server, volume string)
block/volume.go:93
↓ 6 callersMethodToBytesBuf
(buf []byte)
storage.go:121
↓ 6 callersMethodTruncate
Truncate changes the length of the Blockset and the block. If the Blockset has less blocks than the required size, truncate adds zero blocks. If the b
blockset.go:40
↓ 6 callersMethodUUID
()
distributor/distributor.go:73
↓ 6 callersFunctionUint64ToHex
(x uint64)
metadata/etcd/helpers.go:34
↓ 6 callersFunctionencodeVarintPopulateRpc
(dAtA []byte, v uint64)
models/rpc.pb.go:1129
↓ 6 callersFunctionencodeVarintPopulateTorus
(dAtA []byte, v uint64)
models/torus.pb.go:1605
↓ 6 callersFunctionnewServer
(t testing.TB, md *temp.Server)
integration/integration_test.go:30
↓ 6 callersFunctionskipRpc
(dAtA []byte)
models/rpc.pb.go:1833
↓ 6 callersFunctionstderr
(msg string, args ...interface{})
storage/block_device_test.go:22
↓ 6 callersFunctionstderr
(msg string, args ...interface{})
cmd/fsck.torus/lib/lib.go:11
↓ 6 callersFunctionwriteResponse
(resp Response)
cmd/torusblk/flex.go:365
↓ 5 callersMethodBlock
(ctx context.Context, ref torus.BlockRef)
distributor/protocols/tdp/tdp.go:47
↓ 5 callersMethodBlockIterator
()
storage.go:258
↓ 5 callersMethodBlockRef
()
storage.go:266
next →1–100 of 1,324, ranked by callers