MCPcopy Create free account

hub / github.com/MilenMT/torus / functions

Functions1,324 in github.com/MilenMT/torus

⨍ Functions 1,324◇ Types & classes 158
↓ 5 callersFunctionBytesToUint64
(b []byte)
metadata/etcd/helpers.go:24
↓ 5 callersMethodDebug
Debug writes a bunch of debug output to the io.Writer.
server.go:94
↓ 5 callersMethodDeleteBlock
(ctx context.Context, b BlockRef)
storage.go:255
↓ 5 callersMethodErr
()
storage.go:264
↓ 5 callersMethodIsNil
()
storage/block_device/blockHeader.go:35
↓ 5 callersMethodNext
()
storage.go:265
↓ 5 callersMethodPut
(key string, value interface{})
distributor/lru.go:30
↓ 5 callersMethodRebalanceCheck
(ctx context.Context, refs []torus.BlockRef)
distributor/protocols/tdp/tdp.go:49
↓ 5 callersMethodSaveSnapshot
(name string)
block/metadata.go:32
↓ 5 callersMethodSetBlockType
(t BlockType)
storage.go:188
↓ 5 callersMethodUint32
()
models/rpc.pb.go:1070
↓ 5 callersMethodWithContext
(ctx context.Context)
metadata.go:44
↓ 5 callersFunctiondebug
(verbose bool, msg string, args ...interface{})
cmd/mkfs.torus/lib/lib.go:17
↓ 5 callersMethodfindIndex
(s torus.BlockRef)
storage/mfile.go:165
↓ 5 callersMethodgetContext
()
file.go:128
↓ 5 callersMethodputReplyHeader
(dst []byte, err uint32)
internal/nbd/nbd.go:403
↓ 5 callersMethodreadBlockHeader
(offset uint64)
storage/block_device.go:20
↓ 5 callersFunctionregisterRing
(t torus.RingType, name string, newFunc createRingFunc)
ring/ring_main.go:36
↓ 4 callersMethodAddPeers
(PeerInfoList)
ring.go:28
↓ 4 callersMethodAppend
(s []string)
cmd/torusctl/table.go:41
↓ 4 callersMethodBlock
(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption)
models/rpc.pb.go:626
↓ 4 callersFunctionCreateBlockVolume
CreateBlockVolume creates volume in metadata service.
block/volume.go:26
↓ 4 callersFunctionCreateOrOpenMFile
(path string, size uint64, blkSize uint64)
storage/mmap_file.go:17
↓ 4 callersMethodDescribe
()
ring.go:15
↓ 4 callersMethodGetINode
()
block/metadata.go:26
↓ 4 callersMethodGetWeights
()
ring.go:147
↓ 4 callersMethodIsZero
()
storage.go:192
↓ 4 callersMethodMarshalTo
(dAtA []byte)
models/rpc.pb.go:863
↓ 4 callersFunctionParseSnapName
(s string)
cmd/torusctl/block_snapshot.go:83
↓ 4 callersMethodPutBlock
(ctx context.Context, ref torus.BlockRef, data []byte)
distributor/protocols/protocols.go:16
↓ 4 callersMethodPutBlock
(ctx context.Context, ref torus.BlockRef, data []byte)
distributor/protocols/tdp/tdp.go:48
↓ 4 callersMethodPutBlock
(ctx context.Context, in *PutBlockRequest, opts ...grpc.CallOption)
models/rpc.pb.go:627
↓ 4 callersMethodReadAt
(b []byte, off int64)
internal/nbd/nbd.go:74
↓ 4 callersMethodSendError
(aerr aoe.Error)
block/aoe/frame.go:74
↓ 4 callersMethodSetDeadline
(t time.Time)
block/aoe/aoe_test.go:425
↓ 4 callersMethodString
()
storage/block_device_test.go:127
↓ 4 callersMethodUnion
(b PeerList)
ring.go:66
↓ 4 callersMethodUnion
(b PeerInfoList)
ring.go:116
↓ 4 callersMethodWriteAt
(b []byte, off int64)
internal/nbd/nbd.go:75
↓ 4 callersFunctionbytesOrIbytes
(s uint64, si bool)
cmd/torusctl/common.go:45
↓ 4 callersFunctioncloseAll
(t testing.TB, c ...*torus.Server)
integration/integration_test.go:101
↓ 4 callersFunctioncreateBlockMetadata
(mds torus.MetadataService, name string, vid torus.VolumeID)
block/metadata.go:37
↓ 4 callersFunctioncreateServer
()
cmd/torusblk/main.go:91
↓ 4 callersFunctiondie
(why string, args ...interface{})
cmd/torusd/main.go:263
↓ 4 callersFunctiondie
(why string, args ...interface{})
cmd/torusblk/main.go:127
↓ 4 callersMethodfindBlockOffset
findBlockOffset finds the offset into the device a block's header is. Returns the blocks offset, whether or not the block was found, and any errors
storage/block_device.go:419
↓ 4 callersFunctionmakeTempFilename
()
storage/mmap_file_test.go:10
↓ 4 callersFunctionmakeTestData
(size int)
integration/integration_test.go:114
↓ 4 callersFunctionmakeTinyPeers
(t *testing.T)
ring/ketama_test.go:13
↓ 4 callersFunctionnewBaseBlockset
(store torus.BlockStore)
blockset/base.go:28
↓ 4 callersFunctionnewFile
(name string, t *testing.T)
file_blackbox_test.go:50
↓ 4 callersMethodnumBlocks
()
storage/mfile.go:112
↓ 4 callersMethodoptReply
(opt uint32, reptype uint32, data []byte)
internal/nbd/nbdserver.go:252
↓ 4 callersMethodperform
(d *deviceBlock)
storage/block_device_test.go:131
↓ 4 callersFunctionringN
(t testing.TB, n int)
integration/integration_test.go:68
↓ 4 callersFunctionstderr
(msg string, args ...interface{})
cmd/mkfs.torus/mkfs.torus.go:20
↓ 4 callersFunctiontestBPFProgram
testBPFProgram builds a BPF program for the input server and compares the output of the program against the input AoE header, returning whether or not
block/aoe/aoe_test.go:190
↓ 4 callersMethodtoBool
(len int)
distributor/protocols/tdp/bitset.go:43
↓ 4 callersMethodwriteBlockHeader
(hdrs blockDevice.BlockHeaders, offset uint64)
storage/block_device.go:52
↓ 3 callersMethodAndNot
(b PeerList)
ring.go:56
↓ 3 callersMethodBlockType
()
storage.go:184
↓ 3 callersMethodCreateFile
(volume *models.Volume, inode *models.INode, blocks Blockset)
file.go:89
↓ 3 callersFunctionCreateMFile
(path string, size uint64)
storage/mmap_file.go:35
↓ 3 callersMethodDeleteSnapshot
(name string)
block/metadata.go:34
↓ 3 callersMethodFindDevice
(name string)
internal/nbd/nbdserver.go:36
↓ 3 callersMethodGetAllBlockRefs
GetAllBlockRefs returns the BlockRef of the blocks in the Blockset. The ith BlockRef in the returned slice is the Ref of the ith Block in the Blockset
blockset.go:27
↓ 3 callersMethodGetVolume
(volume string)
metadata.go:26
↓ 3 callersMethodGetVolumes
()
metadata.go:25
↓ 3 callersMethodGlobalMetadata
()
metadata/temp/temp.go:81
↓ 3 callersMethodIndexAt
(uuid string)
ring.go:43
↓ 3 callersMethodInt63
()
models/torus.pb.go:1544
↓ 3 callersFunctionNewTableWriter
(output io.Writer)
cmd/torusctl/table.go:16
↓ 3 callersFunctionOpenMFile
(path string, blkSize uint64)
storage/mmap_file.go:44
↓ 3 callersMethodOpenSnapshot
(name string)
block/blockfile.go:50
↓ 3 callersMethodRebalanceCheck
(ctx context.Context, in *RebalanceCheckRequest, opts ...grpc.CallOption)
models/rpc.pb.go:628
↓ 3 callersFunctionRegisterBlockset
RegisterBlockset is the hook used for implementations of blocksets to register themselves to the system. This is usually called in the init() of the p
blockset/blockset_main.go:59
↓ 3 callersMethodRemovePeers
(PeerList)
ring.go:33
↓ 3 callersMethodRender
()
cmd/torusctl/table.go:22
↓ 3 callersMethodRenderCSV
()
cmd/torusctl/table.go:35
↓ 3 callersMethodSetHeader
(s []string)
cmd/torusctl/table.go:45
↓ 3 callersMethodSubscribeNewRings
(chan Ring)
metadata.go:40
↓ 3 callersMethodSyncINode
(torus.INodeRef)
block/metadata.go:27
↓ 3 callersMethodTrim
Trim zeros the blocks in range [from, to).
blockset.go:42
↓ 3 callersMethodUUID
()
distributor/rebalance/rebalancer.go:18
↓ 3 callersMethodUnmarshal
(buf []byte)
storage/block_device/metadata.go:28
↓ 3 callersMethodUnmarshal
(dAtA []byte)
models/torus.pb.go:2150
↓ 3 callersMethodUnmarshalBinary
(data []byte)
block/aoe/frame.go:18
↓ 3 callersMethodUnsubscribeNewRings
(chan Ring)
metadata.go:41
↓ 3 callersMethodUpdateRebalanceInfo
(ri *models.RebalanceInfo)
heartbeat.go:160
↓ 3 callersFunctionZeroINode
()
storage.go:200
↓ 3 callersFunctionconnectSystemd
()
cmd/torusblk/flex.go:92
↓ 3 callersFunctioncreateBlockset
(b torus.BlockLayer, store torus.BlockStore, subLayer blockset)
blockset/blockset_main.go:76
↓ 3 callersFunctiondebug
(verbose bool, msg string, args ...interface{})
cmd/fsck.torus/lib/lib.go:15
↓ 3 callersFunctiondevToUnitName
(dev string)
cmd/torusblk/flex.go:82
↓ 3 callersFunctiondie
(why string, args ...interface{})
cmd/mkfs.torus/mkfs.torus.go:30
↓ 3 callersFunctiongenerateLinearFile
(vol torus.VolumeID, in torus.INodeID, size int)
cmd/ringtool/ringtool.go:241
↓ 3 callersMethodgetConn
getConn returns RPC interface after found proper peers.
distributor/client.go:62
↓ 3 callersFunctionheadersEqual
headersEqual compares a response and request AoE header for equality, but does not factor in their Arg fields.
block/aoe/aoe_test.go:351
↓ 3 callersMethodisClosed
()
distributor/protocols/tdp/tdp.go:222
↓ 3 callersFunctionnewCRCBlockset
(sub blockset)
blockset/crc.go:30
← previousnext →101–200 of 1,324, ranked by callers