MCPcopy Index your code

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

↓ 3,635 callersMethodErrorf
(format string, args ...any)
pkg/builder/new.go:83
↓ 1,409 callersMethodError
()
pkg/http/types.go:144
↓ 851 callersMethodString
()
pkg/specs/builders/types.go:36
↓ 653 callersMethodGet
Get retrieves a value by key barrierNs is the barrier timeout in nanoseconds. If > 0, ensures consistency before reading. Must be > 0 and <= MaxGetHan
pkg/raft/client.go:23
↓ 593 callersMethodNew
(context.Context, *connect.Request[v1.HostConfig])
pkg/spore-drive/proto/gen/mock/v1/mockv1connect/ssh.connect.go:61
↓ 584 callersMethodChild
(any)
pkg/tcc/object/types.go:27
↓ 577 callersMethodSet
(T)
pkg/tcc/transform/types.go:27
↓ 565 callersMethodNew
New creates a new PluginInstance
core/vm/plugin.go:22
↓ 509 callersMethodJoin
(toJoin string)
core/services/substrate/counters/path.go:14
↓ 490 callersMethodClose
Close closes the client
pkg/raft/client.go:29
↓ 461 callersMethodRun
()
tools/tau/cli/common/types.go:30
↓ 457 callersFunctionNew
()
pkg/tcc/object/generic.go:22
↓ 427 callersMethodRun
(cmd string)
pkg/mycelium/command/session.go:13
↓ 403 callersMethodID
()
p2p/peer/type.go:42
↓ 344 callersMethodClose
()
p2p/peer/type.go:34
↓ 319 callersMethodAdd
(Object[T])
pkg/tcc/object/types.go:53
↓ 298 callersMethodSet
Set stores a key-value pair
pkg/raft/client.go:19
↓ 292 callersMethodUnlock
(jid string)
core/services/patrick/client.go:11
↓ 277 callersMethodContext
()
p2p/peer/type.go:35
↓ 274 callersMethodClose
()
services/substrate/runtime/types.go:63
↓ 255 callersMethodPeer
()
p2p/peer/type.go:47
↓ 230 callersMethodLock
(jid string, eta uint32)
core/services/patrick/client.go:9
↓ 213 callersMethodString
(string)
pkg/tcc/transform/types.go:18
↓ 206 callersMethodGet
Get will retrieve the key indexed data
core/kvdb/ifaces.go:18
↓ 194 callersMethodPut
Put will insert the data, indexed by key
core/kvdb/ifaces.go:21
↓ 193 callersMethodId
()
pkg/schema/basic/types.go:10
↓ 189 callersMethodProcess
(Context[T], object.Object[T])
pkg/tcc/transform/types.go:32
↓ 188 callersFunctionNewRaw
()
p2p/keypair/keypair.go:38
↓ 184 callersMethodNew
()
tools/tau/cli/common/types.go:17
↓ 182 callersMethodFork
(object.Object[T])
pkg/tcc/transform/types.go:12
↓ 175 callersMethodObject
(string)
pkg/tcc/transform/types.go:20
↓ 161 callersMethodCommit
(context.Context, *connect.Request[v1.Config])
pkg/spore-drive/proto/gen/config/v1/configv1connect/config.connect.go:70
↓ 158 callersMethodContext
()
pkg/http/types.go:140
↓ 158 callersMethodGet
()
pkg/tcc/transform/types.go:26
↓ 157 callersFunctionNew
New creates a new Raft cluster with the given namespace Nodes with the same namespace discover each other automatically
pkg/raft/cluster.go:61
↓ 153 callersFunctionNewContext
(c context.Context, root ...any)
pkg/tcc/transform/context.go:15
↓ 150 callersFunctionstressLog
stressLog writes a log entry to /tmp/stresstest.log
pkg/raft/cluster_stress_test.go:30
↓ 147 callersMethodCreatePath
(path ...string)
pkg/tcc/object/types.go:28
↓ 144 callersMethodClose
()
pkg/vm-orbit/satellite/vm/types.go:41
↓ 141 callersMethodGet
()
tools/tau/cli/commands/resources/repository/types.go:24
↓ 137 callersMethodAuth
()
pkg/spore-drive/config/parse.go:12
↓ 131 callersMethodNew
(context.Context, *connect.Request[v1.Config])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/node.connect.go:44
↓ 127 callersMethodDone
()
p2p/peer/type.go:39
↓ 126 callersMethodWaitForLeader
WaitForLeader blocks until a leader is elected
pkg/raft/interfaces.go:60
↓ 122 callersMethodMarshal
()
core/services/substrate/components/pubsub/service.go:26
↓ 122 callersMethodWrite
Write writes the slice to the underlying buffer at the offset or returns false if out of range.
core/vm/memory.go:61
↓ 116 callersMethodDescription
()
pkg/schema/basic/types.go:12
↓ 115 callersMethodError
Returns an error
core/vm/instance.go:102
↓ 114 callersMethodStat
()
pkg/specs/builders/types.go:41
↓ 112 callersMethodGet
()
pkg/schema/domains/types.go:11
↓ 110 callersMethodDocument
()
pkg/yaseer/node.go:67
↓ 109 callersMethodShapes
()
pkg/spore-drive/config/parse.go:11
↓ 108 callersMethodget
Get port value.
pkg/spore-drive/clients/py/spore_drive/operations.py:777
↓ 103 callersMethodSet
(string, T)
pkg/tcc/object/types.go:30
↓ 101 callersMethodInterface
()
pkg/schema/pretty/types.go:8
↓ 101 callersFunctionNew
New creates a new Factory instance
pkg/kvdb/mock/mock.go:56
↓ 100 callersFunctionString
String retrieves interface{} value from map and returns a string value.
utils/maps/data.go:124
↓ 99 callersMethodValue
(ctx *cli.Context)
pkg/cli/flags/types.go:6
↓ 96 callersMethodError
()
pkg/spore-drive/drive/progress.go:15
↓ 95 callersMethodGet
(string)
pkg/spore-drive/config/auth.go:12
↓ 95 callersMethodset
Set P2P configuration.
pkg/spore-drive/clients/py/spore_drive/operations.py:386
↓ 93 callersMethodName
()
pkg/schema/basic/types.go:11
↓ 93 callersMethodQuery
()
tools/tau/cli/common/types.go:20
↓ 93 callersFunctionWithTCCFixtureEnv
WithTCCFixtureEnv sets up config and session so that the selected project is the TCC fixture project (config + session in a temp dir). Restores config
tools/tau/testutil/tcc_fixture.go:30
↓ 90 callersMethodTns
Tns returns the Tns client attached to the Substrate
core/services/substrate/types.go:20
↓ 88 callersFunctionMock
(ctx context.Context)
p2p/peer/mock.go:23
↓ 88 callersMethodRead
(module common.Module, readMethod func(p []byte) (n int, err error), bufPtr, bufSize, // reader countPtr
pkg/vm-low-orbit/helpers/types.go:47
↓ 88 callersMethodStartWithConfig
Start universe based on config
dream/universe.go:253
↓ 88 callersFunctiontestOptions
testOptions returns common options for unit tests (fast timeouts + short bootstrap)
pkg/raft/cluster_test.go:35
↓ 87 callersMethodGet
(string)
pkg/tcc/object/types.go:31
↓ 87 callersMethodGet
()
pkg/schema/storages/types.go:11
↓ 87 callersMethodSimple
()
core/services/tns/client.go:34
↓ 87 callersFunctionnewMockNode
(t *testing.T)
pkg/raft/cluster_test.go:18
↓ 85 callersMethodApplication
(name string)
pkg/schema/project/types.go:26
↓ 85 callersFunctionnew
* TODO: build Flag const DeprecatedWasmBuild */ new sets the working directory and log file of the desired output
pkg/builder/output.go:25
↓ 84 callersMethodNode
()
core/common/service.go:6
↓ 83 callersFunctionDecode
Decode takes an input structure and uses reflection to translate it to the output structure. output must be a pointer to a map or struct.
utils/mapstructure/mapstructure.go:101
↓ 83 callersMethodTags
()
pkg/schema/application/types.go:26
↓ 83 callersFunctionVirtConfig
()
pkg/spore-drive/config/fixtures/virt.go:11
↓ 82 callersMethodDecode
CBOR encoding
core/kvdb/ifaces.go:68
↓ 81 callersMethodGetId
()
pkg/specs/structure/types.go:25
↓ 81 callersFunctionSet
()
tools/tau/session/setter.go:7
↓ 80 callersMethodShape
(string)
pkg/spore-drive/config/shapes.go:5
↓ 78 callersMethodSet
(sync bool, ops ...basic.Op)
pkg/schema/common/types.go:16
↓ 76 callersMethodDo
(context.Context, *connect.Request[v1.Op])
pkg/spore-drive/proto/gen/config/v1/configv1connect/config.connect.go:72
↓ 76 callersMethodGet
()
pkg/schema/databases/types.go:11
↓ 76 callersMethodLen
Len returns the number of items in the map
utils/cache/basic/cache.go:36
↓ 75 callersMethodCloud
()
pkg/spore-drive/config/parse.go:9
↓ 75 callersMethodGet
()
pkg/schema/functions/types.go:11
↓ 73 callersMethodUnmarshal
Unmarshal decodes CBOR data into the job and normalizes the repository (e.g. promotes SSHURL to URI).
core/services/patrick/types.go:55
↓ 72 callersMethodGet
()
pkg/schema/messaging/types.go:11
↓ 71 callersFunctionClear
()
tools/tau/session/vars.go:14
↓ 70 callersMethodCompat
()
dream/types.go:156
↓ 68 callersMethodDefine
(command string, handler router.CommandHandler)
p2p/streams/service/service.go:12
↓ 68 callersMethodKV
()
core/services/types.go:16
↓ 68 callersMethodPeering
()
p2p/peer/type.go:48
↓ 68 callersFunctionnewTestNode
newTestNode creates a real libp2p node for testing
pkg/raft/cluster_integration_test.go:40
↓ 67 callersMethodList
List will list all keys with the given prefix
core/kvdb/ifaces.go:27
↓ 67 callersMethodName
()
services/auth/projects/type.go:13
↓ 67 callersMethodSet
(...T)
pkg/spore-drive/config/list.go:7
next →1–100 of 13,103, ranked by callers