Functions — github.com/InferCore/InferCore

hub / github.com/InferCore/InferCore / functions

Functions489 in github.com/InferCore/InferCore

⨍ Functions 489◇ Types & classes 124

↓ 80 callersMethodClose

()

internal/requests/store.go:18

↓ 57 callersMethodError

()

internal/upstream/errors.go:20

↓ 53 callersFunctionNew

(kind Kind, message string)

internal/upstream/errors.go:24

↓ 29 callersMethodWriteHeader

(statusCode int)

internal/server/server.go:877

↓ 28 callersMethodRoutes

()

internal/server/server.go:142

↓ 27 callersFunctionLoad

(path string)

internal/config/config.go:190

↓ 26 callersFunctionNew

(cfg *config.Config)

internal/server/server.go:101

↓ 22 callersFunctiontestConfig

(timeoutMS int, fallbackEnabled bool)

internal/server/server_test.go:1051

↓ 22 callersFunctionwriteTempConfig

(t *testing.T, content string)

internal/config/config_test.go:592

↓ 21 callersFunctionpostInfer

(t *testing.T, baseURL string, payload map[string]any)

internal/server/server_test.go:868

↓ 15 callersFunctionassertStructuredError

(t *testing.T, body []byte, expectedCode string)

internal/server/server_test.go:895

↓ 13 callersFunctionNormalizeAIRequest

NormalizeAIRequest fills defaults for extended AI Request fields.

internal/types/normalize.go:6

↓ 11 callersMethodInvoke

(ctx context.Context, req types.BackendRequest)

internal/interfaces/interfaces.go:20

↓ 11 callersFunctionNewRuleRouter

(cfg *config.Config, costEngine interfaces.CostEngine)

internal/router/rule_router.go:17

↓ 9 callersFunctionNew

(cfg config.BackendConfig)

internal/adapters/vllm/vllm.go:30

↓ 9 callersMethodSelectRoute

(ctx context.Context, req types.AIRequest, state types.RuntimeState)

internal/router/rule_router.go:24

↓ 9 callersMethodemitInferTrace

(traceID, spanID string, start time.Time, requestID, tenantID, backend, result string)

internal/server/server.go:683

↓ 9 callersFunctiontestRouterConfig

()

internal/router/rule_router_test.go:12

↓ 9 callersFunctionwriteError

(w http.ResponseWriter, status int, requestID, code, message string)

internal/server/server.go:662

↓ 8 callersMethodCreateRequest

(ctx context.Context, row RequestRow)

internal/requests/store.go:13

↓ 8 callersFunctionNewMemoryStore

NewMemoryStore returns an in-process ledger (non-durable).

internal/requests/memory.go:17

↓ 8 callersFunctionReplay

Replay reconstructs an AI request from the ledger and re-executes it.

internal/replay/replay.go:41

↓ 8 callersMethodRun

Run executes normalize → policy → (agent stub?) → admission → route → (RAG?) → backend → finalize.

internal/inferexec/orchestrator.go:45

↓ 8 callersFunctionbaseReq

()

internal/inferexec/orchestrator_test.go:70

↓ 7 callersMethodBackendByName

(name string)

internal/config/config.go:473

↓ 7 callersFunctionInferBudgetHTTPStatus

InferBudgetHTTPStatus returns 504 only when the infer-scoped context hit its deadline.

internal/inferexec/budget.go:10

↓ 7 callersFunctionNewBasicEngine

(cfg *config.Config)

internal/policy/basic_engine.go:22

↓ 7 callersFunctionNewSimpleEngine

()

internal/cost/simple_engine.go:9

↓ 7 callersMethodfailLedger

(ctx context.Context, requestID string)

internal/inferexec/orchestrator.go:218

↓ 6 callersMethodEvaluate

(_ context.Context, req types.AIRequest)

internal/policy/basic_engine.go:29

↓ 6 callersMethodHealth

(ctx context.Context)

internal/interfaces/interfaces.go:21

↓ 6 callersFunctionNew

(cfg config.BackendConfig)

internal/adapters/gemini/gemini.go:59

↓ 6 callersFunctionNew

(cfg config.BackendConfig)

internal/adapters/mock/mock.go:16

↓ 6 callersMethodShutdown

(context.Context)

internal/server/server.go:157

↓ 6 callersFunctionassertAdapterConformance

(t *testing.T, adapter interfaces.BackendAdapter)

internal/adapters/conformance_test.go:211

↓ 5 callersMethodGetRequest

(ctx context.Context, requestID string)

