MCPcopy Create free account

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

↓ 8 callersMethodRoot
()
pkg/tcc/object/types.go:62
↓ 8 callersFunctionRunCLIWithDir
RunCLIWithDir runs the full tau CLI with config and session under dir. Use the same dir for multiple commands to share session state (e.g. login flow:
tools/tau/testutil/cli.go:45
↓ 8 callersMethodSub
(filter HostFilter)
pkg/mycelium/network.go:84
↓ 8 callersMethodSuccess
()
core/services/substrate/counters/path.go:18
↓ 8 callersFunctionValidator
(validator func(T) error)
pkg/tcc/engine/options.go:35
↓ 8 callersMethodVersion
()
core/services/substrate/components/storage/service.go:25
↓ 8 callersMethodWarning
(err error)
tools/tau/i18n/printer/printer.go:16
↓ 8 callersMethodWarningPrintfln
(format string, a ...any)
tools/tau/i18n/printer/printer.go:18
↓ 8 callersMethodWebSocket
()
pkg/schema/messaging/types.go:28
↓ 8 callersMethodWrapError
(format string, i ...any)
pkg/schema/basic/types.go:44
↓ 8 callersMethodacmeServiceHandler
(ctx context.Context, st streams.Connection, body command.Body)
services/auth/api_acme.go:152
↓ 8 callersFunctionattachNodesError
(name string, err error)
services/substrate/attach.go:17
↓ 8 callersFunctionattachSmartOpsFromTags
(returnMap map[string]interface{}, tags []string, application string, project projectSchema.Project, library s
pkg/config-compiler/compile/common.go:154
↓ 8 callersFunctionbyId
(u *Universe, i map[string]commonIface.Service, pid string)
dream/universeMethods.go:227
↓ 8 callersMethodcloseFile
closeFile decrements reference count and closes file if no more references
pkg/vm/logger/manager.go:55
↓ 8 callersFunctioncreateMockServiceContext
Helper function to create a mock service context
services/substrate/components/pubsub/websocket/handler_test.go:330
↓ 8 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/libraries/getter_test.go:14
↓ 8 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/domains/getter_test.go:14
↓ 8 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/website/getter_test.go:14
↓ 8 callersMethodfindContainerdBinary
findContainerdBinary finds the containerd binary path
pkg/containers/backends/containerd/daemon.go:350
↓ 8 callersFunctionfirst
(u *Universe, i map[string]commonIface.Service)
dream/universeMethods.go:239
↓ 8 callersFunctionfixtureFS
(virtual bool, dir ...string)
pkg/yaseer/utils_test.go:10
↓ 8 callersMethodgetContract
(contractId uint32)
pkg/vm-low-orbit/ethereum/contract_helpers.go:35
↓ 8 callersMethodgetSocketPath
getSocketPath returns the appropriate socket path
pkg/containers/backends/containerd/containerd.go:158
↓ 8 callersMethodgetTransaction
(module common.Module, clientId, blockIdPtr, contractId, transactionId uint32)
pkg/vm-low-orbit/ethereum/transaction.go:76
↓ 8 callersFunctiongetValue
(aq *yaseer.Query, attr *Attribute)
pkg/tcc/engine/node.go:223
↓ 8 callersFunctionhashFile
(r io.Reader)
pkg/spore-drive/config/all_test.go:73
↓ 8 callersFunctionmustMultiaddr
(t *testing.T, s string)
p2p/peer/addr_factory_test.go:159
↓ 8 callersFunctionnewRemote
(ctx context.Context, h host.Host)
pkg/spore-drive/drive/remote.go:31
↓ 8 callersFunctionnewStableStore
newStableStore creates a new StableStore backed by the given datastore
pkg/raft/storage.go:176
↓ 8 callersFunctionpanicIfPromptNotEnabled
(prompt string)
pkg/cli/prompts/constants.go:77
↓ 8 callersMethodrun
(got string)
pkg/specs/extract/extract_test.go:26
↓ 8 callersFunctionrunHandlerTest
Helper function to run a handler test with common setup
services/substrate/components/pubsub/websocket/handler_test.go:354
↓ 8 callersFunctionrunSourceValidation
(t *testing.T, obj object.Object[object.Refrence])
pkg/tcc/taubyte/v1/pass2/source_validation_test.go:13
↓ 8 callersMethodstart
Start the service and return the port it's running on.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:205
↓ 8 callersFunctiontestExpected
(expected string)
pkg/specs/extract/extract_test.go:22
↓ 8 callersFunctiontestRepoToken
(t *testing.T)
pkg/git/all_test.go:27
↓ 7 callersMethodAddress
()
pkg/spore-drive/config/hosts.go:37
↓ 7 callersFunctionBody
(body command.Body)
p2p/streams/client/client.go:87
↓ 7 callersMethodClose
()
core/services/substrate/components/p2p/service.go:23
↓ 7 callersMethodClose
()
pkg/mycelium/command/session.go:10
↓ 7 callersMethodColdStart
()
core/services/substrate/counters/path.go:8
↓ 7 callersMethodCompress
Compress takes a supported CompressionMethod, compress the files built by the Builder, and returns the ReadSeekCloser of the compressed file
core/builders/types.go:25
↓ 7 callersFunctionDecode
(s io.Reader)
p2p/streams/command/response/response.go:34
↓ 7 callersMethodDelete
(ctx context.Context)
services/auth/hooks/hooks.go:66
↓ 7 callersMethodDeleteRange
(min, max uint64)
pkg/raft/interfaces.go:106
↓ 7 callersMethodEmail
()
pkg/schema/project/types.go:47
↓ 7 callersMethodExists
Exists checks if the image exists locally
pkg/containers/backends/containerd/image.go:43
↓ 7 callersMethodFetchMetrics
FetchMetrics fetches metrics from the API
pkg/sensors/example/collector.go:44
↓ 7 callersFunctionFunctions
()
pkg/tcc/taubyte/v1/pass1/functions.go:13
↓ 7 callersMethodFunctions
Functions adds the function definitions to the HostModule
core/vm/host_module.go:30
↓ 7 callersMethodGet
(context.Context, *connect.Request[v1.GetJobInstanceRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/monkey.connect.go:45
↓ 7 callersMethodGetById
(resourceId string)
core/services/tns/client.go:63
↓ 7 callersMethodGetCount
()
pkg/taucorder/proto/gen/taucorder/v1/swarm.pb.go:250
↓ 7 callersMethodGetNodeID
(ctx context.Context)
pkg/sensors/example/collector.go:135
↓ 7 callersFunctionGetOrAskForAStringValue
(c *cli.Context, field string, label string, prev ...string)
tools/tau/prompts/string.go:57
↓ 7 callersFunctionGetOrRequireATimeout
(ctx *cli.Context, prev ...uint64)
tools/tau/prompts/timeout.go:10
↓ 7 callersFunctionGetOrSelectSource
(ctx *cli.Context, prev ...string)
tools/tau/prompts/source.go:16
↓ 7 callersMethodGetSelect
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:2703
↓ 7 callersMethodGlobal
(projectId string, branches ...string)
core/services/tns/client.go:71
↓ 7 callersFunctionHash
Hash returns the hash of a string or []byte using B58
utils/multihash/generate.go:8
↓ 7 callersMethodID
()
clients/http/auth/git/common/types.go:32
↓ 7 callersMethodId
()
pkg/spore-drive/config/hosts.go:30
↓ 7 callersFunctionInSet
(elms ...T)
pkg/tcc/engine/validators.go:61
↓ 7 callersFunctionLoad
()
tools/tau/clients/patrick_client/load.go:7
↓ 7 callersMethodLocation
(context.Context, *connect.Request[v1.LocationRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/seer.connect.go:48
↓ 7 callersMethodMatch
(s string)
pkg/tcc/engine/stringmatch.go:6
↓ 7 callersMethodMatcher
()
core/services/substrate/components/types.go:42
↓ 7 callersMethodMemoryRead
(offset uint32, size uint32)
pkg/vm-orbit/satellite/module_link.go:15
↓ 7 callersMethodMemoryWrite
(offset uint32, data []byte)
pkg/vm-orbit/satellite/module_link.go:28
↓ 7 callersFunctionNew
(options ...Option)
pkg/mycelium/network.go:24
↓ 7 callersFunctionNew
(options ...Option)
pkg/tcc/taubyte/v1/decompile/decompiler.go:27
↓ 7 callersFunctionNew
New creates a new MCP service using httpIface.Service
dream/mcp/service.go:36
↓ 7 callersMethodNew
(context.Context, *connect.Request[v1.Empty])
pkg/spore-drive/proto/gen/config/v1/configv1connect/config.connect.go:66
↓ 7 callersMethodNumber
()
services/substrate/components/counters/metrics/types.go:9
↓ 7 callersMethodPID
()
p2p/streams/client/client.go:122
↓ 7 callersFunctionPassword
(username, password string)
pkg/mycelium/host/attrs.go:111
↓ 7 callersMethodPublicKey
()
core/services/auth/secrets.go:35
↓ 7 callersMethodPull
Pull retrieves the image from a registry/repository
pkg/containers/backends/docker/image.go:24
↓ 7 callersMethodPushValue
(context.Context, *connect.Request[v1.PushValueRequest])
pkg/sensors/proto/gen/sensors/v1/sensorsv1connect/sensors.connect.go:44
↓ 7 callersMethodRegister
(ctx context.Context)
services/auth/repositories/repositories.go:56
↓ 7 callersMethodRepoID
()
tools/tau/cli/commands/resources/repository/types.go:13
↓ 7 callersFunctionRequiredPaths
(c *cli.Context, prev ...string)
tools/tau/prompts/paths.go:14
↓ 7 callersMethodReset
()
core/services/substrate/counters/metric.go:4
↓ 7 callersFunctionResolveNamesToId
(ct transform.Context[object.Refrence], group string, names []string)
pkg/tcc/taubyte/v1/utils/paths.go:88
↓ 7 callersMethodSensorsRegistry
()
config/services.go:75
↓ 7 callersMethodSetVariables
(vars map[string]interface{})
services/patrick/github_test.go:141
↓ 7 callersMethodSize
()
core/vm/memory.go:5
↓ 7 callersMethodStart
Start starts a container
pkg/containers/backends/docker/docker.go:317
↓ 7 callersFunctionStringSlice
(name string, options ...Option)
pkg/tcc/engine/helpers.go:54
↓ 7 callersMethodSync
Sync syncs the KVDB key values
core/kvdb/ifaces.go:42
↓ 7 callersFunctionTags
(value []string)
pkg/schema/application/set.go:15
↓ 7 callersFunctionUsageOneOfOption
(options []string)
tools/tau/flags/usage.go:8
↓ 7 callersFunctionValidateMinMax
ValidateMinMax checks that the value at maxKey is >= the value at minKey. If either key is missing or not an int, no error is returned (validation is
pkg/tcc/taubyte/v1/utils/minmax.go:12
↓ 7 callersFunctionWithEncryptionKey
WithEncryptionKey enables AES-256-GCM encryption for all transport and stream service messages. The key must be at least 32 bytes. All cluster members
pkg/raft/options.go:60
↓ 7 callersMethodWriteCid
(module common.Module, ptr uint32, value cid.Cid)
pkg/vm-low-orbit/helpers/types.go:53
↓ 7 callersMethod_build_op
Build operation with path.
pkg/spore-drive/clients/py/spore_drive/operations.py:48
↓ 7 callersMethod_load_run_file
Load the run file to get port and PID information.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:123
↓ 7 callersFunctioncleanupInterruptedMigration
cleanupInterruptedMigration handles cases where a previous migration was interrupted
p2p/helpers/datastore.go:37
↓ 7 callersFunctioncreateMockService
(publishFunc func(ctx context.Context, topic string, data []byte) error)
services/substrate/components/pubsub/websocket/datastream_test.go:190
← previousnext →801–900 of 13,103, ranked by callers