MCPcopy Create free account

hub / github.com/bazil/bazil / functions

Functions1,400 in github.com/bazil/bazil

↓ 178 callersMethodClose
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 callersMethodSize
Size returns the current byte size of the Blob.
cas/blobs/blobs.go:474
↓ 64 callersMethodGet
(ctx context.Context, key []byte)
kv/iface.go:8
↓ 58 callersMethodUnmarshal
Unmarshal the directory entry to out. out is valid after the transaction.
db/volumeDir.go:202
↓ 56 callersMethodClose
()
server/server.go:111
↓ 52 callersMethodCleanup
()
util/tempdir/tempdir.go:15
↓ 52 callersFunctionNew
(t testing.TB)
util/tempdir/tempdir.go:58
↓ 51 callersMethodSubdir
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 callersMethodUpdate
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 callersMethodPut
(ctx context.Context, key, value []byte)
kv/iface.go:9
↓ 39 callersMethodIO
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 callersMethodAdd
Add a chunk to the chunk store.
cas/chunks/chunks.go:34
↓ 37 callersMethodupdate
(id Peer, now Epoch)
fs/clock/vector.go:66
↓ 36 callersMethodValidateFile
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 callersMethodName
Name returns the basename of this directory entry. name is valid after the transaction.
db/volumeDir.go:195
↓ 33 callersMethodString
()
fs/clock/clock.go:154
↓ 31 callersMethodView
View calls the function inside a database transaction.
fs/dir.go:106
↓ 27 callersFunctionSync
Sync returns what action receiving state from A to B should cause us to take.
fs/clock/clock.go:213
↓ 27 callersMethodVolumes
()
db/volume.go:43
↓ 25 callersFunctionCreate
Create returns a new Vector Pair that knows it was created by id at time now.
fs/clock/clock.go:63
↓ 25 callersFunctionOpen
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 callersMethodPeers
()
db/peer.go:39
↓ 25 callersFunctionRegister
Register this command on the default Shell.
cliutil/subcommands/default.go:8
↓ 25 callersMethodResolveTheirs
ResolveTheirs records a conflict resolution in favor of other.
fs/clock/clock.go:128
↓ 25 callersMethodVolumeSync
(ctx context.Context, in *VolumeSyncRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:146
↓ 25 callersMethodbucket
(tx *db.Tx)
fs/fs.go:48
↓ 23 callersMethodAddr
()
server/http/http.go:34
↓ 23 callersFunctionDial
(path string, opts ...grpc.DialOption)
util/grpcunix/grpcunix.go:7
↓ 23 callersFunctionNewControlClient
(cc *grpc.ClientConn)
server/control/wire/control.pb.go:158
↓ 22 callersFunctionListenAndServe
(t testing.TB, wg *sync.WaitGroup, app *server.App)
server/control/controltest/controltest.go:11
↓ 22 callersMethodOpen
(ctx context.Context, req *fuse.OpenRequest, resp *fuse.OpenResponse)
fs/file.go:103
↓ 22 callersMethodReadAt
ReadAt reads data from the given offset. See io.ReaderAt.
cas/blobs/blobs.go:237
↓ 21 callersMethodSave
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 callersMethodClose
()
server/control/server.go:40
↓ 20 callersMethodCreate
(ctx context.Context, req *fuse.CreateRequest, resp *fuse.CreateResponse)
fs/dir.go:328
↓ 20 callersMethodWriteAt
WriteAt writes data to the given offset. See io.WriterAt.
cas/blobs/blobs.go:443
↓ 19 callersMethodBytes
Bytes returns a byte slice with the byte content of the key.
cas/key.go:47
↓ 19 callersMethodWrite
(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse)
fs/file.go:116
↓ 18 callersMethodError
()
kv/error.go:15
↓ 17 callersFunctionServeHTTP
(t testing.TB, wg *sync.WaitGroup, app *server.App)
server/http/httptest/httptest.go:12
↓ 17 callersMethodUpdate
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 callersMethodError
()
fs/inodes/inodes.go:30
↓ 16 callersMethodRemove
(ctx context.Context, req *fuse.RemoveRequest)
fs/dir.go:473
↓ 16 callersMethodSharingKeys
()
db/sharingKey.go:46
↓ 16 callersMethodUpdateSync
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 callersMethodmerge
(other vector)
fs/clock/vector.go:77
↓ 15 callersMethodDirs
Dirs provides a way of accessing the directory entries stored in this volume.
db/volume.go:205
↓ 15 callersMethodFirst
()
db/peer.go:144
↓ 14 callersMethodClock
()
db/volume.go:193
↓ 14 callersMethodClose
()
server/http/http.go:23
↓ 14 callersMethodGet
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 callersFunctionNew
(dataDir string, options ...AppOption)
server/server.go:46
↓ 14 callersFunctionParse
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 callersMethodSet
(string)
cliutil/positional/parse.go:30
↓ 14 callersMethodUpdateFromParent
UpdateFromParent simplifies child sync times based on the parent.
fs/clock/clock.go:116
↓ 14 callersFunctionsetLocation
setLocation sets the location of peer identified by pub in app to loc.
fs/sync_test.go:140
↓ 13 callersMethodConflicts
()
db/volume.go:198
↓ 13 callersFunctionNewKey
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 callersMethodControl
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 callersMethodCursor
()
db/peer.go:117
↓ 12 callersMethodMake
Make returns a Peer for the given public key, adding it if necessary.
db/peer.go:69
↓ 12 callersMethodString
()
cliutil/flagx/tcpaddr.go:16
↓ 12 callersMethodUpdateFromChild
UpdateFromChild tracks child modification times in the parent. Return value reports whether s changed.
fs/clock/clock.go:110
↓ 11 callersMethodError
()
cliutil/subcommands/shell.go:88
↓ 11 callersMethodMkdir
(ctx context.Context, req *fuse.MkdirRequest)
fs/dir.go:430
↓ 11 callersMethodNext
()
fs/snap/reader.go:54
↓ 11 callersFunctionParse
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 callersMethodStorage
()
db/peer.go:207
↓ 11 callersMethodUnmarshalBinary
UnmarshalBinary decodes Version from binary form.
fs/clock/marshal.go:93
↓ 11 callersFunctioncreateAndConnectVolume
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 callersMethodGet
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 callersMethodIsPrivate
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 callersMethodIsSpecial
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 callersFunctioncompareLE
compareLE tests if A <= B.
fs/clock/vector.go:133
↓ 10 callersFunctionnle
(t testing.TB, a, b vector)
fs/clock/vector_test.go:96
↓ 9 callersMethodAllow
(backend string)
db/peer.go:216
↓ 9 callersMethodError
()
util/edtls/client.go:26
↓ 9 callersMethodUnmarshalBinary
(data []byte)
peer/peer.go:24
↓ 9 callersFunctionUsage
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 callersFunctionemptyBlob
(t testing.TB, chunkStore chunks.Store)
cas/blobs/blobs_test.go:15
↓ 9 callersFunctionle
(t testing.TB, a, b vector)
fs/clock/vector_test.go:88
↓ 8 callersMethodErrno
()
fs/inodes/inodes.go:34
↓ 8 callersMethodList
(inode uint64)
db/volumeDir.go:143
↓ 8 callersMethodMarshalBinary
()
db/volumeID.go:16
↓ 8 callersFunctionNewKeyPrivate
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 callersMethodRename
(ctx context.Context, req *fuse.RenameRequest, newDir fs.Node)
fs/dir.go:510
↓ 7 callersMethodGetByName
(name string)
db/volume.go:56
↓ 7 callersFunctionNew
(keyval kv.KV)
cas/chunks/kvchunks/kvchunks.go:56
↓ 7 callersFunctionOpen
(path string)
kv/kvfiles/kvfiles.go:62
↓ 7 callersMethodPeerAdd
(ctx context.Context, in *PeerAddRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:148
↓ 7 callersMethodSharingKeyAdd
(ctx context.Context, in *SharingKeyAddRequest, opts ...grpc.CallOption)
server/control/wire/control.pb.go:147
↓ 7 callersMethodVolumeID
VolumeID copies the volume ID to out. out is valid after the transaction.
db/volume.go:184
↓ 7 callersFunctiondirKey
(parentInode uint64, name string)
db/volumeDir.go:17
↓ 7 callersMethodpathToKey
(parentInode uint64, name string)
db/volumeClock.go:34
↓ 6 callersFunctionAllocate
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 callersMethodDialPeer
(pub *peer.PublicKey)
server/peer.go:51
↓ 6 callersMethodIsReserved
IsReserved returns true if the key is reserved. Caller should never use reserved keys.
cas/key.go:87
↓ 6 callersMethodListCommands
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 callersMethodLocations
()
db/peer.go:169
↓ 6 callersFunctionNew
(store kv.KV, secret *[32]byte)
kv/untrusted/untrusted.go:81
next →1–100 of 1,400, ranked by callers