MCPcopy Create free account

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

⨍ Functions 13,103◇ Types & classes 2,320↳ Endpoints 13
↓ 5 callersMethod_call_unary
Make a unary gRPC call.
pkg/spore-drive/clients/py/spore_drive/clients.py:124
↓ 5 callersMethod_get_config_dir
Get the configuration directory based on platform.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:38
↓ 5 callersMethod_get_port
Get the port from the run file with timeout.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:188
↓ 5 callersFunction_setDeleteMap
(seer *Seer, path string, inner string, items map[string]string)
pkg/yaseer/delete_test.go:42
↓ 5 callersMethod_version_matches
Check if the installed version matches the expected version.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:52
↓ 5 callersMethod_wait_for_health_check
Wait for health check to pass with retries.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:163
↓ 5 callersFunctionassertDeepEqualSortedStrings
(t *testing.T, a, b []string)
pkg/spore-drive/config/all_test.go:15
↓ 5 callersFunctionassertDomain1
(t *testing.T, getter domains.Getter)
pkg/schema/domains/getter_test.go:27
↓ 5 callersFunctionassertFunction2_pubsub
(t *testing.T, getter functions.Getter)
pkg/schema/functions/getter_test.go:50
↓ 5 callersFunctionassertLibrary1
(t *testing.T, getter libraries.Getter)
pkg/schema/libraries/getter_test.go:27
↓ 5 callersFunctionassertLibrary2
(t *testing.T, getter libraries.Getter)
pkg/schema/libraries/getter_test.go:44
↓ 5 callersFunctionassertWebsite1
(t *testing.T, getter website.Getter)
pkg/schema/website/getter_test.go:27
↓ 5 callersFunctionassertWebsite2
(t *testing.T, getter website.Getter)
pkg/schema/website/getter_test.go:45
↓ 5 callersFunctionbuildTau
buildTau builds the tau CLI into dir and returns the path to the binary. Uses dir/bin/tau so that dir/tau can be used as the session root (TMPDIR/tau)
tools/tau/session/integration_test.go:37
↓ 5 callersFunctionclientErr
(msg string, args ...any)
pkg/vm-orbit/link/client.go:13
↓ 5 callersMethodcommit
()
pkg/spore-drive/clients/js/src/Config.ts:94
↓ 5 callersMethodcommit
Commit DNS record changes to Namecheap.
pkg/spore-drive/clients/py/example/namecheap_client.py:181
↓ 5 callersMethodcreate
Factory method to create and initialize a drive. Args: config: Configuration for the drive tau: Opti
pkg/spore-drive/clients/py/spore_drive/drive.py:58
↓ 5 callersFunctioncreateMockConnection
(readFunc func() (int, []byte, error), writeFunc func(messageType int, data []byte) error)
services/substrate/components/pubsub/websocket/datastream_test.go:196
↓ 5 callersMethodcreateOCISpec
createOCISpec creates an OCI spec for the container configuration
pkg/containers/backends/containerd/containerd.go:253
↓ 5 callersFunctioncreatePatrickService
(u *dream.Universe, config *iface.ServiceConfig)
services/patrick/dream/init.go:18
↓ 5 callersMethoddataKey
dataKey returns the datastore key for a given user key
pkg/raft/fsm.go:61
↓ 5 callersFunctiondefAttr
(name string, _type Type, options []Option)
pkg/tcc/engine/helpers.go:25
↓ 5 callersFunctiondeleteKey
(key string)
tools/tau/session/helpers.go:79
↓ 5 callersMethoddetectRootlessMode
detectRootlessMode detects if we should run in rootless mode
pkg/containers/backends/containerd/containerd.go:93
↓ 5 callersFunctionempty
(t *testing.T, fun functions.Function)
pkg/schema/functions/delete_test.go:11
↓ 5 callersMethodequals
(a: Host | PlainMessage<Host> | undefined, b: Host | PlainMessage<Host> | undefined)
pkg/spore-drive/clients/js/gen/mock/v1/ssh_pb.ts:84
↓ 5 callersMethodequals
(a: Drive | PlainMessage<Drive> | undefined, b: Drive | PlainMessage<Drive> | undefined)
pkg/spore-drive/clients/js/gen/drive/v1/drive_pb.ts:163
↓ 5 callersMethodequals
(a: WaitRequest | PlainMessage<WaitRequest> | undefined, b: WaitRequest | PlainMessage<WaitRequest> | undefine
pkg/taucorder/clients/js/gen/taucorder/v1/swarm_pb.ts:52
↓ 5 callersMethodequals
(a: TNSPath | PlainMessage<TNSPath> | undefined, b: TNSPath | PlainMessage<TNSPath> | undefined)
pkg/taucorder/clients/js/gen/taucorder/v1/tns_pb.ts:186
↓ 5 callersFunctionfile_taucorder_v1_node_proto_rawDescGZIP
()
pkg/taucorder/proto/gen/taucorder/v1/node.pb.go:466
↓ 5 callersFunctionfilesystemFromBundle
(bundle []byte, base string)
pkg/spore-drive/config/service/serve.go:66
↓ 5 callersMethodfindRootlesskitBinary
findRootlesskitBinary finds the rootlesskit binary path
pkg/containers/backends/containerd/daemon.go:364
↓ 5 callersMethodformat
(msg string, args []interface{})
pkg/raft/transport.go:43
↓ 5 callersMethodfree
()
pkg/spore-drive/clients/js/src/Drive.ts:67
↓ 5 callersMethodfromBinary
(bytes: Uint8Array, options?: Partial<BinaryReadOptions>)
pkg/spore-drive/clients/js/gen/mock/v1/ssh_pb.ts:72
↓ 5 callersMethodfromBinary
(bytes: Uint8Array, options?: Partial<BinaryReadOptions>)
pkg/spore-drive/clients/js/gen/drive/v1/drive_pb.ts:151
↓ 5 callersMethodfromBinary
(bytes: Uint8Array, options?: Partial<BinaryReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/swarm_pb.ts:40
↓ 5 callersMethodfromBinary
(bytes: Uint8Array, options?: Partial<BinaryReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/tns_pb.ts:174
↓ 5 callersMethodfromJson
(jsonValue: JsonValue, options?: Partial<JsonReadOptions>)
pkg/spore-drive/clients/js/gen/mock/v1/ssh_pb.ts:76
↓ 5 callersMethodfromJson
(jsonValue: JsonValue, options?: Partial<JsonReadOptions>)
pkg/spore-drive/clients/js/gen/drive/v1/drive_pb.ts:155
↓ 5 callersMethodfromJson
(jsonValue: JsonValue, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/swarm_pb.ts:44
↓ 5 callersMethodfromJson
(jsonValue: JsonValue, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/tns_pb.ts:178
↓ 5 callersMethodfromJsonString
(jsonString: string, options?: Partial<JsonReadOptions>)
pkg/spore-drive/clients/js/gen/mock/v1/ssh_pb.ts:80
↓ 5 callersMethodfromJsonString
(jsonString: string, options?: Partial<JsonReadOptions>)
pkg/spore-drive/clients/js/gen/drive/v1/drive_pb.ts:159
↓ 5 callersMethodfromJsonString
(jsonString: string, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/swarm_pb.ts:48
↓ 5 callersMethodfromJsonString
(jsonString: string, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/tns_pb.ts:182
↓ 5 callersFunctiongenerateWildCardDomain
(fqdn string)
services/auth/helpers.go:10
↓ 5 callersMethodget
(self, name: str)
pkg/spore-drive/clients/py/spore_drive/operations.py:553
↓ 5 callersMethodget
(self, name: str)
pkg/spore-drive/clients/py/spore_drive/operations.py:695
↓ 5 callersMethodgetACMECertificate
(ctx context.Context, fqdn string)
services/auth/api_acme.go:47
↓ 5 callersMethodgetClientAndContent
(clientId, contentId uint32)
pkg/vm-low-orbit/ipfs/client/client.go:52
↓ 5 callersMethodgetCourse
(cId string)
pkg/spore-drive/drive/service/course.go:39
↓ 5 callersMethodgetDrive
(driveId string)
pkg/spore-drive/drive/service/drive.go:39
↓ 5 callersMethodgetEventWriter
(eventID uint32)
pkg/vm-low-orbit/event/event.go:69
↓ 5 callersMethodgetUniverse
(ctx httpIface.Context)
dream/api/helpers.go:10
↓ 5 callersMethodhandle
()
services/monkey/jobs/types.go:57
↓ 5 callersMethodhasRootlesskit
hasRootlesskit returns true if rootlesskit is available
pkg/containers/backends/containerd/rootless.go:55
↓ 5 callersFunctioninitializePlugin
(extraArgs ...string)
pkg/vm-orbit/tests/e2e/go/utils_test.go:39
↓ 5 callersMethodisRootlessMode
isRootlessMode returns true if running in rootless mode
pkg/containers/backends/containerd/containerd.go:123
↓ 5 callersFunctionkeyFromPath
(path []string)
services/tns/engine/keys.go:10
↓ 5 callersMethodlist
Get all DNS records.
pkg/spore-drive/clients/py/example/namecheap_client.py:142
↓ 5 callersMethodlist
(branch, commit, projectId, appId string)
clients/p2p/tns/structure/list.go:9
↓ 5 callersFunctionmatchPathPrefix
matchPathPrefix returns a gock MatchFunc that matches when the request path has the given prefix.
tools/tau/testutil/authmock.go:141
↓ 5 callersFunctionparseIfEmpty
(v string)
tools/tau/cli/commands/current/command.go:17
↓ 5 callersFunctionparseSessionPIDs
parseSessionPIDs parses a session file/dir base name (new variable-length format). Format: "tau-session-<p0>-<p1>-...-<pN>" (all numeric parts). Retur
tools/tau/session/discovery.go:165
↓ 5 callersMethodpush
(ctx context.Context, name string, value float64)
pkg/sensors/example/collector.go:145
↓ 5 callersFunctionremoveSubscription
(name string, subIdx int)
services/substrate/components/pubsub/websocket/handler.go:95
↓ 5 callersFunctionreturnBytes
(s []byte)
pkg/spore-drive/config/service/utils.go:20
↓ 5 callersFunctionrunTau
runTau runs the tau binary with TMPDIR and TAU_CONFIG_FILE set so session and config use dir.
tools/tau/session/integration_test.go:55
↓ 5 callersFunctionsetKey
(key string, value any)
tools/tau/session/helpers.go:61
↓ 5 callersFunctionsetupEnv
(t *testing.T)
tools/tau/clients/auth_client/client_test.go:17
↓ 5 callersFunctionsetupEnv
(t *testing.T)
tools/tau/clients/patrick_client/load_test.go:16
↓ 5 callersMethodsetupHookInAuth
(hookID, secret string)
services/patrick/github_test.go:84
↓ 5 callersMethodsetupStreamRoutes
()
services/auth/stream.go:12
↓ 5 callersFunctionstartDream
(t *testing.T)
services/monkey/jobs/utils_test.go:161
↓ 5 callersFunctionstorageError
(ctx storageIface.Context)
services/substrate/components/storage/storage/new.go:14
↓ 5 callersFunctionsuccess
(prefix, name string)
tools/tau/i18n/project/success.go:7
↓ 5 callersFunctionsuccess
(prefix, name string)
tools/tau/i18n/application/success.go:7
↓ 5 callersMethodtestSocketConnection
testSocketConnection checks if we can connect to the containerd socket.
pkg/containers/backends/containerd/containerd.go:747
↓ 5 callersFunctiontoInt64
(v interface{})
pkg/raft/client.go:414
↓ 5 callersMethodtokenDomainHTTPHandler
(ctx http.Context)
services/auth/domains_http_endpoints.go:13
↓ 5 callersMethodvalidateMountPermissions
validateMountPermissions validates if a mount operation will work with current UID/GID mapping
pkg/containers/backends/containerd/rootless.go:106
↓ 5 callersFunctionverifyAllVoters
verifyAllVoters verifies all nodes are voters in the cluster
pkg/raft/cluster_stress_test.go:250
↓ 5 callersFunctionverifyClusterStability
verifyClusterStability verifies the cluster is stable (leader doesn't change, no state changes)
pkg/raft/cluster_stress_test.go:398
↓ 5 callersFunctionverifyFSMCoherence
verifyFSMCoherence verifies that FSM state is coherent across all nodes It writes values on the leader, uses Barrier to ensure replication, then reads
pkg/raft/cluster_stress_test.go:459
↓ 5 callersMethodwith_latest_tau
Factory method to create a drive with the latest tau binary. Args: config: Configuration for the drive
pkg/spore-drive/clients/py/spore_drive/drive.py:75
↓ 5 callersFunctionwriteValueToPath
(query *yaseer.Query, path []StringMatch, attr *Attribute, val interface{}, obj object.Object[object.Refrence]
pkg/tcc/engine/dump.go:181
↓ 4 callersMethodApiDomainServiceHandler
******* DOMAIN ********/ ApiDomainServiceHandler handles domain-related p2p stream requests
services/auth/api_hooks.go:270
↓ 4 callersFunctionApplications
()
pkg/tcc/taubyte/v1/decompile/pass3/applications.go:12
↓ 4 callersFunctionApplications
()
pkg/tcc/taubyte/v1/pass1/applications.go:12
↓ 4 callersMethodBeacon
(location Location)
core/services/seer/client.go:6
↓ 4 callersMethodBind
(interface{})
core/services/tns/client.go:16
↓ 4 callersFunctionBootstrap
Bootstrap is an optional helper to connect to the given peers and bootstrap the Peer DHT (and Bitswap). This is a best-effort function. Errors are onl
p2p/helpers/libp2p.go:264
↓ 4 callersFunctionBranch
(value string)
pkg/schema/libraries/set.go:24
↓ 4 callersFunctionBranch
(value string)
pkg/schema/website/set.go:28
↓ 4 callersFunctionBridges
(mqtt bool, websocket bool)
pkg/schema/messaging/set.go:22
↓ 4 callersMethodBroadcast
Broadcast publishes some data.
pkg/kvdb/broadcaster.go:98
↓ 4 callersFunctionCall
(value string)
pkg/schema/functions/set.go:33
↓ 4 callersFunctionChannel
(regex bool, match string)
pkg/schema/messaging/set.go:12
← previousnext →1,201–1,300 of 13,103, ranked by callers