Functions — github.com/taubyte/tau

CodeHub MCPcopy Create free account

hub / github.com/taubyte/tau / functions

Functions13,103 in github.com/taubyte/tau

⨍ Functions 13,103◇ Types & classes 2,320↳ Endpoints 13

(language string)

pkg/cli/singletons/templates/code.go:19

pkg/schema/libraries/getter.go:55

pkg/schema/project/types.go:55

(application string)

pkg/schema/project/list.go:42

pkg/schema/domains/getter.go:58

pkg/schema/services/getter.go:37

pkg/schema/storages/getter.go:68

pkg/schema/basic/types.go:18

pkg/schema/databases/getter.go:75

services/substrate/type.go:66

services/substrate/components/http/function/smartops.go:22

services/substrate/components/http/website/smartops.go:26

services/substrate/components/database/globals/p2p/stream/mock_test.go:27

(smartOps []string)

services/substrate/components/p2p/service/types.go:28

services/substrate/components/p2p/stream/smartop.go:26

services/substrate/components/structure/node.go:68

(ev *event.Event)

services/substrate/components/pubsub/function/smartop.go:22

(smartOps []string)

services/substrate/components/pubsub/messaging/types.go:28

services/substrate/mocks/methods.go:48

services/substrate/runtime/cache/cache_test.go:58

pkg/schema/functions/types.go:30

pkg/vm/service/wazero/service.go:44

* Split splits the string by `/` separator, then cleans up any empty strings example: /home/taubyte with strings.Split would evaluate to []string{""

utils/path/split.go:16

MethodSprintCyan

tools/tau/i18n/printer/printer.go:61

MethodSprintCyan

tools/tau/i18n/printer/printer.go:86

MethodSprintCyan

tools/tau/i18n/printer/printer.go:127

MethodSprintfGreen

(format string, a ...any)

tools/tau/i18n/printer/printer.go:65

MethodSprintfGreen

(format string, a ...any)

tools/tau/i18n/printer/printer.go:88

MethodSprintfGreen

(format string, a ...any)

tools/tau/i18n/printer/printer.go:129

MethodStandardLogger

(opts *hclog.StandardLoggerOptions)

pkg/raft/transport.go:118

MethodStandardWriter

(opts *hclog.StandardLoggerOptions)

pkg/raft/transport.go:122

(srv database.Service)

services/substrate/components/database/globals/p2p/stream/start.go:11

core/services/seer/usage.go:16

core/services/seer/client.go:11

pkg/mycelium/command/cmd.go:90

pkg/mycelium/command/mocks/session.go:49

pkg/http-auto/methods.go:162

pkg/http/mocks/unimplemented.go:21

pkg/http/basic/methods.go:34

pkg/http/basic/secure/methods.go:42

Start starts the peering service, connecting and maintaining connections to all registered peers. It returns an error if the service has already been

p2p/peer/peering.go:170

(handler StreamHandler)

p2p/streams/services.go:47

Start begins accepting connections. Call after all handlers are registered.

p2p/streams/service/service.go:47

services/patrick/api_stream_routes_test.go:24

services/patrick/api_http_routes_test.go:19

(ctx context.Context)

services/seer/dns.go:23

services/substrate/components/counters/unimplemented.go:23

clients/p2p/seer/usage_client.go:101

clients/p2p/seer/client.go:130

FunctionStartSeerBeacon

(config *config.Node, sc seer.Client, serviceType seer.ServiceType, ops ...seerBeaconOption)

services/common/seer_beacon.go:25

FunctionStartWithSuffix

StartWithSuffix starts a spinner with an initial suffix and returns: - updateSuffix: call to change the message (e.g. " Step: build...") - stop: call

tools/tau/prompts/spinner/suffix.go:13

dream/types.go:201

Stash calls taucorder.v1.HoarderService.Stash.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/hoarder.connect.go:86

(context.Context, *connect.Request[v1.StashRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/hoarder.connect.go:93

(context.Context, *connect.Request[v1.StashRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/hoarder.connect.go:134

(ctx context.Context, req *connect.Request[pb.StashRequest])

pkg/taucorder/service/hoarder.go:36

(cid string, peers ...string)

clients/p2p/hoarder/stash.go:10

pkg/specs/builders/common/methods.go:126

State calls taucorder.v1.PatrickService.State.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:111

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:124

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:186

State calls taucorder.v1.AuthService.State.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:147

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:160

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:222

State calls taucorder.v1.TNSService.State.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:126

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:140

(context.Context, *connect.Request[v1.ConsensusStateRequest])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:214

(cyx context.Context, req *connect.Request[pb.ConsensusStateRequest])

pkg/taucorder/service/tns.go:140

(ctx context.Context, req *connect.Request[pb.ConsensusStateRequest])

pkg/taucorder/service/patrick.go:98

(ctx context.Context, req *connect.Request[pb.ConsensusStateRequest])

pkg/taucorder/service/auth.go:86

pkg/raft/cluster.go:610

(context.Context, *connect.Request[v1.Node])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:51

States calls taucorder.v1.PatrickService.States.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:116

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:125

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/patrick.connect.go:190

States calls taucorder.v1.AuthService.States.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:152

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:161

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/auth.connect.go:226

States calls taucorder.v1.TNSService.States.

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:131

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:141

(context.Context, *connect.Request[v1.Node], *connect.ServerStream[v1.ConsensusState])

pkg/taucorder/proto/gen/taucorder/v1/taucorderv1connect/tns.connect.go:218

(ctx context.Context, req *connect.Request[pb.Node], stream *connect.ServerStream[pb.ConsensusState])

pkg/taucorder/service/tns.go:178

(ctx context.Context, req *connect.Request[pb.Node], stream *connect.ServerStream[pb.ConsensusState])

pkg/taucorder/service/patrick.go:137

(ctx context.Context, req *connect.Request[pb.Node], stream *connect.ServerStream[pb.ConsensusState])

pkg/taucorder/service/auth.go:124

utils/tcc/publish_test.go:48

core/services/auth/client.go:23

core/services/tns/client.go:45

(ctx context.Context)

pkg/kvdb/stats.go:12

Stats returns the stats for this KVDB

pkg/kvdb/mock/mock.go:310

services/substrate/runtime/cache/cache_test.go:101

services/substrate/runtime/cache/cache_test.go:1488

clients/p2p/auth/stats.go:13

clients/p2p/tns/stats.go:13

dream/multiverse.go:178

services/patrick/api_stream_handlers_test.go:56

clients/http/dream/status.go:10

clients/http/dream/status.go:18

clients/p2p/monkey/status.go:11

clients/p2p/seer/usage_client.go:163

clients/p2p/seer/client.go:157

← previous next →8,101–8,200 of 13,103, ranked by callers