MCPcopy Create free account

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

↓ 6 callersFunctionResolveNameToId
(ct transform.Context[object.Refrence], group, name string)
pkg/tcc/taubyte/v1/utils/paths.go:65
↓ 6 callersFunctionSelectATemplate
(ctx *cli.Context, templateMap map[string]templates.TemplateInfo, prevURL ...string)
tools/tau/prompts/repository.go:34
↓ 6 callersMethodSendClose
(channel Channel, w io.Writer, err error)
p2p/streams/packer/packer.go:135
↓ 6 callersMethodSet
(sync bool, ops ...basic.Op)
pkg/schema/application/types.go:11
↓ 6 callersMethodSetName
(name string)
pkg/schema/basic/types.go:39
↓ 6 callersMethodSign
(rand io.Reader, digest []byte, opts crypto.SignerOpts)
pkg/http-auto/methods_test.go:27
↓ 6 callersFunctionSmartops
()
pkg/tcc/taubyte/v1/pass1/smartops.go:13
↓ 6 callersMethodStash
(cid string, peers ...string)
core/services/hoarder/client.go:10
↓ 6 callersMethodState
State management methods for Universe
dream/types.go:187
↓ 6 callersMethodStderr
()
core/vm/instance.go:37
↓ 6 callersMethodStdout
()
core/vm/instance.go:36
↓ 6 callersMethodString
()
services/substrate/components/pubsub/common/types.go:14
↓ 6 callersMethodSubscribe
(projectId, appId, resource, channel string)
core/services/substrate/components/pubsub/service.go:13
↓ 6 callersMethodSuccess
()
core/services/substrate/counters/path.go:45
↓ 6 callersFunctionTimeout
(value string)
pkg/schema/smartops/set.go:21
↓ 6 callersMethodTnsClient
()
tools/taucorder/prompt/ifaces.go:32
↓ 6 callersFunctionURL
URL returns an Option that will set the url of the auth server
clients/http/options.go:19
↓ 6 callersMethodUsername
()
pkg/spore-drive/config/auth.go:18
↓ 6 callersFunctionVariableNameValidator
(val string)
tools/tau/validate/variable.go:27
↓ 6 callersFunctionVariablePathValidator
(path string)
tools/tau/validate/variable.go:71
↓ 6 callersMethodWarningPrintln
(a ...any)
tools/tau/i18n/printer/printer.go:17
↓ 6 callersMethodWasm
()
pkg/specs/builders/types.go:24
↓ 6 callersFunctionWeakDecode
WeakDecode is the same as Decode but is shorthand to enable WeaklyTypedInput.
utils/mapstructure/mapstructure.go:117
↓ 6 callersMethodWriteBytes
( module common.Module, ptr uint32, value []byte, )
pkg/vm-low-orbit/helpers/bytes.go:34
↓ 6 callersMethodWriteBytesSize
(module common.Module, ptr uint32, data []byte)
pkg/vm-low-orbit/helpers/types.go:15
↓ 6 callersMethodWriteUint64Le
(module common.Module, ptr uint32, toWrite uint64)
pkg/vm-low-orbit/helpers/types.go:40
↓ 6 callersMethod_is_process_running
Check if a process with the given PID is running.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:133
↓ 6 callersMethod_parse_asset_name
Parse the asset name for the current platform.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:62
↓ 6 callersMethodabort
Abort the course.
pkg/spore-drive/clients/py/spore_drive/drive.py:252
↓ 6 callersFunctionaddJobToDB
(jobID string, status patrick.JobStatus)
services/patrick/api_stream_handlers_test.go:179
↓ 6 callersFunctionassertFunction1_http
(t *testing.T, getter functions.Getter)
pkg/schema/functions/getter_test.go:27
↓ 6 callersFunctionassertMessaging2
(t *testing.T, getter messaging.Getter)
pkg/schema/messaging/getter_test.go:43
↓ 6 callersFunctionassertService1
(t *testing.T, getter services.Getter)
pkg/schema/services/getter_test.go:27
↓ 6 callersFunctionassertSmartops1
(t *testing.T, getter smartops.Getter)
pkg/schema/smartops/getter_test.go:27
↓ 6 callersFunctionassertStorage1
(t *testing.T, getter storages.Getter)
pkg/schema/storages/getter_test.go:27
↓ 6 callersFunctionassertStorage2
(t *testing.T, getter storages.Getter)
pkg/schema/storages/getter_test.go:45
↓ 6 callersFunctionbasicLookUp
(t *testing.T, global bool, mAddr, expectedUri string)
pkg/vm/resolvers/taubyte/resolver_test.go:21
↓ 6 callersMethodbuildRouteFromDef
(def *service.RouteDefinition)
pkg/http/basic/helpers.go:39
↓ 6 callersMethodclose
Close the gRPC channel.
pkg/spore-drive/clients/py/spore_drive/clients.py:178
↓ 6 callersFunctioncreateMockServiceForHandler
Helper function to create a mock service for handler tests
services/substrate/components/pubsub/websocket/handler_test.go:48
↓ 6 callersFunctioncreateTestServiceWithoutKeys
(t *testing.T, port int)
services/auth/api_domain_repository_test.go:66
↓ 6 callersFunctiondomainValidationNew
(fqdn string, project cid.Cid, privKey, pubKey []byte)
services/auth/helpers.go:42
↓ 6 callersMethodequals
(a: Location | PlainMessage<Location> | undefined, b: Location | PlainMessage<Location> | undefined)
pkg/taucorder/clients/js/gen/taucorder/v1/seer_pb.ts:179
↓ 6 callersFunctionfile_drive_v1_drive_proto_rawDescGZIP
()
pkg/spore-drive/proto/gen/drive/v1/drive.pb.go:480
↓ 6 callersFunctionfile_mock_v1_ssh_proto_rawDescGZIP
()
pkg/spore-drive/proto/gen/mock/v1/ssh.pb.go:461
↓ 6 callersFunctionfile_taucorder_v1_swarm_proto_rawDescGZIP
()
pkg/taucorder/proto/gen/taucorder/v1/swarm.pb.go:428
↓ 6 callersFunctionfile_taucorder_v1_tns_proto_rawDescGZIP
()
pkg/taucorder/proto/gen/taucorder/v1/tns.pb.go:396
↓ 6 callersMethodfromBinary
(bytes: Uint8Array, options?: Partial<BinaryReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/seer_pb.ts:167
↓ 6 callersMethodfromJson
(jsonValue: JsonValue, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/seer_pb.ts:171
↓ 6 callersMethodfromJsonString
(jsonString: string, options?: Partial<JsonReadOptions>)
pkg/taucorder/clients/js/gen/taucorder/v1/seer_pb.ts:175
↓ 6 callersMethodget
* Get X509 certificate * @param certId Certificate ID * @returns X509 certificate
pkg/taucorder/clients/js/src/X509.ts:28
↓ 6 callersMethodgetBlock
(clientId uint32, blockId uint64)
pkg/vm-low-orbit/ethereum/block.go:23
↓ 6 callersMethodgetContent
(contentId uint32)
pkg/vm-low-orbit/storage/content_helpers.go:7
↓ 6 callersMethodgetPort
(timeout: number = 3500)
pkg/spore-drive/clients/js/src/Service.ts:201
↓ 6 callersMethodgetResponse
(clientId uint32, requestId uint32)
pkg/vm-low-orbit/http/client/helpers.go:19
↓ 6 callersFunctionget_existing_service_port
Get the port of an existing service if one is running.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:323
↓ 6 callersMethodhandleGet
handleGet handles get requests
pkg/raft/stream.go:163
↓ 6 callersMethodhasSubIDMapping
hasSubIDMapping checks if subuid/subgid mapping exists for a user
pkg/containers/backends/containerd/containerd.go:724
↓ 6 callersFunctioninferPathQuery
(path []StringMatch, query *yaseer.Query)
pkg/tcc/engine/node.go:164
↓ 6 callersMethodlistHooks
(ctx context.Context)
services/auth/api_hooks.go:29
↓ 6 callersMethodlistProjects
(ctx context.Context)
services/auth/api_hooks.go:125
↓ 6 callersMethodlistRepo
(ctx context.Context)
services/auth/api_hooks.go:70
↓ 6 callersFunctionnewTestService
(t *testing.T, node *mockNode, registry *sensors.Registry)
pkg/sensors/service_test.go:36
↓ 6 callersFunctionnotEqual
(a, b interface{})
tools/dream/cli/new/helpers_test.go:196
↓ 6 callersFunctionparseYAMLError
(err error)
pkg/yaseer/root.go:101
↓ 6 callersFunctionregisterMethods
(obj any)
pkg/starlark/module.go:55
↓ 6 callersMethodrequestVoterJoin
(timeout time.Duration)
pkg/raft/cluster.go:317
↓ 6 callersFunctionsessionFileBaseName
sessionFileBaseName returns the session file base name (without .yaml) for the given leaf-first PIDs. Format: tau-session-<p0>-<p1>-...-<pN> (variable
tools/tau/session/discovery.go:151
↓ 6 callersMethodsessionWrap
(method func() error)
pkg/mycelium/command/cmd.go:158
↓ 6 callersMethodsetACMEStaticCertificate
(ctx context.Context, fqdn string, certificate []byte)
services/auth/api_acme.go:32
↓ 6 callersFunctionsetupService
Helper function to initialize the service and mock dependencies.
pkg/spore-drive/drive/service/all_test.go:30
↓ 6 callersFunctionstressTimeoutConfig
stressTimeoutConfig returns slightly more relaxed timeouts for stress scenarios
pkg/raft/cluster_stress_test.go:53
↓ 6 callersFunctionverifyConfigurationConsistency
verifyConfigurationConsistency verifies all nodes see the same cluster configuration
pkg/raft/cluster_stress_test.go:354
↓ 6 callersFunctionverifyLeaderElected
verifyLeaderElected verifies exactly one leader exists and all nodes agree
pkg/raft/cluster_stress_test.go:179
↓ 6 callersFunctionverifyRaftStates
verifyRaftStates verifies that exactly one node is Leader and all others are Followers
pkg/raft/cluster_stress_test.go:320
↓ 5 callersMethodAction
()
tools/tau/cli/commands/resources/common/new.go:39
↓ 5 callersFunctionAddSubscription
(srv pubsubIface.ServiceWithLookup, name string, handler p2p.PubSubConsumerHandler, err_handler p2p.PubSubCons
services/substrate/components/pubsub/websocket/handler.go:103
↓ 5 callersMethodAddVoter
AddVoter adds a peer as a voting member (leader only)
pkg/raft/interfaces.go:68
↓ 5 callersFunctionAllowedOrigins
(regex bool, origins []string)
pkg/http/options/cors.go:26
↓ 5 callersMethodBeSureToCloneProject
()
tools/tau/i18n/help.go:23
↓ 5 callersFunctionBucketTypeValidator
(val string)
tools/tau/validate/variable.go:195
↓ 5 callersMethodBuild
Build will build the given working directory as per builder configuration and returns Output
core/builders/types.go:12
↓ 5 callersFunctionClient
(ctx context.Context)
tools/tau/clients/dream/client.go:20
↓ 5 callersMethodClone
()
tools/tau/cli/common/types.go:23
↓ 5 callersMethodClone
(attributes ...Attribute)
pkg/mycelium/host/host.go:21
↓ 5 callersMethodCodeLoc
()
tools/tau/config/project.go:15
↓ 5 callersFunctionCompilerConfig
(project projectSchema.Project, meta patrick.Meta, generatedDomainRegExp *regexp.Regexp)
pkg/config-compiler/compile/compiler.go:32
↓ 5 callersMethodConfig
()
tools/tau/lib/project/types.go:16
↓ 5 callersMethodConfigLoc
()
tools/tau/config/project.go:11
↓ 5 callersMethodCreatePushHook
(name *string, url *string, devMode bool)
services/auth/github_client.go:118
↓ 5 callersMethodDAG
()
p2p/peer/type.go:36
↓ 5 callersFunctionDatabase
(branch string)
pkg/tcc/taubyte/v1/pass4/database.go:16
↓ 5 callersFunctionDecode
(conn streams.Connection, r io.Reader)
p2p/streams/command/command.go:63
↓ 5 callersFunctionDescription
(value string)
pkg/schema/domains/set.go:12
↓ 5 callersFunctionDescription
(value string)
pkg/schema/services/set.go:11
↓ 5 callersFunctionDev
()
pkg/config-compiler/compile/compiler.go:50
↓ 5 callersFunctionEncode
(s io.Writer, err error)
p2p/streams/command/error/error.go:9
↓ 5 callersFunctionFQDN
(value string)
pkg/schema/domains/set.go:20
↓ 5 callersFunctionFormatSize
FormatSize converts bytes (int64) back to human-readable size string. This is an alias for FormatMemory for semantic clarity. If the field doesn't exi
pkg/tcc/taubyte/v1/utils/parsing.go:189
↓ 5 callersFunctionFunctions
()
pkg/tcc/taubyte/v1/decompile/pass3/functions.go:13
← previousnext →1,001–1,100 of 13,103, ranked by callers