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
↓ 7 callers
Function
createTestHandler
Helper functions to reduce test duplication
services/substrate/components/pubsub/websocket/datastream_test.go:177
↓ 7 callers
Function
decryptResponse
decryptResponse decrypts a response from stream service
pkg/raft/encryption.go:181
↓ 7 callers
Method
delete
Delete host.
pkg/spore-drive/clients/py/spore_drive/operations.py:507
↓ 7 callers
Function
discoverOrCreateConfigFileLoc
()
tools/tau/session/discovery.go:226
↓ 7 callers
Method
duration
()
services/substrate/mocks/counters/report/metric.go:13
↓ 7 callers
Function
encrypt
(data []byte, password string)
cli/app/protect.go:41
↓ 7 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/messaging/getter_test.go:14
↓ 7 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/services/getter_test.go:14
↓ 7 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/storages/getter_test.go:14
↓ 7 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/smartops/getter_test.go:14
↓ 7 callers
Function
eql
(t *testing.T, a [][]any)
pkg/schema/databases/getter_test.go:14
↓ 7 callers
Function
extractIdFromKey
(list []string, split string, index int)
services/auth/helpers.go:27
↓ 7 callers
Function
file_taucorder_v1_seer_proto_rawDescGZIP
()
pkg/taucorder/proto/gen/taucorder/v1/seer.pb.go:695
↓ 7 callers
Function
generateKey
()
services/auth/github.go:89
↓ 7 callers
Method
getACMECache
(ctx context.Context, key string)
services/auth/api_acme.go:96
↓ 7 callers
Method
getACMEStaticCertificate
(ctx context.Context, fqdn string)
services/auth/api_acme.go:69
↓ 7 callers
Method
getClient
(name string)
dream/simple.go:24
↓ 7 callers
Method
getDatabase
(databaseId uint32)
pkg/vm-low-orbit/database/client/database.go:21
↓ 7 callers
Function
getKind
(val reflect.Value)
utils/mapstructure/mapstructure.go:1336
↓ 7 callers
Method
handler
(msg *pubsub.Message)
services/substrate/components/pubsub/websocket/handler.go:77
↓ 7 callers
Method
has_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 callers
Method
init
(url: string)
pkg/spore-drive/clients/js/src/Drive.ts:57
↓ 7 callers
Method
initClient
initClient initializes the Docker client
pkg/containers/backends/docker/docker.go:132
↓ 7 callers
Method
isRunning
isRunning checks if the containerd daemon is running
pkg/containers/backends/containerd/daemon.go:326
↓ 7 callers
Function
join
(basePath Path, toJoin v)
core/services/substrate/counters/path.go:33
↓ 7 callers
Method
loadYamlDocument
(path string)
pkg/yaseer/root.go:130
↓ 7 callers
Function
localResolveNameToId
(store transform.Store[object.Refrence], ctp []any, group, name string)
pkg/tcc/taubyte/v1/utils/paths.go:48
↓ 7 callers
Function
makeAddrsFactory
(announce []string, noAnnounce []string)
p2p/peer/addr_factory.go:10
↓ 7 callers
Method
mergePeers
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 callers
Function
newInternalClient
newInternalClient creates a new internal raft p2p client for the given namespace
pkg/raft/client.go:48
↓ 7 callers
Function
newJob
(repo commonTest.Repository, jobId string)
services/monkey/jobs/utils_test.go:128
↓ 7 callers
Function
newMockConfigurable
()
pkg/http/options/all_test.go:14
↓ 7 callers
Function
newTestContext
(ctx context.Context, simple *dream.Simple, logFile *os.File)
services/monkey/jobs/utils_test.go:30
↓ 7 callers
Function
serverError
(format string, args ...interface{})
pkg/vm-orbit/satellite/helpers.go:56
↓ 7 callers
Method
uint
()
services/substrate/mocks/counters/report/metric.go:5
↓ 6 callers
Method
Accept
()
pkg/raft/transport.go:177
↓ 6 callers
Method
AddJob
(t *testing.T, peerC peer.Node, job *patrick.Job)
clients/p2p/patrick/mock/patrick_struct.go:34
↓ 6 callers
Function
Auth
Auth returns an Option that will set the auth token of the client
clients/http/options.go:49
↓ 6 callers
Method
Body
()
pkg/http/types.go:121
↓ 6 callers
Function
Branch
* Branch is an Option to set the repository branch. * * branch: The branch to use. */
pkg/git/options.go:147
↓ 6 callers
Method
Cache
()
core/services/substrate/components/types.go:12
↓ 6 callers
Function
Call
(value string)
pkg/schema/smartops/set.go:29
↓ 6 callers
Method
Capacity
()
core/services/substrate/components/storage/service.go:46
↓ 6 callers
Method
Checkout
()
tools/tau/cli/common/types.go:26
↓ 6 callers
Method
CollectAndPush
(ctx context.Context)
pkg/sensors/example/collector.go:104
↓ 6 callers
Method
Combined
Combined returns the Stderr, and Stdout combined container logs.
pkg/containers/mux.go:10
↓ 6 callers
Function
Compat
(path ...StringMatch)
pkg/tcc/engine/options.go:23
↓ 6 callers
Method
DELETE
(*RouteDefinition)
pkg/http/types.go:149
↓ 6 callers
Method
DatabaseStats
()
core/services/patrick/client.go:18
↓ 6 callers
Function
Databases
()
pkg/tcc/taubyte/v1/pass1/databases.go:13
↓ 6 callers
Method
Databases
(string)
pkg/schema/project/types.go:52
↓ 6 callers
Method
DefineStream
(command string, std router.CommandHandler, stream router.StreamHandler)
p2p/streams/service/service.go:13
↓ 6 callers
Function
Description
(value string)
pkg/schema/application/set.go:11
↓ 6 callers
Method
Domain
()
core/services/tns/client.go:36
↓ 6 callers
Method
Encode
(s io.Writer)
p2p/streams/command/response/response.go:14
↓ 6 callers
Method
Execution
()
core/services/substrate/counters/path.go:9
↓ 6 callers
Method
Fetch
(PrettierFetchMethod)
pkg/schema/internal/test/prettier.go:13
↓ 6 callers
Method
ForceContext
Used in tests for setting the unexported contexts
services/monkey/jobs/context.go:12
↓ 6 callers
Method
Get
(name string)
pkg/sensors/registry.go:48
↓ 6 callers
Method
GetKey
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:1981
↓ 6 callers
Function
GetMatchRegex
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/channel_match.go:18
↓ 6 callers
Function
GetOrAskForAStringValue
(c *cli.Context, field string, label string, prev ...string)
pkg/cli/prompts/string.go:56
↓ 6 callers
Function
GetOrAskForEmbedToken
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/embed_token.go:8
↓ 6 callers
Function
GetOrAskForLocal
(ctx *cli.Context, prev ...bool)
tools/tau/prompts/local.go:8
↓ 6 callers
Function
GetOrRequireACall
TODO parse the source, and make this a selection based on exported functions.
tools/tau/prompts/call.go:15
↓ 6 callers
Function
GetOrRequireMemoryAndType
(ctx *cli.Context, new bool, prev ...uint64)
tools/tau/prompts/memory.go:33
↓ 6 callers
Function
GetOrSelectLanguage
(ctx *cli.Context, prev ...string)
tools/tau/prompts/language.go:29
↓ 6 callers
Method
GetPortHttp
(node peer.Node)
dream/universe.go:180
↓ 6 callers
Function
GetSelectedUser
GetSelectedUser returns selected profile: session first, then profileFromProject, then config default.
tools/tau/config/selected.go:51
↓ 6 callers
Method
GetSize
(ctx context.Context, key datastore.Key)
p2p/datastores/mem/mem.go:66
↓ 6 callers
Method
GetType
()
pkg/spore-drive/proto/gen/config/v1/config.pb.go:303
↓ 6 callers
Method
GetURLHttp
(node peer.Node)
dream/universe.go:216
↓ 6 callers
Method
GitHubTokenHTTPAuthCleanup
(ctx http.Context)
core/services/types.go:26
↓ 6 callers
Function
Id
(value string)
pkg/schema/smartops/set.go:5
↓ 6 callers
Method
Image
Image returns an Image interface for the given image name
pkg/containers/backends/docker/docker.go:161
↓ 6 callers
Method
In
()
services/substrate/components/pubsub/websocket/datastream.go:37
↓ 6 callers
Function
IndexOf
TODO "golang.org/x/exp/slices"
tools/tau/cli/args/helpers.go:4
↓ 6 callers
Method
InfoPrintln
(a ...any)
tools/tau/i18n/printer/printer.go:13
↓ 6 callers
Method
Initialize
(parentCommand *cli.Command, baseCommand *cli.Command, baseOps []Option)
tools/tau/cli/common/types.go:13
↓ 6 callers
Function
IsAny
(val string, tests ...func(val string) bool)
tools/tau/validate/bool_helpers.go:9
↓ 6 callers
Function
IsInt
(val string)
tools/tau/validate/bool_helpers.go:18
↓ 6 callers
Function
MatchAllString
(val string, expressions [][]string)
tools/tau/validate/helpers.go:9
↓ 6 callers
Function
Memory
(value string)
pkg/schema/smartops/set.go:25
↓ 6 callers
Method
Monkey
()
pkg/taucorder/clients/js/src/Taucorder.ts:109
↓ 6 callers
Function
NameWithDefault
(c *cli.Command, def string)
tools/dream/cli/command/name.go:11
↓ 6 callers
Function
New
(ctx context.Context, node peer.Node, config *config.Node, ops ...options.Option)
pkg/http-auto/new.go:26
↓ 6 callers
Function
New
(interval time.Duration, opts ...Option)
pkg/cli/io/progress/progressreader.go:68
↓ 6 callers
Function
New
(node peer.Node)
pkg/vm/backend/dfs/backend.go:20
↓ 6 callers
Function
New
(peer peer.Node, name string, path string)
p2p/streams/service/service.go:26
↓ 6 callers
Function
New
(ctx context.Context, node peer.Node, cacheDir string)
services/auth/acme/store/store.go:45
↓ 6 callers
Method
New
(context.Context, *connect.Request[v1.DriveRequest])
pkg/spore-drive/proto/gen/drive/v1/drivev1connect/drive.connect.go:63
↓ 6 callers
Method
Object
()
pkg/tcc/object/generic.go:360
↓ 6 callers
Method
Password
()
pkg/spore-drive/config/auth.go:19
↓ 6 callers
Function
Path
(name, folder string)
tools/tau/lib/codefile/path.go:11
↓ 6 callers
Method
Ping
(context.Context, *connect.Request[v1.PingRequest])
pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/swarm.connect.go:52
↓ 6 callers
Function
ProcessProjectIDValidation
ProcessProjectIDValidation runs project ID validation from TCC compiler.
utils/tcc/validations.go:27
↓ 6 callers
Method
ProgressChan
()
pkg/cli/io/progress/progressreader.go:138
↓ 6 callers
Method
Push
()
tools/tau/cli/common/types.go:24
↓ 6 callers
Method
Registry
()
pkg/sensors/service.go:55
↓ 6 callers
Method
Repository
()
tools/tau/templates/create.go:18
← previous
next →
901–1,000 of 13,103, ranked by callers