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
↓ 178 callers
Method
Close
Close unmounts the filesystem and waits for fs.Serve to return. TODO not true: Any returned error will be stored in Err. It is safe to call Close mu
fs/fstestutil/create.go:68
↓ 69 callers
Method
Size
Size returns the current byte size of the Blob.
cas/blobs/blobs.go:474
↓ 64 callers
Method
Get
(ctx context.Context, key []byte)
kv/iface.go:8
↓ 58 callers
Method
Unmarshal
Unmarshal the directory entry to out. out is valid after the transaction.
db/volumeDir.go:202
↓ 56 callers
Method
Close
()
server/server.go:111
↓ 52 callers
Method
Cleanup
()
util/tempdir/tempdir.go:15
↓ 52 callers
Function
New
(t testing.TB)
util/tempdir/tempdir.go:58
↓ 51 callers
Method
Subdir
Utility function to create a new subdirectory. This can be used to have more predictable path names in a test that needs multiple temp directories: on
util/tempdir/tempdir.go:49
↓ 49 callers
Method
Update
Update adds or updates the version vector entry for id to point to time now. As an optimization, it removes all the other modification time entries.
fs/clock/clock.go:83
↓ 42 callers
Method
Put
(ctx context.Context, key, value []byte)
kv/iface.go:9
↓ 39 callers
Method
IO
IO returns a value that remembers ctx and lets the caller perform I/O operations that do not take a context argument.
cas/blobs/blobs.go:230
↓ 38 callers
Method
Add
Add a chunk to the chunk store.
cas/chunks/chunks.go:34
↓ 37 callers
Method
update
(id Peer, now Epoch)
fs/clock/vector.go:66
↓ 36 callers
Method
ValidateFile
ValidateFile panics if internal assumptions have been broken. This should never happen. This method is intended for unit tests only. The assumptions
fs/clock/clock_export_test.go:9
↓ 33 callers
Method
Name
Name returns the basename of this directory entry. name is valid after the transaction.
db/volumeDir.go:195
↓ 33 callers
Method
String
()
fs/clock/clock.go:154
↓ 31 callers
Method
View
View calls the function inside a database transaction.
fs/dir.go:106
↓ 27 callers
Function
Sync
Sync returns what action receiving state from A to B should cause us to take.
fs/clock/clock.go:213
↓ 27 callers
Method
Volumes
()
db/volume.go:43
↓ 25 callers
Function
Create
Create returns a new Vector Pair that knows it was created by id at time now.
fs/clock/clock.go:63
↓ 25 callers
Function
Open
Open returns a new Blob, using the given chunk store and manifest. It makes a copy of the manifest, so the caller is free to use it in any way after
cas/blobs/blobs.go:129
↓ 25 callers
Method
Peers
()
db/peer.go:39
↓ 25 callers
Function
Register
Register this command on the default Shell.
cliutil/subcommands/default.go:8
↓ 25 callers
Method
ResolveTheirs
ResolveTheirs records a conflict resolution in favor of other.
fs/clock/clock.go:128
↓ 25 callers
Method
VolumeSync
(ctx context.Context, in *VolumeSyncRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:146
↓ 25 callers
Method
bucket
(tx *db.Tx)
fs/fs.go:48
↓ 23 callers
Method
Addr
()
server/http/http.go:34
↓ 23 callers
Function
Dial
(path string, opts ...grpc.DialOption)
util/grpcunix/grpcunix.go:7
↓ 23 callers
Function
NewControlClient
(cc *grpc.ClientConn)
server/control/wire/control.pb.go:158
↓ 22 callers
Function
ListenAndServe
(t testing.TB, wg *sync.WaitGroup, app *server.App)
server/control/controltest/controltest.go:11
↓ 22 callers
Method
Open
(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse)
fs/file.go:103
↓ 22 callers
Method
ReadAt
ReadAt reads data from the given offset. See io.ReaderAt.
cas/blobs/blobs.go:237
↓ 21 callers
Method
Save
Save persists the Blob into the Store and returns a new Manifest that can be passed to Open later.
cas/blobs/blobs.go:631
↓ 20 callers
Method
Close
()
server/control/server.go:40
↓ 20 callers
Method
Create
(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse)
fs/dir.go:328
↓ 20 callers
Method
WriteAt
WriteAt writes data to the given offset. See io.WriterAt.
cas/blobs/blobs.go:443
↓ 19 callers
Method
Bytes
Bytes returns a byte slice with the byte content of the key.
cas/key.go:47
↓ 19 callers
Method
Write
(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse)
fs/file.go:116
↓ 18 callers
Method
Error
()
kv/error.go:15
↓ 17 callers
Function
ServeHTTP
(t testing.TB, wg *sync.WaitGroup, app *server.App)
server/http/httptest/httptest.go:12
↓ 17 callers
Method
Update
Update makes changes to the database. There can be only one Update call at a time. If a lock L is held while calling db.Update, L must never be taken
db/db.go:56
↓ 16 callers
Method
Error
()
fs/inodes/inodes.go:30
↓ 16 callers
Method
Remove
(ctx context.Context, req *fuse.RemoveRequest)
fs/dir.go:473
↓ 16 callers
Method
SharingKeys
()
db/sharingKey.go:46
↓ 16 callers
Method
UpdateSync
UpdateSync updates the sync time only for id to point to time now. Caller guarantees if an entry exists for id already, now is greater than or equal
fs/clock/clock.go:103
↓ 16 callers
Method
merge
(other vector)
fs/clock/vector.go:77
↓ 15 callers
Method
Dirs
Dirs provides a way of accessing the directory entries stored in this volume.
db/volume.go:205
↓ 15 callers
Method
First
()
db/peer.go:144
↓ 14 callers
Method
Clock
()
db/volume.go:193
↓ 14 callers
Method
Close
()
server/http/http.go:23
↓ 14 callers
Method
Get
Get a chunk from the chunk store. The returned Chunk is considered read-only and must not be modified.
cas/chunks/chunks.go:31
↓ 14 callers
Function
New
(dataDir string, options ...AppOption)
server/server.go:46
↓ 14 callers
Function
Parse
Parse fills the fields of the struct pointed to by args with input from the given list. Fields are handled based on their data type, for example stri
cliutil/positional/parse.go:57
↓ 14 callers
Method
Set
(string)
cliutil/positional/parse.go:30
↓ 14 callers
Method
UpdateFromParent
UpdateFromParent simplifies child sync times based on the parent.
fs/clock/clock.go:116
↓ 14 callers
Function
setLocation
setLocation sets the location of peer identified by pub in app to loc.
fs/sync_test.go:140
↓ 13 callers
Method
Conflicts
()
db/volume.go:198
↓ 13 callers
Function
NewKey
NewKey makes a new Key with the given byte contents. If the input happens to be a reserved byte sequence, the returned key will be Invalid. This func
cas/key.go:129
↓ 12 callers
Method
Control
Control returns a gRPC client that can make control requests to the server. This allows dialing only when needed, because not every cli tool is a cont
cli/cli.go:81
↓ 12 callers
Method
Cursor
()
db/peer.go:117
↓ 12 callers
Method
Make
Make returns a Peer for the given public key, adding it if necessary.
db/peer.go:69
↓ 12 callers
Method
String
()
cliutil/flagx/tcpaddr.go:16
↓ 12 callers
Method
UpdateFromChild
UpdateFromChild tracks child modification times in the parent. Return value reports whether s changed.
fs/clock/clock.go:110
↓ 11 callers
Method
Error
()
cliutil/subcommands/shell.go:88
↓ 11 callers
Method
Mkdir
(ctx context.Context, req *fuse.MkdirRequest)
fs/dir.go:430
↓ 11 callers
Method
Next
()
fs/snap/reader.go:54
↓ 11 callers
Function
Parse
Parse the command line using the default Shell. In typical use, cmd is the address of a registered command at the top of the package hierarchy where
cliutil/subcommands/default.go:17
↓ 11 callers
Method
Storage
()
db/peer.go:207
↓ 11 callers
Method
UnmarshalBinary
UnmarshalBinary decodes Version from binary form.
fs/clock/marshal.go:93
↓ 11 callers
Function
createAndConnectVolume
createAndConnectVolume creates a volume on app1 and connects app2 to it. It does all the necessary setup to authorize client to use resources on the s
fs/sync_test.go:36
↓ 10 callers
Method
Get
Get returns an available id from the pool. Get panics if the pool is exhausted; 2**64 should be enough for everyone.
idpool/idpool.go:18
↓ 10 callers
Method
IsPrivate
IsPrivate returns true if the key is private. Private keys can be used to store 64 bits of data in them, but cannot be stored persistently. See Privat
cas/key.go:70
↓ 10 callers
Method
IsSpecial
IsSpecial returns true if the key is special. Special keys are further categorized into: - Empty key: test with k == Empty - Private keys: test with
cas/key.go:59
↓ 10 callers
Function
compareLE
compareLE tests if A <= B.
fs/clock/vector.go:133
↓ 10 callers
Function
nle
(t testing.TB, a, b vector)
fs/clock/vector_test.go:96
↓ 9 callers
Method
Allow
(backend string)
db/peer.go:216
↓ 9 callers
Method
Error
()
util/edtls/client.go:26
↓ 9 callers
Method
UnmarshalBinary
(data []byte)
peer/peer.go:24
↓ 9 callers
Function
Usage
Usage returns a string suitable for use in a command line synopsis. Struct tags with the key "positional" can be used to control the usage message. T
cliutil/positional/usage.go:55
↓ 9 callers
Function
emptyBlob
(t testing.TB, chunkStore chunks.Store)
cas/blobs/blobs_test.go:15
↓ 9 callers
Function
le
(t testing.TB, a, b vector)
fs/clock/vector_test.go:88
↓ 8 callers
Method
Errno
()
fs/inodes/inodes.go:34
↓ 8 callers
Method
List
(inode uint64)
db/volumeDir.go:143
↓ 8 callers
Method
MarshalBinary
()
db/volumeID.go:16
↓ 8 callers
Function
NewKeyPrivate
NewKeyPrivate is like NewKey, but allows byte sequences in the private range. The private data can be extracted with the method Private. panics with
cas/key.go:143
↓ 8 callers
Method
Rename
(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node)
fs/dir.go:510
↓ 7 callers
Method
GetByName
(name string)
db/volume.go:56
↓ 7 callers
Function
New
(keyval kv.KV)
cas/chunks/kvchunks/kvchunks.go:56
↓ 7 callers
Function
Open
(path string)
kv/kvfiles/kvfiles.go:62
↓ 7 callers
Method
PeerAdd
(ctx context.Context, in *PeerAddRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:148
↓ 7 callers
Method
SharingKeyAdd
(ctx context.Context, in *SharingKeyAddRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:147
↓ 7 callers
Method
VolumeID
VolumeID copies the volume ID to out. out is valid after the transaction.
db/volume.go:184
↓ 7 callers
Function
dirKey
(parentInode uint64, name string)
db/volumeDir.go:17
↓ 7 callers
Method
pathToKey
(parentInode uint64, name string)
db/volumeClock.go:34
↓ 6 callers
Function
Allocate
Allocate returns the next available inode number, and marks it used. Returns ErrOutOfInodes if there are no free inodes.
fs/inodes/inodes.go:44
↓ 6 callers
Method
DialPeer
(pub *peer.PublicKey)
server/peer.go:51
↓ 6 callers
Method
IsReserved
IsReserved returns true if the key is reserved. Caller should never use reserved keys.
cas/key.go:87
↓ 6 callers
Method
ListCommands
ListCommands returns a list of the subcommands encountered. Index 0 is the topmost parent, last item is the active subcommand.
cliutil/subcommands/result.go:48
↓ 6 callers
Method
Locations
()
db/peer.go:169
↓ 6 callers
Function
New
(store kv.KV, secret *[32]byte)
kv/untrusted/untrusted.go:81
next →
1–100 of 1,400, ranked by callers