Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ankorstore/yokai
/ functions
Functions
2,008 in github.com/ankorstore/yokai
⨍
Functions
2,008
◇
Types & classes
442
↓ 4 callers
Method
Generate
Generate returns the configured deterministic value.
generate/generatetest/uuidv7/generator.go:37
↓ 4 callers
Method
GetAppName
()
fxhttpserver/testdata/service/service.go:17
↓ 4 callers
Method
Handle
()
fxhttpserver/registry.go:17
↓ 4 callers
Method
IncrementCronJobExecutionError
IncrementCronJobExecutionError increments the number of execution errors for a given cron job.
fxcron/metrics.go:98
↓ 4 callers
Method
IncrementWorkerExecutionError
IncrementWorkerExecutionError increments the failing workers counter for a given worker name.
worker/metrics.go:85
↓ 4 callers
Method
IncrementWorkerExecutionRestart
IncrementWorkerExecutionRestart increments the restarted workers counter for a given worker name.
worker/metrics.go:67
↓ 4 callers
Method
Level
Level returns the level of the [TestLogRecord].
log/logtest/record.go:25
↓ 4 callers
Method
Message
Message returns the message of the [TestLogRecord].
log/logtest/record.go:39
↓ 4 callers
Method
Metrics
Metrics returns the [WorkerPool] internal [WorkerMetrics].
worker/pool.go:90
↓ 4 callers
Method
Middlewares
()
fxworker/define.go:30
↓ 4 callers
Method
Names
Names returns all registered Task names.
fxcore/task.go:72
↓ 4 callers
Function
NewHandlerDefinition
NewHandlerDefinition returns a new [HandlerDefinition].
fxhttpserver/define.go:55
↓ 4 callers
Method
Ping
Ping pings a connection for context.
sql/connection.go:244
↓ 4 callers
Method
Printf
Printf logs with info level, and prints to stdout if configured to do so.
fxsql/logger.go:27
↓ 4 callers
Method
Reset
()
trace/tracetest/exporter.go:16
↓ 4 callers
Method
ResolveCronJobs
ResolveCronJobs resolves a list of [ResolvedCronJob] from their definitions.
fxcron/registry.go:38
↓ 4 callers
Method
ResolveWorkersRegistrations
ResolveWorkersRegistrations resolves a list of [worker.WorkerRegistration] from their definitions.
fxworker/registry.go:35
↓ 4 callers
Method
Run
(ctx context.Context)
fxcron/registry.go:13
↓ 4 callers
Method
Span
Span get a specific [tracetest.SpanStub] from the in memory internal exporter by name.
trace/tracetest/exporter.go:54
↓ 4 callers
Method
Spans
Spans get the [tracetest.SpanStubs] from the in memory internal exporter.
trace/tracetest/exporter.go:49
↓ 4 callers
Method
applyAfterHooks
(event *HookEvent)
sql/statement.go:170
↓ 4 callers
Method
applyBeforeHooks
(event *HookEvent)
sql/statement.go:164
↓ 4 callers
Function
bestEffortStop
bestEffortStop runs a best-effort telemetry operation under a bounded context and logs any error without propagating it.
fxtrace/module.go:100
↓ 4 callers
Function
createTestDB
(t *testing.T)
sql/healthcheck/probe_test.go:78
↓ 4 callers
Method
resolveMiddlewareDefinition
(middlewareDefinition MiddlewareDefinition)
fxhttpserver/registry.go:160
↓ 3 callers
Method
Add
Add adds and register a given Driver for a name.
sql/registry.go:30
↓ 3 callers
Method
Begin
Begin starts a transaction and returns a driver.Tx.
sql/connection.go:201
↓ 3 callers
Method
Buffer
Buffer returns the internal buffer.
log/logtest/buffer.go:39
↓ 3 callers
Method
Check
Check returns a successful [healthcheck.CheckerProbeResult] if the worker pool executions are all in healthy status.
worker/healthcheck/probe.go:44
↓ 3 callers
Method
Columns
()
sql/statement_test.go:98
↓ 3 callers
Method
Concrete
()
fxhttpserver/define.go:40
↓ 3 callers
Method
Configuration
Configuration returns the Configuration of the Driver.
sql/driver.go:32
↓ 3 callers
Method
Create
(mcpServer *server.MCPServer, options ...server.StdioOption)
fxmcpserver/server/stdio/factory.go:13
↓ 3 callers
Method
Create
Create returns a new [OTEL TracerProvider], and accepts a list of [TracerProviderOption]. For example: tp, _ := trace.NewDefaultTracerProviderFacto
trace/factory.go:39
↓ 3 callers
Method
Create
(ctx context.Context, model *TestModel)
fxorm/testdata/model/repository.go:31
↓ 3 callers
Method
Create
(opts ...HttpClientOption)
httpclient/factory.go:9
↓ 3 callers
Function
CtxLogger
CtxLogger returns the contextual [log.Logger].
grpcserver/context.go:15
↓ 3 callers
Method
Exec
Exec executes a query and returns a driver.Result.
sql/connection.go:39
↓ 3 callers
Method
Fatal
Fatal produces a log with fatal level.
httpserver/logger.go:143
↓ 3 callers
Method
FindAll
(ctx context.Context)
fxorm/testdata/model/repository.go:19
↓ 3 callers
Function
GetType
GetType returns a stable identifier for the given target’s type.
fxworker/reflect.go:28
↓ 3 callers
Method
Handlers
()
fxhttpserver/resolve.go:82
↓ 3 callers
Method
Has
Has returns true is a driver is already registered for a given name.
sql/registry.go:53
↓ 3 callers
Method
Implementation
Implementation return the resolved grpc server service implementation.
fxgrpcserver/resolve.go:20
↓ 3 callers
Method
IncrementCronJobExecutionSuccess
IncrementCronJobExecutionSuccess increments the number of execution successes for a given cron job.
fxcron/metrics.go:89
↓ 3 callers
Method
IncrementWorkerExecutionStart
IncrementWorkerExecutionStart increments the started workers counter for a given worker name.
worker/metrics.go:58
↓ 3 callers
Method
IncrementWorkerExecutionSuccess
IncrementWorkerExecutionSuccess increments the successful workers counter for a given worker name.
worker/metrics.go:76
↓ 3 callers
Method
Info
Info returns the MCPStdioServer information.
fxmcpserver/server/stdio/server.go:79
↓ 3 callers
Function
IsConcreteHandler
IsConcreteHandler returns true if the handler is a concrete [echo.HandlerFunc] implementation.
fxhttpserver/reflect.go:52
↓ 3 callers
Method
ListItems
ListItems returns the list of TaskListItem for the dashboard sidebar, sorted by name, collapsing tasks that share the same group under a single group
fxcore/task.go:93
↓ 3 callers
Method
Message
Message returns the worker execution message.
worker/event.go:30
↓ 3 callers
Function
NewConfiguration
NewConfiguration returns a new Configuration.
sql/configuration.go:10
↓ 3 callers
Function
NewDriver
NewDriver returns a new Driver.
sql/driver.go:19
↓ 3 callers
Function
NewResolvedHandler
NewResolvedHandler returns a new [ResolvedHandler].
fxhttpserver/resolve.go:50
↓ 3 callers
Function
NewResolvedMiddleware
NewResolvedMiddleware returns a new [ResolvedMiddleware].
fxhttpserver/resolve.go:17
↓ 3 callers
Method
ObserveCronJobExecutionDuration
ObserveCronJobExecutionDuration observes the duration of a cron job execution.
fxcron/metrics.go:80
↓ 3 callers
Method
Panic
Panic produces a log with panic level.
httpserver/logger.go:158
↓ 3 callers
Method
Prepare
Prepare prepares a query and returns a driver.Stmt.
sql/connection.go:159
↓ 3 callers
Method
Query
Query executes a statement and returns a driver.Rows.
sql/statement.go:120
↓ 3 callers
Method
Query
Query executes a query and returns a driver.Rows.
sql/connection.go:111
↓ 3 callers
Method
Registration
Registration returns the [WorkerRegistration] from the [WorkerPool] for a given worker name.
worker/pool.go:103
↓ 3 callers
Method
Render
Render renders the core dashboard template.
fxcore/renderer.go:24
↓ 3 callers
Method
Reset
Reset resets the in memory internal exporter.
trace/tracetest/exporter.go:42
↓ 3 callers
Method
ResolveCheckerProbesRegistrations
ResolveCheckerProbesRegistrations resolves [healthcheck.CheckerProbeRegistration] from their definitions.
fxhealthcheck/registry.go:32
↓ 3 callers
Method
ResolveGrpcServerServices
ResolveGrpcServerServices resolves a list of [ResolvedGrpcServerService] from their definitions.
fxgrpcserver/registry.go:67
↓ 3 callers
Method
ReturnType
()
fxworker/define.go:28
↓ 3 callers
Method
RoundTrip
RoundTrip performs a request / response round trip, based on the wrapped [http.Transport].
httpclient/transport/base.go:52
↓ 3 callers
Method
Run
Run runs a specific Task.
fxcore/task.go:131
↓ 3 callers
Method
Running
Running returns true if the MCPStdioServer is running.
fxmcpserver/server/stdio/server.go:71
↓ 3 callers
Method
Service
Service returns the service name of the [TestLogRecord].
log/logtest/record.go:53
↓ 3 callers
Method
SetId
SetId sets the [WorkerExecution] id.
worker/execution.go:41
↓ 3 callers
Method
SetName
SetName sets the name of the [SQLProbe].
sql/healthcheck/probe.go:37
↓ 3 callers
Method
Time
Time returns the time of the [TestLogRecord].
log/logtest/record.go:67
↓ 3 callers
Method
Timestamp
Timestamp returns the worker execution timestamp.
worker/event.go:35
↓ 3 callers
Method
ToZerolog
ToZerolog converts new [log.Logger] to a [zerolog.Logger].
httpserver/logger.go:28
↓ 3 callers
Method
TrackJobExecution
(jobName string)
fxcron/testdata/cron/tracker/tracker.go:16
↓ 3 callers
Method
Types
()
fxvalidator/define.go:103
↓ 2 callers
Method
Alias
()
fxvalidator/define.go:7
↓ 2 callers
Method
Base
Base returns the base driver.Driver of the Driver.
sql/driver.go:27
↓ 2 callers
Method
BeginTx
BeginTx starts a transaction for a context and returns a driver.Tx.
sql/connection.go:220
↓ 2 callers
Method
CallEvenIfNull
()
fxvalidator/define.go:38
↓ 2 callers
Method
Check
Check returns a successful [healthcheck.CheckerProbeResult] if the database connection can be pinged.
sql/healthcheck/probe.go:44
↓ 2 callers
Method
Check
Check returns a successful [healthcheck.CheckerProbeResult] if the database connection can be pinged.
orm/healthcheck/probe.go:44
↓ 2 callers
Method
Close
()
fxmcpserver/fxmcpservertest/stream.go:38
↓ 2 callers
Method
Commit
Commit commits the Transaction.
sql/transaction.go:35
↓ 2 callers
Method
Config
Config returns the MCPStdioServer config.
fxmcpserver/server/stdio/server.go:46
↓ 2 callers
Method
Connect
Connect returns a new driver.Conn.
sql/connector.go:27
↓ 2 callers
Method
ContainRecord
(expectedAttributes map[string]interface{})
log/logtest/buffer.go:20
↓ 2 callers
Method
ContainSpan
(expectedName string, expectedAttributes ...attribute.KeyValue)
trace/tracetest/exporter.go:20
↓ 2 callers
Function
Contains
Contains returns true if a provided string is found in a list of strings.
fxcron/util.go:6
↓ 2 callers
Function
Contains
Contains returns true if a given string can be found in a given slice of strings.
grpcserver/util.go:4
↓ 2 callers
Method
Create
Create returns a new [Checker], and accepts a list of [CheckerOption]. For example: checker, _ := healthcheck.NewDefaultCheckerFactory().Create( h
healthcheck/factory.go:23
↓ 2 callers
Method
Create
(opts ...grpc.DialOption)
grpcserver/grpcservertest/factory.go:15
↓ 2 callers
Method
Data
()
fxcore/info.go:47
↓ 2 callers
Method
Data
Data return the data of the module info.
fxcron/info.go:31
↓ 2 callers
Method
Driver
Driver returns the Driver of the Connector.
sql/connector.go:41
↓ 2 callers
Method
Dump
Dump prints the internal buffer log records, for debugging purposes.
log/logtest/buffer.go:124
↓ 2 callers
Method
Errorf
(format string, args ...interface{})
fxmetrics/testdata/spy/spy.go:34
↓ 2 callers
Method
Exclude
Exclude configures a list of method names to exclude from logging.
grpcserver/logger.go:50
↓ 2 callers
Method
ExecutionId
ExecutionId returns the worker execution id.
worker/event.go:25
← previous
next →
201–300 of 2,008, ranked by callers