Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/taubyte/tau
/ functions
Functions
13,103 in github.com/taubyte/tau
⨍
Functions
13,103
◇
Types & classes
2,320
↳
Endpoints
13
↓ 8 callers
Method
Root
()
pkg/tcc/object/types.go:62
↓ 8 callers
Function
RunCLIWithDir
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 callers
Method
Sub
(filter HostFilter)
pkg/mycelium/network.go:84
↓ 8 callers
Method
Success
()
core/services/substrate/counters/path.go:18
↓ 8 callers
Function
Validator
(validator func(T) error)
pkg/tcc/engine/options.go:35
↓ 8 callers
Method
Version
()
core/services/substrate/components/storage/service.go:25
↓ 8 callers
Method
Warning
(err error)
tools/tau/i18n/printer/printer.go:16
↓ 8 callers
Method
WarningPrintfln
(format string, a ...any)
tools/tau/i18n/printer/printer.go:18
↓ 8 callers
Method
WebSocket
()
pkg/schema/messaging/types.go:28
↓ 8 callers
Method
WrapError
(format string, i ...any)
pkg/schema/basic/types.go:44
↓ 8 callers
Method
acmeServiceHandler
(ctx context.Context, st streams.Connection, body command.Body)
services/auth/api_acme.go:152
↓ 8 callers
Function
attachNodesError
(name string, err error)
services/substrate/attach.go:17
↓ 8 callers
Function
attachSmartOpsFromTags
(returnMap map[string]interface{}, tags []string, application string, project projectSchema.Project, library s
pkg/config-compiler/compile/common.go:154
↓ 8 callers
Function
byId
(u *Universe, i map[string]commonIface.Service, pid string)
dream/universeMethods.go:227
↓ 8 callers
Method
closeFile
closeFile decrements reference count and closes file if no more references
pkg/vm/logger/manager.go:55
↓ 8 callers
Function
createMockServiceContext
Helper function to create a mock service context
services/substrate/components/pubsub/websocket/handler_test.go:330
↓ 8 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/libraries/getter_test.go:14
↓ 8 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/domains/getter_test.go:14
↓ 8 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/website/getter_test.go:14
↓ 8 callers
Method
findContainerdBinary
findContainerdBinary finds the containerd binary path
pkg/containers/backends/containerd/daemon.go:350
↓ 8 callers
Function
first
(u *Universe, i map[string]commonIface.Service)
dream/universeMethods.go:239
↓ 8 callers
Function
fixtureFS
(virtual bool, dir ...string)
pkg/yaseer/utils_test.go:10
↓ 8 callers
Method
getContract
(contractId uint32)
pkg/vm-low-orbit/ethereum/contract_helpers.go:35
↓ 8 callers
Method
getSocketPath
getSocketPath returns the appropriate socket path
pkg/containers/backends/containerd/containerd.go:158
↓ 8 callers
Method
getTransaction
(module common.Module, clientId, blockIdPtr, contractId, transactionId uint32)
pkg/vm-low-orbit/ethereum/transaction.go:76
↓ 8 callers
Function
getValue
(aq *yaseer.Query, attr *Attribute)
pkg/tcc/engine/node.go:223
↓ 8 callers
Function
hashFile
(r io.Reader)
pkg/spore-drive/config/all_test.go:73
↓ 8 callers
Function
mustMultiaddr
(t *testing.T, s string)
p2p/peer/addr_factory_test.go:159
↓ 8 callers
Function
newRemote
(ctx context.Context, h host.Host)
pkg/spore-drive/drive/remote.go:31
↓ 8 callers
Function
newStableStore
newStableStore creates a new StableStore backed by the given datastore
pkg/raft/storage.go:176
↓ 8 callers
Function
panicIfPromptNotEnabled
(prompt string)
pkg/cli/prompts/constants.go:77
↓ 8 callers
Method
run
(got string)
pkg/specs/extract/extract_test.go:26
↓ 8 callers
Function
runHandlerTest
Helper function to run a handler test with common setup
services/substrate/components/pubsub/websocket/handler_test.go:354
↓ 8 callers
Function
runSourceValidation
(t *testing.T, obj object.Object[object.Refrence])
pkg/tcc/taubyte/v1/pass2/source_validation_test.go:13
↓ 8 callers
Method
start
Start the service and return the port it's running on.
pkg/spore-drive/clients/py/spore_drive/service_manager.py:205
↓ 8 callers
Function
testExpected
(expected string)
pkg/specs/extract/extract_test.go:22
↓ 8 callers
Function
testRepoToken
(t *testing.T)
pkg/git/all_test.go:27
↓ 7 callers
Method
Address
()
pkg/spore-drive/config/hosts.go:37
↓ 7 callers
Function
Body
(body command.Body)
p2p/streams/client/client.go:87
↓ 7 callers
Method
Close
()
core/services/substrate/components/p2p/service.go:23
↓ 7 callers
Method
Close
()
pkg/mycelium/command/session.go:10
↓ 7 callers
Method
ColdStart
()
core/services/substrate/counters/path.go:8
↓ 7 callers
Method
Compress
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 callers
Function
Decode
(s io.Reader)
p2p/streams/command/response/response.go:34
↓ 7 callers
Method
Delete
(ctx context.Context)
services/auth/hooks/hooks.go:66
↓ 7 callers
Method
DeleteRange
(min, max uint64)
pkg/raft/interfaces.go:106
↓ 7 callers
Method
Email
()
pkg/schema/project/types.go:47
↓ 7 callers
Method
Exists
Exists checks if the image exists locally
pkg/containers/backends/containerd/image.go:43
↓ 7 callers
Method
FetchMetrics
FetchMetrics fetches metrics from the API
pkg/sensors/example/collector.go:44
↓ 7 callers
Function
Functions
()
pkg/tcc/taubyte/v1/pass1/functions.go:13
↓ 7 callers
Method
Functions
Functions adds the function definitions to the HostModule
core/vm/host_module.go:30
↓ 7 callers
Method
Get
(context.Context, *connect.Request[v1.GetJobInstanceRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/monkey.connect.go:45
↓ 7 callers
Method
GetById
(resourceId string)
core/services/tns/client.go:63
↓ 7 callers
Method
GetCount
()
pkg/taucorder/proto/gen/taucorder/v1/swarm.pb.go:250
↓ 7 callers
Method
GetNodeID
(ctx context.Context)
pkg/sensors/example/collector.go:135
↓ 7 callers
Function
GetOrAskForAStringValue
(c *cli.Context, field string, label string, prev ...string)
tools/tau/prompts/string.go:57
↓ 7 callers
Function
GetOrRequireATimeout
(ctx *cli.Context, prev ...uint64)
tools/tau/prompts/timeout.go:10
↓ 7 callers
Function
GetOrSelectSource
(ctx *cli.Context, prev ...string)
tools/tau/prompts/source.go:16
↓ 7 callers
Method
GetSelect
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:2703
↓ 7 callers
Method
Global
(projectId string, branches ...string)
core/services/tns/client.go:71
↓ 7 callers
Function
Hash
Hash returns the hash of a string or []byte using B58
utils/multihash/generate.go:8
↓ 7 callers
Method
ID
()
clients/http/auth/git/common/types.go:32
↓ 7 callers
Method
Id
()
pkg/spore-drive/config/hosts.go:30
↓ 7 callers
Function
InSet
(elms ...T)
pkg/tcc/engine/validators.go:61
↓ 7 callers
Function
Load
()
tools/tau/clients/patrick_client/load.go:7
↓ 7 callers
Method
Location
(context.Context, *connect.Request[v1.LocationRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/seer.connect.go:48
↓ 7 callers
Method
Match
(s string)
pkg/tcc/engine/stringmatch.go:6
↓ 7 callers
Method
Matcher
()
core/services/substrate/components/types.go:42
↓ 7 callers
Method
MemoryRead
(offset uint32, size uint32)
pkg/vm-orbit/satellite/module_link.go:15
↓ 7 callers
Method
MemoryWrite
(offset uint32, data []byte)
pkg/vm-orbit/satellite/module_link.go:28
↓ 7 callers
Function
New
(options ...Option)
pkg/mycelium/network.go:24
↓ 7 callers
Function
New
(options ...Option)
pkg/tcc/taubyte/v1/decompile/decompiler.go:27
↓ 7 callers
Function
New
New creates a new MCP service using httpIface.Service
dream/mcp/service.go:36
↓ 7 callers
Method
New
(context.Context, *connect.Request[v1.Empty])
pkg/spore-drive/proto/gen/config/v1/configv1connect/config.connect.go:66
↓ 7 callers
Method
Number
()
services/substrate/components/counters/metrics/types.go:9
↓ 7 callers
Method
PID
()
p2p/streams/client/client.go:122
↓ 7 callers
Function
Password
(username, password string)
pkg/mycelium/host/attrs.go:111
↓ 7 callers
Method
PublicKey
()
core/services/auth/secrets.go:35
↓ 7 callers
Method
Pull
Pull retrieves the image from a registry/repository
pkg/containers/backends/docker/image.go:24
↓ 7 callers
Method
PushValue
(context.Context, *connect.Request[v1.PushValueRequest])
pkg/sensors/proto/gen/sensors/v1/sensorsv1connect/sensors.connect.go:44
↓ 7 callers
Method
Register
(ctx context.Context)
services/auth/repositories/repositories.go:56
↓ 7 callers
Method
RepoID
()
tools/tau/cli/commands/resources/repository/types.go:13
↓ 7 callers
Function
RequiredPaths
(c *cli.Context, prev ...string)
tools/tau/prompts/paths.go:14
↓ 7 callers
Method
Reset
()
core/services/substrate/counters/metric.go:4
↓ 7 callers
Function
ResolveNamesToId
(ct transform.Context[object.Refrence], group string, names []string)
pkg/tcc/taubyte/v1/utils/paths.go:88
↓ 7 callers
Method
SensorsRegistry
()
config/services.go:75
↓ 7 callers
Method
SetVariables
(vars map[string]interface{})
services/patrick/github_test.go:141
↓ 7 callers
Method
Size
()
core/vm/memory.go:5
↓ 7 callers
Method
Start
Start starts a container
pkg/containers/backends/docker/docker.go:317
↓ 7 callers
Function
StringSlice
(name string, options ...Option)
pkg/tcc/engine/helpers.go:54
↓ 7 callers
Method
Sync
Sync syncs the KVDB key values
core/kvdb/ifaces.go:42
↓ 7 callers
Function
Tags
(value []string)
pkg/schema/application/set.go:15
↓ 7 callers
Function
UsageOneOfOption
(options []string)
tools/tau/flags/usage.go:8
↓ 7 callers
Function
ValidateMinMax
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 callers
Function
WithEncryptionKey
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 callers
Method
WriteCid
(module common.Module, ptr uint32, value cid.Cid)
pkg/vm-low-orbit/helpers/types.go:53
↓ 7 callers
Method
_build_op
Build operation with path.
pkg/spore-drive/clients/py/spore_drive/operations.py:48
↓ 7 callers
Method
_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 callers
Function
cleanupInterruptedMigration
cleanupInterruptedMigration handles cases where a previous migration was interrupted
p2p/helpers/datastore.go:37
↓ 7 callers
Function
createMockService
(publishFunc func(ctx context.Context, topic string, data []byte) error)
services/substrate/components/pubsub/websocket/datastream_test.go:190
← previous
next →
801–900 of 13,103, ranked by callers