MCPcopy Create free account

hub / github.com/anthdm/raptor / functions

Functions176 in github.com/anthdm/raptor

↓ 29 callersFunctionwriteJSON
(w http.ResponseWriter, status int, v any)
internal/api/handler.go:35
↓ 23 callersFunctionErrorResponse
(err error)
internal/api/handler.go:18
↓ 23 callersFunctionGet
()
internal/config/config.go:63
↓ 15 callersMethodString
()
cmd/cli/main.go:43
↓ 11 callersMethodClose
()
internal/runtime/runtime.go:65
↓ 11 callersMethodWrite
(b []byte)
sdk/sdk.go:64
↓ 11 callersFunctionprintErrorAndExit
(err error)
cmd/cli/main.go:202
↓ 10 callersFunctionwriteResponse
(w http.ResponseWriter, code int, b []byte)
internal/actrs/wasmserver.go:196
↓ 9 callersMethodGet
(uuid.UUID)
internal/storage/mod_cache.go:14
↓ 8 callersMethodWriteHeader
(status int)
sdk/sdk.go:68
↓ 7 callersMethodServeHTTP
TODO(anthdm): Handle the favicon.ico
internal/actrs/wasmserver.go:114
↓ 7 callersFunctionmakeAPIHandler
(h apiHandler)
internal/api/handler.go:26
↓ 6 callersMethodGetEndpoint
(uuid.UUID)
internal/storage/storage.go:11
↓ 6 callersFunctionParseStdout
(stdout io.Reader)
internal/shared/shared.go:24
↓ 5 callersFunctioncreateServer
()
internal/api/server_test.go:135
↓ 4 callersMethodCreateDeployment
(*types.Deployment)
internal/storage/storage.go:12
↓ 4 callersMethodCreateEndpoint
(*types.Endpoint)
internal/storage/storage.go:9
↓ 4 callersFunctionNewDefaultModCache
()
internal/storage/mod_cache.go:23
↓ 4 callersFunctionParse
(path string)
internal/config/config.go:48
↓ 4 callersMethodSet
(value string)
cmd/cli/main.go:38
↓ 4 callersFunctionfile_proto_types_proto_rawDescGZIP
()
proto/types.pb.go:366
↓ 4 callersFunctionprintUsage
()
cmd/cli/main.go:20
↓ 4 callersFunctionseedEndpoint
(t *testing.T, s *Server)
internal/api/server_test.go:129
↓ 3 callersMethodGetDeployment
(uuid.UUID)
internal/storage/storage.go:13
↓ 3 callersFunctionIngressUrl
()
internal/config/config.go:83
↓ 3 callersMethodInvoke
(stdin io.Reader, env map[string]string, args ...string)
internal/runtime/runtime.go:52
↓ 3 callersFunctionNew
(ctx context.Context, args Args)
internal/runtime/runtime.go:32
↓ 3 callersFunctionNewDeployment
(endpoint *Endpoint, blob []byte)
internal/types/deployment.go:19
↓ 3 callersFunctionNewSQLStore
(user, password, dbname, host, port, sslmode string)
internal/storage/sql.go:18
↓ 3 callersMethodUpdateEndpoint
(uuid.UUID, UpdateEndpointParams)
internal/storage/storage.go:10
↓ 3 callersFunctionmakeURL
makeURL takes a host address and returns a http URL.
internal/config/config.go:68
↓ 3 callersFunctionrespondError
(ctx *actor.Context, code int32, msg string, id string)
internal/actrs/runtime.go:183
↓ 2 callersFunctionApiUrl
()
internal/config/config.go:87
↓ 2 callersMethodHeader
()
sdk/sdk.go:60
↓ 2 callersFunctionIsZeroUUID
(id uuid.UUID)
internal/shared/shared.go:96
↓ 2 callersFunctionNewEndpoint
(name string, runtime string, env map[string]string)
internal/types/endpoint.go:33
↓ 2 callersFunctionNewRuntime
(store storage.Store, cache storage.ModCacher)
internal/actrs/runtime.go:46
↓ 2 callersFunctionNewServer
NewServer returns a new server given a Store interface.
internal/api/server.go:26
↓ 2 callersMethodPut
(uuid.UUID, wazero.CompilationCache)
internal/storage/mod_cache.go:13
↓ 2 callersMethodReset
()
proto/types.pb.go:42
↓ 2 callersMethodScan
(dest ...interface{})
internal/storage/sql.go:123
↓ 2 callersMethodinitRouter
()
internal/api/server.go:40
↓ 2 callersFunctionscanEndpoint
(s Scanner, e *types.Endpoint)
internal/storage/sql.go:165
↓ 1 callersMethodDelete
(uuid.UUID)
internal/storage/mod_cache.go:15
↓ 1 callersMethodGetEndpoint
(id uuid.UUID)
internal/storage/memory_store.go:31
↓ 1 callersMethodGetRuntimeMetrics
(uuid.UUID)
internal/storage/storage.go:18
↓ 1 callersMethodHasActiveDeploy
()
internal/types/endpoint.go:29
↓ 1 callersMethodListen
Listen starts listening on the given address.
internal/api/server.go:35
↓ 1 callersFunctionMakeProtoRequest
(id string, r *http.Request)
internal/shared/shared.go:63
↓ 1 callersFunctionNew
(config Config)
internal/client/client.go:36
↓ 1 callersFunctionNewConfig
()
internal/client/client.go:19
↓ 1 callersFunctionNewMemoryStore
()
internal/storage/memory_store.go:17
↓ 1 callersFunctionNewRuntimeManager
(c *cluster.Cluster)
internal/actrs/runtime_manager.go:24
↓ 1 callersFunctionNewWasmServer
NewWasmServer return a new wasm server given a storage and a mod cache.
internal/actrs/wasmserver.go:45
↓ 1 callersFunctionParseRuntimeHTTPResponse
(in string)
internal/shared/shared.go:47
↓ 1 callersMethodPublish
(params api.PublishParams)
internal/client/client.go:43
↓ 1 callersFunctionValidRuntime
(runtime string)
internal/types/endpoint.go:14
↓ 1 callersMethodWithURL
(url string)
internal/client/client.go:25
↓ 1 callersFunctionbuildUpdateEndpointQuery
(id uuid.UUID, params UpdateEndpointParams)
internal/storage/sql.go:126
↓ 1 callersFunctionfile_proto_types_proto_init
()
proto/types.pb.go:396
↓ 1 callersMethodhandleDeploy
(args []string)
cmd/cli/main.go:156
↓ 1 callersMethodhandleEndpoint
(args []string)
cmd/cli/main.go:117
↓ 1 callersMethodhandleHTTPRequest
(ctx *actor.Context, msg *proto.HTTPRequest)
internal/actrs/runtime.go:127
↓ 1 callersMethodhandlePublish
(args []string)
cmd/cli/main.go:93
↓ 1 callersMethodhandleServeEndpoint
(args []string)
cmd/cli/main.go:186
↓ 1 callersMethodinitialize
(c *actor.Context)
internal/actrs/wasmserver.go:88
↓ 1 callersMethodinitialize
(msg *proto.HTTPRequest)
internal/actrs/runtime.go:87
↓ 1 callersFunctionmakeEnvMap
(list []string)
cmd/cli/main.go:190
↓ 1 callersFunctionmakeProtoHeader
(header http.Header)
internal/shared/shared.go:86
↓ 1 callersFunctionmakeRequest
()
cmd/load/main.go:24
↓ 1 callersFunctionnewRequestWithResponse
(request *proto.HTTPRequest)
internal/actrs/wasmserver.go:25
↓ 1 callersMethodrequestRuntime
NOTE: There could be a case where we do not get a response in time, hence the PID will be nil. This case is handled where we should spawn the runtime
internal/actrs/wasmserver.go:98
↓ 1 callersFunctionrespond
(res, status)
internal/_testdata/helloworld.js:3
↓ 1 callersFunctionrespond
(res, status)
examples/js/index.js:3
↓ 1 callersFunctionscanDeploy
(s Scanner, d *types.Deployment)
internal/storage/sql.go:155
↓ 1 callersFunctionseedEndpoint
(store storage.Store, cache storage.ModCacher)
cmd/api/main.go:57
↓ 1 callersFunctiontrimmedEndpointFromURL
(url *url.URL)
internal/shared/shared.go:77
↓ 1 callersMethodvalidate
()
internal/api/server.go:74
FunctionBenchmarkParseStdout
(b *testing.B)
internal/shared/shared_test.go:14
MethodCreateDeployment
(endpointID uuid.UUID, blob io.Reader, params api.CreateDeploymentParams)
internal/client/client.go:95
MethodCreateDeployment
(deploy *types.Deployment)
internal/storage/sql.go:100
MethodCreateDeployment
(deploy *types.Deployment)
internal/storage/memory_store.go:59
MethodCreateEndpoint
(params api.CreateEndpointParams)
internal/client/client.go:69
MethodCreateEndpoint
(endpoint *types.Endpoint)
internal/storage/sql.go:42
MethodCreateEndpoint
(e *types.Endpoint)
internal/storage/memory_store.go:24
MethodCreateRuntimeMetric
(*types.RuntimeMetric)
internal/storage/storage.go:17
MethodCreateRuntimeMetric
(metric *types.RuntimeMetric)
internal/storage/sql.go:114
MethodCreateRuntimeMetric
(_ *types.RuntimeMetric)
internal/storage/memory_store.go:76
MethodDelete
(id uuid.UUID)
internal/storage/mod_cache.go:42
MethodDescriptor
Deprecated: Use HTTPRequest.ProtoReflect.Descriptor instead.
proto/types.pb.go:70
MethodDescriptor
Deprecated: Use HeaderFields.ProtoReflect.Descriptor instead.
proto/types.pb.go:187
MethodDescriptor
Deprecated: Use HTTPResponse.ProtoReflect.Descriptor instead.
proto/types.pb.go:236
MethodDescriptor
Deprecated: Use RemoveRuntime.ProtoReflect.Descriptor instead.
proto/types.pb.go:297
MethodGet
(id uuid.UUID)
internal/storage/mod_cache.go:35
MethodGetBody
()
proto/types.pb.go:74
MethodGetDeployment
(id uuid.UUID)
internal/storage/sql.go:91
MethodGetDeployment
(id uuid.UUID)
internal/storage/memory_store.go:66
MethodGetDeploymentID
()
proto/types.pb.go:123
MethodGetEndpoint
(id uuid.UUID)
internal/storage/sql.go:60
MethodGetEndpointID
()
proto/types.pb.go:95
next →1–100 of 176, ranked by callers