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
↓ 10 callers
Method
Write
Write writes into the internal buffer.
log/logtest/buffer.go:44
↓ 10 callers
Function
prepareTestServiceGrpcServerAndClient
(t *testing.T, logger *log.Logger, exclusions []string, metadata map[string]string, withTestInterceptors bool)
grpcserver/logger_test.go:752
↓ 9 callers
Method
After
(context.Context, *HookEvent)
sql/hook.go:12
↓ 9 callers
Method
Exec
Exec executes a statement and returns a driver.Result.
sql/statement.go:51
↓ 9 callers
Method
Kinds
()
fxhealthcheck/define.go:8
↓ 9 callers
Method
LogMode
LogMode sets the logger log level.
orm/logger.go:30
↓ 9 callers
Method
Records
Records return the list of [TestLogRecord] from the internal buffer.
log/logtest/buffer.go:62
↓ 9 callers
Method
Recv
()
grpcserver/testdata/proto/test_grpc.pb.go:57
↓ 9 callers
Method
Send
(*Request)
grpcserver/testdata/proto/test_grpc.pb.go:56
↓ 9 callers
Method
ToZerolog
ToZerolog converts as [Logger] into a [Zerolog logger]. [Zerolog logger]: https://github.com/rs/zerolog/blob/master/log.go
log/logger.go:28
↓ 9 callers
Function
createTestLogTools
(t *testing.T)
sql/register_test.go:779
↓ 9 callers
Function
createTestTraceTools
(t *testing.T)
sql/register_test.go:792
↓ 9 callers
Function
registerTestDriver
(t *testing.T)
sql/register_test.go:728
↓ 8 callers
Method
ContainAttributes
ContainAttributes returns true if the [TestLogRecord] partially matches provided attributes. nolint:cyclop
log/logtest/record.go:143
↓ 8 callers
Method
Execution
Execution returns the [WorkerExecution] from the [WorkerPool] for a given worker name.
worker/pool.go:123
↓ 8 callers
Method
Expression
()
fxcron/define.go:10
↓ 8 callers
Method
Hooks
Hooks returns the Configuration list of Hook.
sql/configuration.go:23
↓ 8 callers
Method
MaxExecutionsAttempts
MaxExecutionsAttempts returns the [WorkerExecution] max execution attempts.
worker/execution.go:96
↓ 8 callers
Method
Name
()
healthcheck/probe.go:9
↓ 8 callers
Method
Name
()
fxcron/registry.go:12
↓ 8 callers
Function
NewMiddlewareDefinition
NewMiddlewareDefinition returns a new [MiddlewareDefinition].
fxhttpserver/define.go:16
↓ 8 callers
Method
Probe
Probe returns the [CheckerProbe] of the [CheckerProbeRegistration].
healthcheck/checker.go:28
↓ 8 callers
Method
RegisterProbe
RegisterProbe registers a [CheckerProbe] for an optional list of [ProbeKind]. If no [ProbeKind] is provided, the [CheckerProbe] will be registered for
healthcheck/checker.go:82
↓ 8 callers
Method
ResolveHandlers
ResolveHandlers resolves a list of [ResolvedHandler] from their definitions.
fxhttpserver/registry.go:78
↓ 8 callers
Method
Running
Running returns true if the MCPSSEServer is running.
fxmcpserver/server/sse/server.go:90
↓ 8 callers
Method
Start
Start starts all [Worker] registered in the [WorkerPool].
worker/pool.go:61
↓ 8 callers
Method
String
String returns a string representation of a [LogOutputWriter]. nolint:exhaustive
log/enum.go:52
↓ 7 callers
Method
AppDescription
AppDescription returns the configured application description (from config field app.description or env var APP_DESCRIPTION).
config/config.go:36
↓ 7 callers
Method
Config
Config returns the MCPSSEServer config.
fxmcpserver/server/sse/server.go:45
↓ 7 callers
Method
Executions
Executions returns the [WorkerPool] list of [WorkerExecution].
worker/pool.go:115
↓ 7 callers
Method
Find
Find returns a [FxModuleInfo] by name.
fxcore/info.go:182
↓ 7 callers
Method
Level
Level returns the log level.
httpserver/logger.go:62
↓ 7 callers
Method
Name
()
healthcheck/testdata/probes/success.go:15
↓ 7 callers
Method
Name
()
fxsql/seeder.go:12
↓ 7 callers
Method
Prefix
()
fxhttpserver/resolve.go:81
↓ 7 callers
Method
Run
(ctx context.Context, db *sql.DB)
fxsql/seeder.go:13
↓ 7 callers
Function
Sanitize
Sanitize transforms a given string to not contain spaces or dashes, and to be in lower case.
fxcron/util.go:17
↓ 7 callers
Method
logJSON
(event *zerolog.Event, j echologger.JSON)
httpserver/logger.go:187
↓ 6 callers
Method
Attribute
Attribute returns an attribute of the [TestLogRecord] by name.
log/logtest/record.go:81
↓ 6 callers
Method
Auxiliary
(name string)
fxsql/pool.go:26
↓ 6 callers
Method
Bidi
(ctx context.Context, opts ...grpc.CallOption)
grpcserver/testdata/proto/test_grpc.pb.go:26
↓ 6 callers
Method
Create
(mcpServer *server.MCPServer, options ...server.StreamableHTTPOption)
fxmcpserver/server/stream/factory.go:19
↓ 6 callers
Method
Create
(mcpServer *server.MCPServer, options ...server.SSEOption)
fxmcpserver/server/sse/factory.go:23
↓ 6 callers
Method
Description
()
fxgrpcserver/define.go:8
↓ 6 callers
Method
Generate
()
generate/uuidv6/generator.go:7
↓ 6 callers
Method
Generate
()
generate/uuidv7/generator.go:7
↓ 6 callers
Function
GetReturnType
GetReturnType returns a stable identifier for the return type of constructor-like target. If a target is a function, we examine its first return value
fxhttpserver/reflect.go:37
↓ 6 callers
Method
Handle
Handle handles the panic recovery.
grpcserver/panic.go:24
↓ 6 callers
Method
Id
Id returns the [WorkerExecution] id.
worker/execution.go:36
↓ 6 callers
Method
IsDevEnv
IsDevEnv returns if the application is running in dev mode.
config/config.go:61
↓ 6 callers
Method
IsProdEnv
IsProdEnv returns if the application is running in prod mode.
config/config.go:56
↓ 6 callers
Method
JobExecutions
(jobName string)
fxcron/testdata/cron/tracker/tracker.go:30
↓ 6 callers
Method
Next
(dest []driver.Value)
sql/statement_test.go:114
↓ 6 callers
Method
Options
()
fxworker/define.go:29
↓ 6 callers
Method
RoundTrip
(*http.Request)
httpclient/transport/logger_test.go:24
↓ 6 callers
Function
Sanitize
Sanitize transforms a given string to not contain spaces or dashes, and to be in lower case.
worker/util.go:6
↓ 6 callers
Method
StreamInterceptor
StreamInterceptor handles the stream requests. nolint:cyclop,dupl,gocognit,nestif
grpcserver/logger.go:169
↓ 6 callers
Method
UnaryInterceptor
UnaryInterceptor handles the unary requests. nolint:cyclop,dupl,gocognit,nestif
grpcserver/logger.go:59
↓ 6 callers
Method
Warn
Warn logs with warn level.
orm/logger.go:44
↓ 6 callers
Method
Warn
Warn produces a log with warn level.
httpserver/logger.go:113
↓ 6 callers
Method
WithOptions
WithOptions is used to pass a list of [fx.Option].
fxcore/bootstrap.go:38
↓ 6 callers
Method
after
()
orm/plugin/trace.go:94
↓ 6 callers
Method
before
(spanName string)
orm/plugin/trace.go:84
↓ 6 callers
Function
registerNamedTestDriver
(t *testing.T, name string)
sql/register_test.go:753
↓ 5 callers
Method
After
After executes SQL tracing logic after SQL operations.
sql/hook/trace/hook.go:69
↓ 5 callers
Method
Auxiliaries
()
fxsql/pool.go:34
↓ 5 callers
Method
Base
Base returns the wrapped [http.Transport].
httpclient/transport/base.go:47
↓ 5 callers
Method
Before
Before executes SQL tracing logic before SQL operations.
sql/hook/trace/hook.go:35
↓ 5 callers
Method
Config
Config returns the MCPStreamableHTTPServer config.
fxmcpserver/server/stream/server.go:44
↓ 5 callers
Method
Debugf
Debugf produces a formatted log with debug level.
httpserver/logger.go:88
↓ 5 callers
Method
DeferredStartThreshold
DeferredStartThreshold returns the [WorkerExecution] max deferred start threshold, in seconds.
worker/execution.go:114
↓ 5 callers
Method
Group
()
fxcore/task.go:25
↓ 5 callers
Method
HasRecord
(expectedAttributes map[string]interface{})
log/logtest/buffer.go:19
↓ 5 callers
Method
Info
Info returns the MCPStreamableHTTPServer information.
fxmcpserver/server/stream/server.go:97
↓ 5 callers
Function
IsConcreteMiddleware
IsConcreteMiddleware returns true if the middleware is a concrete [echo.MiddlewareFunc] implementation.
fxhttpserver/reflect.go:47
↓ 5 callers
Method
Latency
Latency returns the HookEvent latency (duration between start and end times).
sql/hook.go:109
↓ 5 callers
Method
MatchAttributes
MatchAttributes returns true if the [TestLogRecord] exactly matches provided attributes. nolint:cyclop
log/logtest/record.go:93
↓ 5 callers
Method
QueryContext
QueryContext executes a statement for a context and returns a driver.Rows.
sql/statement.go:139
↓ 5 callers
Method
Register
Register registers the [WorkerMetrics] against a [prometheus.Registry].
worker/metrics.go:46
↓ 5 callers
Method
ResolveHandlersGroups
ResolveHandlersGroups resolves a list of [ResolvedHandlersGroup] from their definitions.
fxhttpserver/registry.go:105
↓ 5 callers
Method
ResolveMiddlewares
ResolveMiddlewares resolves a list of [ResolvedMiddleware] from their definitions.
fxhttpserver/registry.go:60
↓ 5 callers
Method
Run
(ctx context.Context)
worker/worker.go:8
↓ 5 callers
Method
Running
Running returns true if the MCPStreamableHTTPServer is running.
fxmcpserver/server/stream/server.go:89
↓ 5 callers
Method
SetLevel
SetLevel sets the log level.
httpserver/logger.go:67
↓ 5 callers
Method
Stop
Stop gracefully stops all [Worker] registered in the [WorkerPool].
worker/pool.go:73
↓ 5 callers
Method
String
String returns a string representation of the [WorkerStatus]. nolint:exhaustive
worker/enum.go:17
↓ 5 callers
Function
boundedContext
boundedContext derives a child context capped at the smaller of `limit` and half of the parent's remaining deadline. The fraction leaves room for any
fxtrace/module.go:113
↓ 5 callers
Function
prepareHealthCheckServiceGrpcServerAndClient
(t *testing.T, checker *healthcheck.Checker, logger *log.Logger)
grpcserver/healthcheck_test.go:155
↓ 4 callers
Method
After
After executes SQL logging logic after SQL operations.
sql/hook/log/hook.go:35
↓ 4 callers
Method
Before
Before executes SQL logging logic before SQL operations.
sql/hook/log/hook.go:30
↓ 4 callers
Method
BootstrapApp
BootstrapApp boostrap the application, accepting optional bootstrap options.
fxcore/bootstrap.go:45
↓ 4 callers
Method
BootstrapTestApp
BootstrapTestApp boostrap the application in test mode, accepting a testing context and optional bootstrap options.
fxcore/bootstrap.go:55
↓ 4 callers
Function
ConvertNamedValuesToValues
ConvertNamedValuesToValues converts a list of driver.NamedValue into a list of driver.Value.
sql/convert.go:8
↓ 4 callers
Method
Create
Create returns a new [Config], and accepts a list of [ConfigOption]. For example: var cfg, _ = config.NewDefaultConfigFactory().Create() is equival
config/factory.go:36
↓ 4 callers
Method
Errors
()
fxmetrics/testdata/spy/spy.go:22
↓ 4 callers
Method
Failures
()
fxmetrics/testdata/spy/spy.go:18
↓ 4 callers
Method
Fn
()
fxvalidator/define.go:37
↓ 4 callers
Function
FuncName
FuncName returns a readable func name for code browsing purposes.
fxmcpserver/server/util.go:10
↓ 4 callers
Method
Generate
Generate returns the configured deterministic value.
generate/generatetest/uuidv6/generator.go:37
↓ 4 callers
Method
Generate
Generate returns the configured deterministic value.
generate/generatetest/uuid/generator.go:25
← previous
next →
101–200 of 2,008, ranked by callers