MCPcopy Create free account

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

↓ 7 callersFunctioncreateTestHandler
Helper functions to reduce test duplication
services/substrate/components/pubsub/websocket/datastream_test.go:177
↓ 7 callersFunctiondecryptResponse
decryptResponse decrypts a response from stream service
pkg/raft/encryption.go:181
↓ 7 callersMethoddelete
Delete host.
pkg/spore-drive/clients/py/spore_drive/operations.py:507
↓ 7 callersFunctiondiscoverOrCreateConfigFileLoc
()
tools/tau/session/discovery.go:226
↓ 7 callersMethodduration
()
services/substrate/mocks/counters/report/metric.go:13
↓ 7 callersFunctionencrypt
(data []byte, password string)
cli/app/protect.go:41
↓ 7 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/messaging/getter_test.go:14
↓ 7 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/services/getter_test.go:14
↓ 7 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/storages/getter_test.go:14
↓ 7 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/smartops/getter_test.go:14
↓ 7 callersFunctioneql
(t *testing.T, a [][]any)
pkg/schema/databases/getter_test.go:14
↓ 7 callersFunctionextractIdFromKey
(list []string, split string, index int)
services/auth/helpers.go:27
↓ 7 callersFunctionfile_taucorder_v1_seer_proto_rawDescGZIP
()
pkg/taucorder/proto/gen/taucorder/v1/seer.pb.go:695
↓ 7 callersFunctiongenerateKey
()
services/auth/github.go:89
↓ 7 callersMethodgetACMECache
(ctx context.Context, key string)
services/auth/api_acme.go:96
↓ 7 callersMethodgetACMEStaticCertificate
(ctx context.Context, fqdn string)
services/auth/api_acme.go:69
↓ 7 callersMethodgetClient
(name string)
dream/simple.go:24
↓ 7 callersMethodgetDatabase
(databaseId uint32)
pkg/vm-low-orbit/database/client/database.go:21
↓ 7 callersFunctiongetKind
(val reflect.Value)
utils/mapstructure/mapstructure.go:1336
↓ 7 callersMethodhandler
(msg *pubsub.Message)
services/substrate/components/pubsub/websocket/handler.go:77
↓ 7 callersMethodhas_existing_service
Check if there's an existing service running and return (is_running, port).
pkg/spore-drive/clients/py/spore_drive/service_manager.py:273
↓ 7 callersMethodinit
(url: string)
pkg/spore-drive/clients/js/src/Drive.ts:57
↓ 7 callersMethodinitClient
initClient initializes the Docker client
pkg/containers/backends/docker/docker.go:132
↓ 7 callersMethodisRunning
isRunning checks if the containerd daemon is running
pkg/containers/backends/containerd/daemon.go:326
↓ 7 callersFunctionjoin
(basePath Path, toJoin v)
core/services/substrate/counters/path.go:33
↓ 7 callersMethodloadYamlDocument
(path string)
pkg/yaseer/root.go:130
↓ 7 callersFunctionlocalResolveNameToId
(store transform.Store[object.Refrence], ctp []any, group, name string)
pkg/tcc/taubyte/v1/utils/paths.go:48
↓ 7 callersFunctionmakeAddrsFactory
(announce []string, noAnnounce []string)
p2p/peer/addr_factory.go:10
↓ 7 callersMethodmergePeers
mergePeers merges peer info from another node and returns newly discovered peer IDs theirStart is when the other node started, theirPeers maps peer ID
pkg/raft/discovery.go:67
↓ 7 callersFunctionnewInternalClient
newInternalClient creates a new internal raft p2p client for the given namespace
pkg/raft/client.go:48
↓ 7 callersFunctionnewJob
(repo commonTest.Repository, jobId string)
services/monkey/jobs/utils_test.go:128
↓ 7 callersFunctionnewMockConfigurable
()
pkg/http/options/all_test.go:14
↓ 7 callersFunctionnewTestContext
(ctx context.Context, simple *dream.Simple, logFile *os.File)
services/monkey/jobs/utils_test.go:30
↓ 7 callersFunctionserverError
(format string, args ...interface{})
pkg/vm-orbit/satellite/helpers.go:56
↓ 7 callersMethoduint
()
services/substrate/mocks/counters/report/metric.go:5
↓ 6 callersMethodAccept
()
pkg/raft/transport.go:177
↓ 6 callersMethodAddJob
(t *testing.T, peerC peer.Node, job *patrick.Job)
clients/p2p/patrick/mock/patrick_struct.go:34
↓ 6 callersFunctionAuth
Auth returns an Option that will set the auth token of the client
clients/http/options.go:49
↓ 6 callersMethodBody
()
pkg/http/types.go:121
↓ 6 callersFunctionBranch
* Branch is an Option to set the repository branch. * * branch: The branch to use. */
pkg/git/options.go:147
↓ 6 callersMethodCache
()
core/services/substrate/components/types.go:12
↓ 6 callersFunctionCall
(value string)
pkg/schema/smartops/set.go:29
↓ 6 callersMethodCapacity
()
core/services/substrate/components/storage/service.go:46
↓ 6 callersMethodCheckout
()
tools/tau/cli/common/types.go:26
↓ 6 callersMethodCollectAndPush
(ctx context.Context)
pkg/sensors/example/collector.go:104
↓ 6 callersMethodCombined
Combined returns the Stderr, and Stdout combined container logs.
pkg/containers/mux.go:10
↓ 6 callersFunctionCompat
(path ...StringMatch)
pkg/tcc/engine/options.go:23
↓ 6 callersMethodDELETE
(*RouteDefinition)
pkg/http/types.go:149
↓ 6 callersMethodDatabaseStats
()
core/services/patrick/client.go:18
↓ 6 callersFunctionDatabases
()
pkg/tcc/taubyte/v1/pass1/databases.go:13
↓ 6 callersMethodDatabases
(string)
pkg/schema/project/types.go:52
↓ 6 callersMethodDefineStream
(command string, std router.CommandHandler, stream router.StreamHandler)
p2p/streams/service/service.go:13
↓ 6 callersFunctionDescription
(value string)
pkg/schema/application/set.go:11
↓ 6 callersMethodDomain
()
core/services/tns/client.go:36
↓ 6 callersMethodEncode
(s io.Writer)
p2p/streams/command/response/response.go:14
↓ 6 callersMethodExecution
()
core/services/substrate/counters/path.go:9
↓ 6 callersMethodFetch
(PrettierFetchMethod)
pkg/schema/internal/test/prettier.go:13
↓ 6 callersMethodForceContext
Used in tests for setting the unexported contexts
services/monkey/jobs/context.go:12
↓ 6 callersMethodGet
(name string)
pkg/sensors/registry.go:48
↓ 6 callersMethodGetKey
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:1981
↓ 6 callersFunctionGetMatchRegex
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/channel_match.go:18
↓ 6 callersFunctionGetOrAskForAStringValue
(c *cli.Context, field string, label string, prev ...string)
pkg/cli/prompts/string.go:56
↓ 6 callersFunctionGetOrAskForEmbedToken
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/embed_token.go:8
↓ 6 callersFunctionGetOrAskForLocal
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/local.go:8
↓ 6 callersFunctionGetOrRequireACall
TODO parse the source, and make this a selection based on exported functions.
tools/tau/prompts/call.go:15
↓ 6 callersFunctionGetOrRequireMemoryAndType
(ctx *cli.Context, new bool, prev ...uint64)
tools/tau/prompts/memory.go:33
↓ 6 callersFunctionGetOrSelectLanguage
(ctx *cli.Context, prev ...string)
tools/tau/prompts/language.go:29
↓ 6 callersMethodGetPortHttp
(node peer.Node)
dream/universe.go:180
↓ 6 callersFunctionGetSelectedUser
GetSelectedUser returns selected profile: session first, then profileFromProject, then config default.
tools/tau/config/selected.go:51
↓ 6 callersMethodGetSize
(ctx context.Context, key datastore.Key)
p2p/datastores/mem/mem.go:66
↓ 6 callersMethodGetType
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:303
↓ 6 callersMethodGetURLHttp
(node peer.Node)
dream/universe.go:216
↓ 6 callersMethodGitHubTokenHTTPAuthCleanup
(ctx http.Context)
core/services/types.go:26
↓ 6 callersFunctionId
(value string)
pkg/schema/smartops/set.go:5
↓ 6 callersMethodImage
Image returns an Image interface for the given image name
pkg/containers/backends/docker/docker.go:161
↓ 6 callersMethodIn
()
services/substrate/components/pubsub/websocket/datastream.go:37
↓ 6 callersFunctionIndexOf
TODO "golang.org/x/exp/slices"
tools/tau/cli/args/helpers.go:4
↓ 6 callersMethodInfoPrintln
(a ...any)
tools/tau/i18n/printer/printer.go:13
↓ 6 callersMethodInitialize
(parentCommand *cli.Command, baseCommand *cli.Command, baseOps []Option)
tools/tau/cli/common/types.go:13
↓ 6 callersFunctionIsAny
(val string, tests ...func(val string) bool)
tools/tau/validate/bool_helpers.go:9
↓ 6 callersFunctionIsInt
(val string)
tools/tau/validate/bool_helpers.go:18
↓ 6 callersFunctionMatchAllString
(val string, expressions [][]string)
tools/tau/validate/helpers.go:9
↓ 6 callersFunctionMemory
(value string)
pkg/schema/smartops/set.go:25
↓ 6 callersMethodMonkey
()
pkg/taucorder/clients/js/src/Taucorder.ts:109
↓ 6 callersFunctionNameWithDefault
(c *cli.Command, def string)
tools/dream/cli/command/name.go:11
↓ 6 callersFunctionNew
(ctx context.Context, node peer.Node, config *config.Node, ops ...options.Option)
pkg/http-auto/new.go:26
↓ 6 callersFunctionNew
(interval time.Duration, opts ...Option)
pkg/cli/io/progress/progressreader.go:68
↓ 6 callersFunctionNew
(node peer.Node)
pkg/vm/backend/dfs/backend.go:20
↓ 6 callersFunctionNew
(peer peer.Node, name string, path string)
p2p/streams/service/service.go:26
↓ 6 callersFunctionNew
(ctx context.Context, node peer.Node, cacheDir string)
services/auth/acme/store/store.go:45
↓ 6 callersMethodNew
(context.Context, *connect.Request[v1.DriveRequest])
pkg/spore-drive/proto/gen/drive/v1/drivev1connect/drive.connect.go:63
↓ 6 callersMethodObject
()
pkg/tcc/object/generic.go:360
↓ 6 callersMethodPassword
()
pkg/spore-drive/config/auth.go:19
↓ 6 callersFunctionPath
(name, folder string)
tools/tau/lib/codefile/path.go:11
↓ 6 callersMethodPing
(context.Context, *connect.Request[v1.PingRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/swarm.connect.go:52
↓ 6 callersFunctionProcessProjectIDValidation
ProcessProjectIDValidation runs project ID validation from TCC compiler.
utils/tcc/validations.go:27
↓ 6 callersMethodProgressChan
()
pkg/cli/io/progress/progressreader.go:138
↓ 6 callersMethodPush
()
tools/tau/cli/common/types.go:24
↓ 6 callersMethodRegistry
()
pkg/sensors/service.go:55
↓ 6 callersMethodRepository
()
tools/tau/templates/create.go:18
← previousnext →901–1,000 of 13,103, ranked by callers