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
↓ 1 callers
Method
Lookup
(ctx context.Context, name string)
fs/snap/fuse.go:73
↓ 1 callers
Method
Lookup
TODO how to pass ctx to rat.ReadAt
fs/snap/reader.go:25
↓ 1 callers
Function
Main
Main is primary entry point into the bazil command line application.
cli/cli.go:150
↓ 1 callers
Method
MarshalBinary
()
cas/key.go:106
↓ 1 callers
Function
MarshalPrefixBytes
MarshalPrefixBytes marshals a uvarint length prefixed protobuf message.
pb/marshalprefixbytes.go:10
↓ 1 callers
Function
New
(app *server.App)
server/peer/peer.go:44
↓ 1 callers
Function
New
New creates a new Stash.
cas/chunks/stash/stash.go:12
↓ 1 callers
Function
NewPeerClient
(cc *grpc.ClientConn)
peer/wire/peer.pb.go:780
↓ 1 callers
Method
NextEpoch
NextEpoch increments the epoch and returns the new value. The value is only safe to use if the transaction commits. If epoch wraps around, returns Er
db/volume.go:249
↓ 1 callers
Function
Open
(peer wire.PeerClient)
kv/kvpeer/kvpeer.go:78
↓ 1 callers
Method
Open
Open key-value stores as allowed for this peer. Uses the opener function for the actual open action. If the peer is not allowed to use any storage, r
db/peer.go:228
↓ 1 callers
Method
Protocol
()
fs/fstestutil/create.go:89
↓ 1 callers
Method
Put
(ctx context.Context, key, value []byte)
kv/kvmock/inmem.go:23
↓ 1 callers
Method
Readlink
(ctx context.Context, req *fuse.ReadlinkRequest)
fs/pending.go:233
↓ 1 callers
Method
Register
Register a new command. Each command is a singleton value of a unique type that has its address given to Shell.Register. Commands are identified by t
cliutil/subcommands/shell.go:60
↓ 1 callers
Function
RegisterControlServer
(s *grpc.Server, srv ControlServer)
server/control/wire/control.pb.go:327
↓ 1 callers
Function
RegisterPeerServer
(s *grpc.Server, srv PeerServer)
peer/wire/peer.pb.go:929
↓ 1 callers
Method
ResolveNew
ResolveNew records a conflict resolution in favor of newly created content.
fs/clock/clock.go:148
↓ 1 callers
Method
SendAndClose
(*ObjectPutResponse)
peer/wire/peer.pb.go:956
↓ 1 callers
Method
Serve
()
server/control/server.go:44
↓ 1 callers
Method
Set
(value string)
db/volumeID.go:48
↓ 1 callers
Method
SetOutput
(w io.Writer)
cliutil/subcommands/iface.go:24
↓ 1 callers
Method
Setup
()
cli/cli.go:119
↓ 1 callers
Method
SharingKeyName
SharingKeyName returns the sharing key name for this item. Returned value is valid after the transaction.
db/volumeStorage.go:89
↓ 1 callers
Method
Snapshot
Snapshot records a snapshot of the volume. The Snapshot message itself has not been persisted yet.
fs/fs.go:98
↓ 1 callers
Method
Storage
()
db/volume.go:188
↓ 1 callers
Method
String
()
cliutil/flagx/abspath.go:15
↓ 1 callers
Method
String
()
cas/chunks/chunks.go:20
↓ 1 callers
Method
SyncReceive
(ctx context.Context, dirPath string, peers map[uint32][]byte, dirClockBuf []byte, recv func() ([]*wirepeer.Di
fs/fs.go:400
↓ 1 callers
Method
Teardown
()
cli/cli.go:120
↓ 1 callers
Method
TombstoneCreate
TombstoneCreate marks the entry in parent directory with the given name as removed, but leaves a hint of its existence. It creates a new entry if one
db/volumeDir.go:93
↓ 1 callers
Function
TombstoneFromParent
TombstoneFromParent returns a new tombstone clock based on the parent.
fs/clock/clock.go:183
↓ 1 callers
Method
UnmarshalBinary
(data []byte)
fs/clock/clock.go:39
↓ 1 callers
Function
UnmarshalPrefixAt
UnmarshalPrefixAt unmarshals a uvarint length prefixed protobuf message.
pb/unmarshalprefixat.go:14
↓ 1 callers
Method
Update
(parentInode uint64, name string, now clock.Epoch)
db/volumeClock.go:79
↓ 1 callers
Method
UpdateOrCreate
(parentInode uint64, name string, now clock.Epoch)
db/volumeClock.go:105
↓ 1 callers
Method
UpdateParent
UpdateParent is like Update, but does not simplify the modification time version vector. It is safe to use for directories and other entities where up
fs/clock/clock.go:94
↓ 1 callers
Method
WaitForUnmount
()
server/server.go:386
↓ 1 callers
Function
basename
(dirKey []byte)
db/volumeDir.go:24
↓ 1 callers
Function
buildCommands
(dst string, importPaths ...string)
task/gen-protobuf.go:40
↓ 1 callers
Function
bytesToInode
(buf []byte)
fs/inodes/inodes.go:21
↓ 1 callers
Method
cleanEpoch
caller must hold v.epoch.mu
fs/fs.go:133
↓ 1 callers
Method
debug
(msg interface{})
server/server.go:377
↓ 1 callers
Method
dirToKeyPrefix
(parentInode uint64)
db/volumeConflict.go:30
↓ 1 callers
Function
expandPackages
(spec []string)
task/gen-imports.go:42
↓ 1 callers
Function
findSig
(cert *x509.Certificate, pub *[ed25519.PublicKeySize]byte, sig *[ed25519.SignatureSize]byte)
util/edtls/vouch.go:42
↓ 1 callers
Method
generateTLSConfig
(signPub *[ed25519.PublicKeySize]byte, signPriv *[ed25519.PrivateKeySize]byte)
server/tls.go:25
↓ 1 callers
Method
getSharingKey
(name string, out *[32]byte)
cli/debug/cas/cas.go:34
↓ 1 callers
Function
getTagField
Get the named struct tag field. For example, from Foo struct { Bar string `positional:"something,metavar=BLEH,somethingelse"` } calling getTagField
cliutil/positional/usage.go:25
↓ 1 callers
Function
gitVersion
()
task/build.go:44
↓ 1 callers
Function
goBuild
(src string, action string, args ...string)
task/build.go:30
↓ 1 callers
Function
gopath
()
task/gen-protobuf.go:17
↓ 1 callers
Function
includeArgs
(gopath []string)
task/gen-protobuf.go:21
↓ 1 callers
Method
initPeers
()
db/peer.go:29
↓ 1 callers
Method
initSharingKeys
()
db/sharingKey.go:21
↓ 1 callers
Method
initVolumes
()
db/volume.go:33
↓ 1 callers
Function
inodeToBytes
(inode uint64, buf []byte)
fs/inodes/inodes.go:17
↓ 1 callers
Method
invalidateEntry
(d node, name string)
fs/fs.go:429
↓ 1 callers
Function
isInUse
isInUse returns if the error was EADDRINUSE, as expected from from bind(2).
util/trylisten/trylisten.go:10
↓ 1 callers
Function
listProtos
()
task/gen-protobuf.go:50
↓ 1 callers
Function
loadOrGenerateKeys
loadOrGenerateKeys reads the master signing key from the global state in DB, (generating one if it's not already there), and generates the boxing keys
server/key.go:35
↓ 1 callers
Function
lock
(lockPath string)
server/lock.go:9
↓ 1 callers
Method
lookup
lookup fetches the data chunk for given global byte offset. The returned Chunk remains zero trimmed. It may be a Private or a normal chunk. For writ
cas/blobs/blobs.go:192
↓ 1 callers
Method
lookupPath
(tx *db.Tx, dirPath string)
fs/fs.go:352
↓ 1 callers
Function
makePeerMap
makePeerMap returns a mapping from the peerids in peers to the ones in the local database.
fs/dir.go:674
↓ 1 callers
Method
marshal
(ctx context.Context)
fs/fs.go:447
↓ 1 callers
Function
newInvalidKey
()
cas/key.go:177
↓ 1 callers
Method
nextEpoch
caller is responsible for locking TODO nextEpoch only needs to tick if the volume is seeing mutation; unmounted is safe?
fs/fs.go:112
↓ 1 callers
Method
openVolume
caller must hold App.volumes.Mutex
server/server.go:175
↓ 1 callers
Function
process
()
task/gen-protobuf.go:72
↓ 1 callers
Function
process
(dst string, imports []string)
task/gen-imports.go:64
↓ 1 callers
Function
randomVolumeID
()
db/volume.go:167
↓ 1 callers
Method
reviveNode
(de *wire.Dirent, name string)
fs/dir.go:182
↓ 1 callers
Function
run
(result subcommands.Result)
cli/cli.go:123
↓ 1 callers
Method
save
(tx *db.Tx, name string, de *wire.Dirent)
fs/dir.go:299
↓ 1 callers
Method
saveChunk
(ctx context.Context, key cas.Key, level uint8)
cas/blobs/blobs.go:599
↓ 1 callers
Method
snapshot
snapshot records a snapshot of the directory and stores it in wde
fs/dir.go:604
↓ 1 callers
Function
sourceDir
()
task/build.go:13
↓ 1 callers
Function
srcRoot
(abspath string)
task/gen-protobuf.go:29
↓ 1 callers
Function
statBlocks
(size uint64)
fs/readonly/file.go:36
↓ 1 callers
Method
syncReceive
(ctx context.Context, peers map[uint32][]byte, dirClockBuf []byte, recv func() ([]*wirepeer.Dirent, error))
fs/dir.go:850
↓ 1 callers
Function
trim
(b []byte)
cas/blobs/blobs.go:478
↓ 1 callers
Method
tryResolveConflicts
Resolve as many of the postponed syncs as we can.
fs/dir.go:1022
↓ 1 callers
Function
unmarshalItem
(buf *bytes.Reader, it *item)
fs/clock/marshal.go:52
↓ 1 callers
Method
updateSimplify
updateSimplify adds id at time now to the vector, knowing that only one entry needs to be preserved.
fs/clock/vector.go:73
↓ 1 callers
Function
zeroSlice
(p []byte)
cas/blobs/blobs.go:486
Method
Add
(ctx context.Context, chunk *chunks.Chunk)
cas/chunks/kvchunks/kvchunks.go:42
Method
Add
Add adds a Chunk to the Store. See chunks.Store.Add.
cas/chunks/mock/inmem.go:36
Method
Add
Add adds a Chunk to the Store. See chunks.Store.Add.
cas/chunks/mock/never.go:22
Method
Add
Add a storage backend to be used by the volume. Active Volume instances are not notified. If volume has storage by that name already, returns ErrVol
db/volumeStorage.go:25
Method
Add
Add a sharing key. If name is invalid, returns ErrSharingKeyNameInvalid. If a sharing key by that name already exists, returns ErrSharingKeyExist.
db/sharingKey.go:79
Method
Add
(parentInode uint64, c *clock.Clock, de *wirepeer.Dirent)
db/volumeConflict.go:36
Method
Add
Add adds a volume that was created elsewhere to this node. If the name exists already, returns ErrVolNameExist.
db/volume.go:163
Method
Allow
(vol *Volume)
db/peer.go:256
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/dot-bazil.go:19
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/dot-snap.go:29
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/pending.go:25
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/pending.go:92
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/pending.go:224
Method
Attr
(ctx context.Context, a *fuse.Attr)
fs/file.go:83
← previous
next →
301–400 of 1,400, ranked by callers