internal/requests/store.go:16

↓ 5 callersMethodName

()

internal/interfaces/interfaces.go:49

↓ 5 callersFunctionNew

(cfg config.BackendConfig)

internal/adapters/anthropic/anthropic.go:33

↓ 5 callersFunctionNewExporterFromConfig

(cfg config.TelemetryConfig)

internal/telemetry/factory.go:11

↓ 5 callersMethodRun

Run executes fn and persists one ledger step when Store is non-nil. When ledger is disabled (Store nil), fn still runs; OnStep is invoked if set.

internal/execution/steps.go:36

↓ 5 callersFunctiontestConfig

()

internal/policy/basic_engine_test.go:11

↓ 4 callersFunctionClassify

Classify returns pipeline kind from ref or request type.

internal/pipelines/registry.go:26

↓ 4 callersFunctionExecutionPlanForRequestType

ExecutionPlanForRequestType returns the ordered phases for a request type after policy normalization. Agent stops after stub; inference skips retrieve

internal/inferexec/plan.go:25

↓ 4 callersMethodMetadata

()

internal/interfaces/interfaces.go:22

↓ 4 callersFunctionNewDependenciesFromConfig

NewDependenciesFromConfig builds policy/router/reliability for CLI replay.

internal/replay/replay.go:250

↓ 4 callersFunctionNewFromConfig

NewFromConfig returns a ledger Store or nil when ledger is disabled.

internal/requests/factory.go:11

↓ 4 callersFunctionNewMemoryEngine

()

internal/slo/memory_engine.go:27

↓ 4 callersFunctionNewMemoryEngineFromConfig

(c config.SLOStoreConfig)

internal/slo/memory_engine.go:31

↓ 4 callersFunctionNewOTLPHTTPExporter

(endpoint string, timeout time.Duration, retries, batchSize int, flushEvery time.Duration)

internal/telemetry/otlp_http_exporter.go:31

↓ 4 callersFunctionNewTraceID

()

internal/traceutil/ids.go:8

↓ 4 callersMethodRecordCompletion

(requestID string, ts time.Time)

internal/interfaces/interfaces.go:60

↓ 4 callersMethodRecordFirstToken

(requestID string, ts time.Time)

internal/interfaces/interfaces.go:59

↓ 4 callersMethodRecordStart

(requestID string)

internal/interfaces/interfaces.go:58

↓ 4 callersMethodapplyHeaders

(req *http.Request)

internal/adapters/vllm/vllm.go:399

↓ 4 callersFunctionbackendSelectable

(state types.RuntimeState, backendName string)

internal/router/rule_router.go:49

↓ 4 callersMethodensureRecord

(requestID string)

internal/slo/memory_engine.go:184

↓ 4 callersMethodevictLocked

()

internal/slo/memory_engine.go:193

↓ 4 callersFunctionhasCapability

(capabilities []string, expected string)

internal/router/rule_router.go:167

↓ 4 callersMethodisAzure

()

internal/adapters/vllm/vllm.go:344

↓ 4 callersFunctionwriteJSON

(w http.ResponseWriter, status int, v any)

internal/server/server.go:656

↓ 3 callersFunctionBackendHealthOK

BackendHealthOK mirrors routing semantics: unknown backends are treated as selectable.

internal/router/rule_router.go:39

↓ 3 callersMethodCurrentSignals

CurrentSignals implements interfaces.ScalingSignalProvider for autoscaler-facing hints.

internal/server/server.go:813

↓ 3 callersFunctionFromConfig

FromConfig builds retrieval adapters from knowledge_bases.

internal/retrieval/build.go:12

↓ 3 callersFunctionIsValidTrigger

(trigger string)

internal/fallback/triggers.go:19

↓ 3 callersFunctionNewManager

(cfg *config.Config, adapters map[string]interfaces.BackendAdapter)

internal/reliability/manager.go:24

↓ 3 callersFunctionNewRerankFromConfig

NewRerankFromConfig returns the configured reranker. Only "noop" is implemented; unknown types fall back to noop.

internal/retrieval/rerank_factory.go:12

↓ 3 callersFunctionNewSpanID

()

internal/traceutil/ids.go:12

↓ 3 callersFunctionNewWithDependencies

(cfg *config.Config, sloEngine interfaces.SLOEngine, telemetryExporter interfaces.TelemetryExporter)

internal/server/server.go:105

↓ 3 callersFunctionRun

