MCPcopy Create free account

hub / github.com/Juice-Labs/Juice-Labs / functions

Functions311 in github.com/Juice-Labs/Juice-Labs

⨍ Functions 311◇ Types & classes 62
↓ 40 callersMethodSet
(s string)
pkg/utilities/comma.go:23
↓ 26 callersFunctionError
(v ...any)
pkg/logger/logger.go:146
↓ 25 callersMethodString
()
pkg/utilities/comma.go:16
↓ 20 callersMethodClose
()
cmd/controller/storage/storage.go:78
↓ 20 callersMethodNext
()
cmd/controller/storage/storage.go:47
↓ 19 callersMethodCtx
()
pkg/task/task.go:21
↓ 17 callersMethodClose
()
pkg/appmain/appmain.go:19
↓ 16 callersMethodAddCreateEndpoint
(fn CreateEndpointFn)
pkg/server/server.go:63
↓ 16 callersFunctiongetGaugeOpts
(name string)
cmd/controller/prometheus/frontend.go:42
↓ 14 callersMethodScan
(dest ...any)
cmd/controller/storage/postgres/postgres.go:29
↓ 13 callersMethodRun
(group Group)
pkg/task/task.go:17
↓ 9 callersFunctionEnsureValidToken
EnsureValidToken is a middleware that will check the validity of our JWT.
pkg/middleware/jwt.go:35
↓ 8 callersMethodGo
(string, Task)
pkg/task/task.go:23
↓ 7 callersFunctionInfof
(format string, v ...any)
pkg/logger/logger.go:176
↓ 7 callersMethodValue
()
cmd/controller/storage/storage.go:48
↓ 7 callersFunctioncheckAgent
(t *testing.T, db storage.Storage, check restapi.Agent)
cmd/controller/storage/tests/storage_test.go:147
↓ 6 callersFunctionDebugf
(format string, v ...any)
pkg/logger/logger.go:188
↓ 6 callersFunctionPanic
(v ...any)
pkg/logger/logger.go:138
↓ 6 callersMethodRelease
()
cmd/agent/app/agent.go:58
↓ 5 callersMethodCancel
()
pkg/task/task.go:22
↓ 5 callersMethodGetAgentById
(id string)
cmd/controller/storage/storage.go:83
↓ 5 callersMethodGoFn
(string, TaskFn)
pkg/task/task.go:24
↓ 5 callersFunctionTracef
(format string, v ...any)
pkg/logger/logger.go:200
↓ 5 callersMethodUpdateAgent
(update restapi.AgentUpdate)
cmd/controller/storage/storage.go:84
↓ 5 callersFunctionWarning
(v ...any)
pkg/logger/logger.go:158
↓ 5 callersFunctioncompare
(t *testing.T, check T, against T, err error)
cmd/controller/storage/tests/storage_test.go:119
↓ 4 callersMethodGetGpus
()
pkg/gpu/gpu.go:83
↓ 4 callersMethodGetSessionById
(id string)
cmd/controller/storage/storage.go:89
↓ 4 callersMethodId
()
cmd/agent/session/session.go:61
↓ 4 callersMethodWait
()
pkg/task/task.go:28
↓ 4 callersFunctiondefaultSessionRequirements
(gpuVram uint64)
cmd/controller/backend/backend_test.go:59
↓ 4 callersMethoddo
(ctx context.Context, method string, path string, contentType string, body io.Reader)
pkg/restapi/client.go:38
↓ 4 callersFunctionjsonReaderFromObject
(object T)
pkg/restapi/helpers.go:89
↓ 4 callersFunctionopenMemdb
(t *testing.T)
cmd/controller/storage/tests/storage_test.go:20
↓ 4 callersFunctionopenPostgres
(t *testing.T)
cmd/controller/storage/tests/storage_test.go:29
↓ 4 callersFunctionqueueSession
(t *testing.T, db storage.Storage, requirements restapi.SessionRequirements)
cmd/controller/backend/backend_test.go:174
↓ 4 callersMethodsetExitStatus
(exitStatus string)
cmd/agent/session/session.go:81
↓ 3 callersMethodAddConsumer
(consumer MetricsConsumerFn)
cmd/agent/gpu/metrics.go:40
↓ 3 callersMethodCount
()
pkg/gpu/gpu.go:75
↓ 3 callersMethodGetSessionWithContext
(ctx context.Context, id string)
pkg/restapi/client.go:90
↓ 3 callersFunctionInfo
(v ...any)
pkg/logger/logger.go:170
↓ 3 callersFunctionNewDefaultIterator
(objects []T)
cmd/controller/storage/storage.go:56
↓ 3 callersFunctionOpenStorage
(ctx context.Context, connection string)
cmd/controller/storage/postgres/postgres.go:256
↓ 3 callersFunctionOpenStorage
(ctx context.Context)
cmd/controller/storage/memdb/memdb.go:43
↓ 3 callersMethodRegisterAgent
(agent restapi.Agent)
cmd/controller/storage/storage.go:82
↓ 3 callersMethodRequestSession
(requirements restapi.SessionRequirements)
cmd/controller/storage/storage.go:86
↓ 3 callersFunctionRun
(name string, version string, logic task.TaskFn)
pkg/appmain/appmain.go:31
↓ 3 callersMethodSetAgentsMissingIfNotUpdatedFor
(duration time.Duration)
cmd/controller/storage/storage.go:96
↓ 3 callersFunctionTotalVramRequired
(requirements restapi.SessionRequirements)
cmd/controller/storage/storage.go:113
↓ 3 callersFunctioncheckSession
(t *testing.T, db storage.Storage, check restapi.Session)
cmd/controller/storage/tests/storage_test.go:153
↓ 3 callersFunctioncompare
(t *testing.T, check T, against T, err error)
cmd/controller/backend/backend_test.go:115
↓ 3 callersFunctiondefaultAgent
(gpuVram uint64)
cmd/controller/backend/backend_test.go:37
↓ 3 callersMethodget
(ctx context.Context, path string)
pkg/restapi/client.go:56
↓ 3 callersMethodgetSession
(id string)
cmd/agent/app/agent.go:178
↓ 3 callersFunctionnewIterator
(ctx context.Context, statement *sql.Stmt, unmarshal unmarshalFn[T])
cmd/controller/storage/postgres/postgres.go:45
↓ 3 callersFunctionqueueSession
(t *testing.T, db storage.Storage, requirements restapi.SessionRequirements)
cmd/controller/storage/tests/storage_test.go:178
↓ 3 callersFunctionregisterAgent
(t *testing.T, db storage.Storage, agent restapi.Agent)
cmd/controller/backend/backend_test.go:161
↓ 3 callersFunctionstrconvErr
The following was pulled largely from database/sql/convert.go:convertAssignRows
cmd/controller/storage/postgres/composite.go:115
↓ 3 callersMethodupdate
(ctx context.Context)
cmd/controller/backend/backend.go:97
↓ 3 callersFunctionvalidateResponse
(response *http.Response)
pkg/restapi/helpers.go:72
↓ 2 callersMethodAssignSession
(sessionId string, agentId string, gpus []restapi.SessionGpu)
cmd/controller/storage/storage.go:87
↓ 2 callersFunctionErrorf
(format string, v ...any)
pkg/logger/logger.go:152
↓ 2 callersMethodFind
(requirements []restapi.GpuRequirements)
pkg/gpu/gpu.go:132
↓ 2 callersFunctionGenerateCertificate
()
pkg/crypto/certificate.go:18
↓ 2 callersMethodGetAgentWithContext
(ctx context.Context, id string)
pkg/restapi/client.go:156
↓ 2 callersMethodGetAgents
For Testing
cmd/controller/storage/storage.go:92
↓ 2 callersMethodGetPciBusString
()
pkg/gpu/gpu.go:104
↓ 2 callersMethodGetQueuedSessionById
(id string)
cmd/controller/storage/storage.go:90
↓ 2 callersMethodGetQueuedSessionsIterator
()
cmd/controller/storage/storage.go:94
↓ 2 callersFunctionNewBackend
(storage storage.Storage)
cmd/controller/backend/backend.go:22
↓ 2 callersFunctionNewPCIAddressFromString
(pciIdentifier string)
pkg/gpu/pci.go:20
↓ 2 callersFunctionNewServer
(address string, tlsConfig *tls.Config)
pkg/server/server.go:36
↓ 2 callersMethodPort
()
pkg/server/server.go:59
↓ 2 callersFunctionReadBodyAsBytes
(header http.Header, statusCode int, body io.ReadCloser, contentLength int64)
pkg/net/http.go:176
↓ 2 callersMethodRegisterAgentWithContext
(ctx context.Context, agent Agent)
pkg/restapi/client.go:189
↓ 2 callersMethodRemoveMissingAgentsIfNotUpdatedFor
(duration time.Duration)
cmd/controller/storage/storage.go:97
↓ 2 callersMethodSelect
(chosenGpus []restapi.SessionGpu)
pkg/gpu/gpu.go:186
↓ 2 callersMethodSetCreateEndpoint
(name string, fn CreateEndpointFn)
pkg/server/server.go:67
↓ 2 callersMethodStart
(group task.Group)
cmd/agent/session/session.go:111
↓ 2 callersMethodStatusWithContext
(ctx context.Context)
pkg/restapi/client.go:76
↓ 2 callersFunctionTotalVram
(gpus []restapi.Gpu)
cmd/controller/storage/storage.go:104
↓ 2 callersMethodUpdateAgentWithContext
(ctx context.Context, update AgentUpdate)
pkg/restapi/client.go:170
↓ 2 callersMethodchangeState
(newState string)
cmd/agent/session/session.go:87
↓ 2 callersFunctiondefaultAgent
(gpuVram uint64)
cmd/controller/storage/tests/storage_test.go:38
↓ 2 callersFunctiondefaultSessionRequirements
(gpuVram uint64)
cmd/controller/storage/tests/storage_test.go:63
↓ 2 callersMethoddoUrl
(ctx context.Context, method string, url url.URL, contentType string, body io.Reader)
pkg/restapi/client.go:21
↓ 2 callersMethodensureCapacity
(newElements int)
pkg/utilities/linkedList.go:64
↓ 2 callersFunctionisSubset
(set, subset map[string]string)
cmd/controller/backend/backend.go:48
↓ 2 callersFunctionparseBody
(body io.Reader, length int64)
pkg/restapi/helpers.go:14
↓ 2 callersFunctionparseResponse
(response *http.Response, contentType string)
pkg/restapi/helpers.go:30
↓ 2 callersFunctionparseStringResponse
(response *http.Response)
pkg/restapi/helpers.go:63
↓ 2 callersMethodpopFreeNode
()
pkg/utilities/linkedList.go:94
↓ 2 callersMethodpostWithJson
(ctx context.Context, path string, body io.Reader)
pkg/restapi/client.go:64
↓ 2 callersMethodputWithJson
(ctx context.Context, path string, body io.Reader)
pkg/restapi/client.go:68
↓ 2 callersFunctionregisterAgent
(t *testing.T, db storage.Storage, agent restapi.Agent)
cmd/controller/storage/tests/storage_test.go:165
↓ 2 callersMethodretrieveRows
()
cmd/controller/storage/postgres/postgres.go:65
↓ 2 callersMethodrun
(label string, task TaskFn)
pkg/task/task.go:93
↓ 2 callersMethodrunSession
(group task.Group, id string, juicePath string, version string, gpus *gpu.SelectedGpuSet)
cmd/agent/app/agent.go:222
↓ 2 callersFunctionsetupIpc
()
cmd/agent/session/session_linux.go:14
↓ 2 callersFunctionunmarshalSession
(row sqlRow)
cmd/controller/storage/postgres/postgres.go:199
next →1–100 of 311, ranked by callers