Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bazil/bazil
/ functions
Functions
1,400 in github.com/bazil/bazil
⨍
Functions
1,400
◇
Types & classes
236
↓ 2 callers
Function
Debug
(fn func(msg interface{}))
server/options.go:11
↓ 2 callers
Method
Epoch
Epoch returns the current mutation epoch of the volume. Returned value is valid after the transaction.
db/volume.go:222
↓ 2 callers
Method
Error
()
cas/key.go:32
↓ 2 callers
Method
GetTombstone
()
fs/wire/dirent.pb.go:111
↓ 2 callers
Method
GetType
()
fs/snap/wire/snap.pb.go:83
↓ 2 callers
Method
GetVolumeByName
(name string)
server/server.go:158
↓ 2 callers
Function
HandleGet
(ctx context.Context, fn Handler, key cas.Key, typ string, level uint8)
cas/chunks/chunkutil/makechunk.go:23
↓ 2 callers
Method
Init
(name string, errorHandling flag.ErrorHandling)
cliutil/subcommands/iface.go:23
↓ 2 callers
Method
Iter
()
fs/snap/reader.go:45
↓ 2 callers
Method
Key
Key returns a copy of the current value of the KeyParam. As usual with cas.Key, the returned value is promised to be immutable.
cas/flagx/keyparam.go:51
↓ 2 callers
Method
ListAll
ListAll iterates over all of the conflict entries for this directory.
db/volumeConflict.go:67
↓ 2 callers
Function
MakeChunk
MakeChunk makes a new Chunk of the given description, filling it with content from data.
cas/chunks/chunkutil/makechunk.go:12
↓ 2 callers
Method
MarshalBinary
MarshalBinary encodes Version into binary form.
fs/clock/marshal.go:44
↓ 2 callers
Method
Mount
Mount makes the contents of the volume visible at the given mountpoint. If Mount returns with a nil error, the mount has occurred.
server/server.go:308
↓ 2 callers
Method
Name
Name returns the full name of the subcommand being executed, including all the parents.
cliutil/subcommands/result.go:42
↓ 2 callers
Function
New
New creates a control socket to listen for administrative commands. Caller is expected to call Control.Serve to actually process incoming requests and
server/control/server.go:21
↓ 2 callers
Function
New
(app *server.App, listener net.Listener)
server/http/http.go:15
↓ 2 callers
Function
NewFile
NewFile opens a file for read-only access. TODO pass in metadata.
fs/readonly/file.go:19
↓ 2 callers
Function
NewKeyPrivateNum
NewKeyPrivateNum makes a new Key in the private range, with the given number encoded in it. The number can be extracted from the key with the method P
cas/key.go:156
↓ 2 callers
Function
NewReader
(rat io.ReaderAt, align uint32)
fs/snap/reader.go:16
↓ 2 callers
Function
NewTestDB
(t testing.TB)
db/common_test.go:18
↓ 2 callers
Function
NewWriter
(wat io.WriterAt)
fs/snap/writer.go:19
↓ 2 callers
Method
Next
()
db/volumeDir.go:163
↓ 2 callers
Method
ObjectGet
(ctx context.Context, in *ObjectGetRequest, opts ...grpc.CallOption)
peer/wire/peer.pb.go:771
↓ 2 callers
Method
ObjectPut
(ctx context.Context, opts ...grpc.CallOption)
peer/wire/peer.pb.go:770
↓ 2 callers
Function
Open
(path string, mode os.FileMode, options *bolt.Options)
db/db.go:16
↓ 2 callers
Method
OpenKV
(tx *db.Tx, storage *db.VolumeStorage)
server/server.go:193
↓ 2 callers
Method
OpenKVForPeer
(pub *peer.PublicKey)
server/peer.go:15
↓ 2 callers
Method
Put
Put an entry in parent directory with the given name.
db/volumeDir.go:46
↓ 2 callers
Method
Read
(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse)
fs/file.go:176
↓ 2 callers
Method
Reset
()
peer/wire/peer.pb.go:424
↓ 2 callers
Method
Send
(*ObjectPutRequest)
peer/wire/peer.pb.go:803
↓ 2 callers
Method
Set
(value string)
cliutil/flagx/tcpaddr.go:20
↓ 2 callers
Method
Set
(value string)
cliutil/flagx/abspath.go:21
↓ 2 callers
Method
SetFUSE
(srv *fs.Server)
fs/fs.go:425
↓ 2 callers
Method
SetMinimum
SetMinimum sets the minimum value that will be returned. This is useful for reserving some ids for special use.
idpool/idpool.go:39
↓ 2 callers
Method
String
()
peer/peer.go:34
↓ 2 callers
Method
String
()
cas/blobs/blobs.go:149
↓ 2 callers
Method
String
String returns a hex representation of the key. See flag.Value.String and cas.Key.String.
cas/flagx/keyparam.go:23
↓ 2 callers
Method
String
()
db/volumeID.go:44
↓ 2 callers
Method
SyncSend
(ctx context.Context, dirPath string, send func(*wirepeer.VolumeSyncPullItem) error)
fs/fs.go:158
↓ 2 callers
Method
VisitAll
(fn func(*flag.Flag))
cliutil/subcommands/iface.go:33
↓ 2 callers
Method
add
ensure id is in the list, adding it there if necessary
fs/clock/vector.go:46
↓ 2 callers
Method
add
add a new volume. If the name exists already, returns ErrVolNameExist. If the volume ID exists already, returns ErrVolIDExist.
db/volume.go:86
↓ 2 callers
Method
chunkSizeForLevel
(level uint8)
cas/blobs/blobs.go:282
↓ 2 callers
Method
computeBoxedKey
(key []byte)
kv/untrusted/untrusted.go:25
↓ 2 callers
Method
computeLevel
(size uint64)
cas/blobs/blobs.go:105
↓ 2 callers
Method
discardAfter
chunk must be a Private chunk
cas/blobs/blobs.go:308
↓ 2 callers
Method
drop
(priv uint64)
cas/chunks/stash/stash.go:52
↓ 2 callers
Function
extractEd25519Pubkey
(priv *[ed25519.PrivateKeySize]byte)
server/key.go:24
↓ 2 callers
Method
flush
(ctx context.Context)
fs/file.go:131
↓ 2 callers
Method
forgetChild
(name string, child node)
fs/dir.go:387
↓ 2 callers
Method
item
(k, v []byte)
db/volumeStorage.go:49
↓ 2 callers
Method
item
(k, v []byte)
db/volumeConflict.go:119
↓ 2 callers
Method
item
(k, _ []byte)
db/peer.go:125
↓ 2 callers
Method
lookupForWrite
lookupForWrite fetches the data chunk for the given offset and ensures it is Private and reinflated, and thus writable.
cas/blobs/blobs.go:363
↓ 2 callers
Function
makeKey
(key cas.Key, typ string, level uint8)
cas/chunks/kvchunks/kvchunks.go:21
↓ 2 callers
Method
makeNonce
Nonce summarizes key, type and level so mismatch of e.g. type can be detected.
kv/untrusted/untrusted.go:43
↓ 2 callers
Method
marshalInternal
(ctx context.Context)
fs/file.go:60
↓ 2 callers
Function
newApp
(t testing.TB, dataDir string, log func(msg interface{}))
fs/fstestutil/create.go:31
↓ 2 callers
Function
newKey
(b []byte)
cas/key.go:112
↓ 2 callers
Method
openStorage
(backend string)
server/server.go:225
↓ 2 callers
Function
pkgName
(cmd interface{})
cliutil/subcommands/shell.go:33
↓ 2 callers
Method
rebase
rebase sets v to only include the items not in other.
fs/clock/vector.go:90
↓ 2 callers
Method
reviveDir
(de *wire.Dirent, dt *wire.Dir, name string)
fs/dir.go:177
↓ 2 callers
Function
safeSlice
safeSlice returns a slice of buf if possible, and where buf is not large enough to serve this slice, it returns a new slice of the right size. In case
cas/blobs/blobs.go:175
↓ 2 callers
Function
setAbsPath
(t testing.TB, value string)
cliutil/flagx/abspath_test.go:18
↓ 2 callers
Method
setEpoch
(epoch clock.Epoch)
db/volume.go:231
↓ 2 callers
Function
setTCPAddr
(t testing.TB, value string)
cliutil/flagx/tcpaddr_test.go:19
↓ 2 callers
Function
setup_greeting
(t testing.TB, chunkStore chunks.Store)
fs/snap/serve_test.go:44
↓ 2 callers
Method
shrink
Decreases depth, always selecting only the leftmost tree, and dropping all Private chunks in the rest.
cas/blobs/blobs.go:335
↓ 2 callers
Method
specialKind
()
cas/key.go:63
↓ 2 callers
Function
splitPath
(p string)
fs/fs.go:150
↓ 2 callers
Method
syncToMissing
caller must hold d.mu
fs/dir.go:698
↓ 2 callers
Function
testCompareBoth
(t *testing.T, saveEvery int)
cas/blobs/quickblobs_test.go:81
↓ 2 callers
Method
unmarshal
()
db/volumeStorage.go:70
↓ 1 callers
Method
Align
()
fs/snap/writer.go:25
↓ 1 callers
Method
Backend
Backend returns the storage backend for this item. Returned value is valid after the transaction.
db/volumeStorage.go:77
↓ 1 callers
Method
Clear
Clear drops all the Private chunks held in this Stash. This is useful e.g. when the contents of a Blob are completely rewritten.
cas/chunks/stash/stash.go:131
↓ 1 callers
Method
Close
()
server/server.go:274
↓ 1 callers
Method
CloseAndRecv
()
peer/wire/peer.pb.go:804
↓ 1 callers
Function
Create
(path string)
kv/kvfiles/kvfiles.go:68
↓ 1 callers
Method
Create
Create a totally new volume, not yet shared with any peers. If the name exists already, returns ErrVolNameExist.
db/volume.go:144
↓ 1 callers
Function
DataDir
()
defaults/paths.go:11
↓ 1 callers
Method
Debug
(msg interface{})
server/server.go:123
↓ 1 callers
Method
Delete
(parentInode uint64, name string, clockBuf []byte)
db/volumeConflict.go:89
↓ 1 callers
Method
Drop
Drop forgets a Private chunk. The key may be reused, so caller must not remember the old key.
cas/chunks/stash/stash.go:59
↓ 1 callers
Function
Dynamic
Dynamic returns a dynamic inode. The result is guaranteed to never collide with inodes returned from Allocate.
fs/inodes/dynamic.go:11
↓ 1 callers
Method
Error
()
kv/untrusted/untrusted.go:92
↓ 1 callers
Method
Error
()
cas/error.go:17
↓ 1 callers
Method
Flush
(ctx context.Context, req *fuse.FlushRequest)
fs/file.go:170
↓ 1 callers
Method
Get
Get returns a Peer for the given public key. If the peer does not exist, returns ErrPeerNotFound.
db/peer.go:55
↓ 1 callers
Method
GetDescription
()
cliutil/subcommands/iface.go:54
↓ 1 callers
Method
GetDir
()
fs/wire/dirent.pb.go:104
↓ 1 callers
Method
GetFUSEDirent
GetFUSEDirent returns a populated fuse.Dirent
fs/wire/to-fuse.go:8
↓ 1 callers
Method
GetFile
()
fs/wire/dirent.pb.go:97
↓ 1 callers
Method
GetOverview
()
cliutil/subcommands/iface.go:79
↓ 1 callers
Method
GetSynopses
()
cliutil/subcommands/iface.go:64
↓ 1 callers
Method
ID
()
db/peer.go:161
↓ 1 callers
Method
Len
()
fs/clock/vector.go:17
← previous
next →
201–300 of 1,400, ranked by callers