Run posts each item to POST {baseURL}/infer and prints a summary to w. defaultPipeline is applied when an item omits pipeline_ref. apiKey, if non-empt

internal/eval/eval.go:44

↓ 3 callersMethodUpdateRequest

(ctx context.Context, requestID string, patch RequestPatch)

internal/requests/store.go:14

↓ 3 callersMethodapplyAPIKey

(req *http.Request)

internal/adapters/gemini/gemini.go:376

↓ 3 callersMethodapplyExtraHeaders

(req *http.Request)

internal/adapters/gemini/gemini.go:386

↓ 3 callersMethodapplyExtraHeaders

(req *http.Request)

internal/adapters/anthropic/anthropic.go:320

↓ 3 callersFunctioneffectiveTopK

(kb config.KnowledgeBaseConfig, opts map[string]any, fallback int)

internal/retrieval/common.go:5

↓ 3 callersMethodenqueue

(kind string, record map[string]any)

internal/telemetry/otlp_http_exporter.go:106

↓ 3 callersFunctionfirstString

(m map[string]any, keys ...string)

internal/retrieval/opensearch_kb.go:135

↓ 3 callersFunctiongeminiCandidatesText

(candidates []gemCandidate)

internal/adapters/gemini/gemini.go:41

↓ 3 callersFunctionhttpClientTimeoutMS

(kb config.KnowledgeBaseConfig)

internal/retrieval/common.go:28

↓ 3 callersFunctionnullStringBytes

(b []byte)

internal/requests/postgres.go:135

↓ 3 callersFunctionreplayTestConfig

()

internal/replay/replay_test.go:77

↓ 3 callersFunctiontestConfigTwoBackends

(timeoutMS int, fallbackEnabled bool)

internal/server/server_test.go:976

↓ 3 callersFunctiontestConfigWithFileKB

(t *testing.T)

internal/server/server_test.go:186

↓ 3 callersFunctiontoInt

(v any)

internal/policy/basic_engine.go:156

↓ 3 callersFunctiontruncateForErr

(b []byte, max int)

internal/retrieval/http_kb.go:81

↓ 2 callersMethodEmitTrace

(trace types.TraceRecord)

internal/interfaces/interfaces.go:68

↓ 2 callersMethodError

()

internal/server/infer_rag.go:20

↓ 2 callersMethodEstimate

(req types.AIRequest, backend types.BackendMetadata)

internal/cost/simple_engine.go:13

↓ 2 callersMethodEvaluate

(ctx context.Context, req types.AIRequest)

internal/interfaces/interfaces.go:15

↓ 2 callersMethodExecuteWithFallback

( ctx context.Context, req types.AIRequest, primary types.RouteDecision, fallback []types.RouteDecisio

internal/interfaces/interfaces.go:26

↓ 2 callersMethodGetRequest

(ctx context.Context, requestID string)

internal/requests/sqlite.go:149

↓ 2 callersMethodGetRequest

(ctx context.Context, requestID string)

internal/requests/postgres.go:142

↓ 2 callersFunctionHTTPLayerTimeouts

HTTPLayerTimeouts returns net/http.Server timeouts. If server.http.{read,write,idle}_timeout_ms are > 0, those values are used; otherwise defaults are

internal/server/server.go:73

↓ 2 callersFunctionItemFromRequestRow

ItemFromRequestRow builds an eval Item from a ledger row (requires ai_request_json). If the row has selected_backend (successful completion), it is co

internal/eval/ledger_export.go:13

↓ 2 callersFunctionMergeRetrievalIntoInput

MergeRetrievalIntoInput writes retrieval/rerank output into req.Input (retrieved_context, retrieved_chunks).

internal/retrieval/merge.go:10

↓ 2 callersMethodName

Name implements RerankAdapter.

internal/retrieval/noop_rerank.go:13

↓ 2 callersFunctionNew

(cfg config.BackendConfig)

internal/adapters/bedrock/bedrock.go:25

↓ 2 callersFunctionNewHTTPJSONKB

NewHTTPJSONKB builds an adapter for knowledge_bases type "http".

internal/retrieval/http_kb.go:29

↓ 2 callersFunctionNewLogExporter

()

internal/telemetry/log_exporter.go:11

↓ 2 callersMethodRerank

(ctx context.Context, query string, chunks []types.RetrievalChunk, opts map[string]any)

internal/interfaces/interfaces.go:50

↓ 2 callersMethodRetrieve

(ctx context.Context, query string, opts map[string]any)

internal/interfaces/interfaces.go:44

next →1–100 of 489, ranked by callers