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
↓ 318 callers
Method
Error
Error returns the HookEvent error.
sql/hook.go:69
↓ 206 callers
Method
String
String returns a string representation of a [MiddlewareKind].
fxhttpserver/enum.go:13
↓ 150 callers
Method
Create
(options ...HttpServerOption)
httpserver/factory.go:9
↓ 147 callers
Method
Add
(name string, driver *Driver)
sql/registry.go:12
↓ 128 callers
Method
String
String returns a string representation of the [ProbeKind]. nolint:exhaustive
healthcheck/enum.go:15
↓ 118 callers
Method
WithContext
WithContext is used to pass a parent [context.Context].
fxcore/bootstrap.go:31
↓ 103 callers
Method
Run
(ctx context.Context, input []byte)
fxcore/task.go:21
↓ 89 callers
Method
Errorf
(format string, args ...interface{})
fxorm/module_test.go:29
↓ 89 callers
Method
Get
(name string)
sql/registry.go:13
↓ 89 callers
Method
String
String returns a string representation of the System.
sql/system.go:16
↓ 72 callers
Method
String
()
grpcserver/testdata/proto/test.pb.go:42
↓ 66 callers
Method
Provide
()
fxmcpserver/server/provider.go:25
↓ 59 callers
Method
Close
Close closes the Statement.
sql/statement.go:41
↓ 56 callers
Method
String
String returns a string representation of the [Sampler]. nolint:exhaustive
trace/enum.go:60
↓ 55 callers
Method
Info
Info returns the MCPSSEServer information.
fxmcpserver/server/sse/server.go:98
↓ 50 callers
Method
Start
Start records the HookEvent start time.
sql/hook.go:95
↓ 44 callers
Method
Error
Error produces a log with error level.
httpserver/logger.go:128
↓ 44 callers
Method
Handle
()
worker/middleware.go:8
↓ 40 callers
Method
Start
Start starts the MCPSSEServer.
fxmcpserver/server/sse/server.go:50
↓ 39 callers
Method
HttpServer
HttpServer returns the core http server.
fxcore/core.go:36
↓ 36 callers
Method
Options
()
fxcron/define.go:11
↓ 35 callers
Method
Errorf
Errorf produces a formatted log with error level.
httpserver/logger.go:133
↓ 32 callers
Method
Create
(options ...OrmOption)
orm/factory.go:15
↓ 32 callers
Method
Debug
Debug produces a log with debug level.
httpserver/logger.go:83
↓ 32 callers
Method
System
System returns the HookEvent System.
sql/hook.go:39
↓ 30 callers
Method
Create
(options ...gocron.SchedulerOption)
fxcron/factory.go:9
↓ 30 callers
Method
DB
()
fxsql/database.go:23
↓ 29 callers
Method
Sleep
(d time.Duration)
fxclock/testdata/service/service.go:21
↓ 29 callers
Method
Stop
Stop records the HookEvent stop time.
sql/hook.go:102
↓ 28 callers
Method
Close
()
fxmcpserver/fxmcpservertest/sse.go:44
↓ 28 callers
Method
Now
()
fxclock/testdata/service/service.go:17
↓ 27 callers
Method
Info
Info logs with info level.
orm/logger.go:51
↓ 27 callers
Method
String
()
fxgrpcserver/testdata/proto/test.pb.go:42
↓ 25 callers
Method
Info
Info produces a log with info level.
httpserver/logger.go:98
↓ 25 callers
Function
createTestConfig
()
config/config_test.go:227
↓ 24 callers
Method
RunTestApp
RunTestApp runs the application in test mode, accepting a testing context and optional runtime options.
fxcore/bootstrap.go:75
↓ 23 callers
Method
Create
(options ...GrpcServerOption)
grpcserver/factory.go:10
↓ 22 callers
Method
Handler
()
fxhttpserver/resolve.go:38
↓ 22 callers
Method
IsTestEnv
IsTestEnv returns if the application is running in test mode.
config/config.go:66
↓ 22 callers
Method
Open
Open returns a new Connection.
sql/driver.go:37
↓ 21 callers
Method
Worker
Worker returns the [Worker] of the [WorkerRegistration].
worker/worker.go:26
↓ 20 callers
Method
HasEvent
HasEvent returns true if a [WorkerExecutionEvent] was found for a given message.
worker/execution.go:150
↓ 20 callers
Method
Name
()
fxmcpserver/server/registry.go:11
↓ 20 callers
Method
Operation
Operation returns the HookEvent Operation.
sql/hook.go:44
↓ 20 callers
Method
Query
Query returns the HookEvent query.
sql/hook.go:49
↓ 20 callers
Method
SetError
SetError sets the HookEvent error.
sql/hook.go:88
↓ 19 callers
Method
AppName
()
fxgrpcserver/testdata/service/dependency.go:17
↓ 19 callers
Method
Create
(options ...server.ServerOption)
fxmcpserver/server/factory.go:17
↓ 19 callers
Method
Kind
()
fxhttpserver/resolve.go:8
↓ 19 callers
Method
Register
(name string, fn func(*gorm.DB))
orm/plugin/trace.go:23
↓ 19 callers
Method
Value
()
fxcore/info.go:17
↓ 18 callers
Method
AppDebug
AppDebug returns if the application debug mode is enabled (from config field app.debug or env var APP_DEBUG).
config/config.go:51
↓ 18 callers
Method
Check
Check executes all the registered probes for a [ProbeKind], passes a [context.Context] to each of them, and returns a [CheckerResult]. The [CheckerRes
healthcheck/checker.go:98
↓ 17 callers
Function
NewHookEvent
NewHookEvent returns a new HookEvent.
sql/hook.go:29
↓ 16 callers
Method
AppEnv
AppEnv returns the configured application environment (from config field app.env or env var APP_ENV).
config/config.go:41
↓ 16 callers
Method
Check
(ctx context.Context)
healthcheck/probe.go:10
↓ 16 callers
Method
Name
()
worker/worker.go:7
↓ 16 callers
Method
Path
()
fxhttpserver/resolve.go:37
↓ 15 callers
Method
Generate
()
generate/uuid/generator.go:7
↓ 15 callers
Method
Middleware
()
fxhttpserver/resolve.go:7
↓ 15 callers
Method
Probes
Probes returns the list of [CheckerProbe] registered for the provided list of [ProbeKind]. If no [ProbeKind] is provided, probes matching all kinds wi
healthcheck/checker.go:64
↓ 14 callers
Method
AppName
AppName returns the configured application name (from config field app.name or env var APP_NAME).
config/config.go:31
↓ 14 callers
Method
ContainSpan
ContainSpan return true if a trace span from the in memory internal buffer is partially matching provided name and attributes. nolint:cyclop,gocognit
trace/tracetest/exporter.go:101
↓ 14 callers
Method
HasSpan
(expectedName string, expectedAttributes ...attribute.KeyValue)
trace/tracetest/exporter.go:19
↓ 14 callers
Method
Options
()
fxmcpserver/server/registry.go:12
↓ 14 callers
Method
RowsAffected
RowsAffected returns the HookEvent database affected rows.
sql/hook.go:64
↓ 13 callers
Method
Arguments
Arguments returns the HookEvent query arguments.
sql/hook.go:54
↓ 13 callers
Method
Create
(options ...WorkerPoolOption)
worker/factory.go:5
↓ 13 callers
Method
ExecContext
ExecContext executes a statement for a context and returns a driver.Result.
sql/statement.go:82
↓ 13 callers
Method
Handle
()
fxmcpserver/server/registry.go:13
↓ 13 callers
Method
HasSpan
HasSpan return true if a trace span from the in memory internal buffer is exactly matching provided name and attributes.
trace/tracetest/exporter.go:65
↓ 13 callers
Method
LastInsertId
LastInsertId returns the HookEvent database last inserted id.
sql/hook.go:59
↓ 13 callers
Method
Reset
Reset resets the internal buffer.
log/logtest/buffer.go:52
↓ 13 callers
Method
SetLastInsertId
SetLastInsertId sets the HookEvent database last inserted id.
sql/hook.go:74
↓ 13 callers
Method
SetRowsAffected
SetRowsAffected sets the HookEvent database affected rows.
sql/hook.go:81
↓ 13 callers
Method
String
String returns a string representation of the [Driver].
orm/enum.go:21
↓ 12 callers
Method
AppVersion
AppVersion returns the configured application version (from config field app.version or env var APP_VERSION).
config/config.go:46
↓ 12 callers
Method
Create
(system System, hooks ...Hook)
sql/factory.go:13
↓ 12 callers
Method
Method
()
fxhttpserver/resolve.go:36
↓ 12 callers
Method
Name
()
fxcore/task.go:20
↓ 12 callers
Method
Primary
()
fxsql/pool.go:22
↓ 12 callers
Method
Stop
Stop stops the MCPSSEServer.
fxmcpserver/server/sse/server.go:72
↓ 12 callers
Method
Unary
(ctx context.Context, in *Request, opts ...grpc.CallOption)
grpcserver/testdata/proto/test_grpc.pb.go:25
↓ 11 callers
Method
AddEvent
AddEvent adds a [WorkerExecutionEvent] to the [WorkerExecution].
worker/execution.go:140
↓ 11 callers
Method
ContainRecord
ContainRecord return true if a log record from the internal buffer is partially matching provided attributes.
log/logtest/buffer.go:108
↓ 11 callers
Method
Events
Events returns the [WorkerExecution] list of [WorkerExecutionEvent].
worker/execution.go:132
↓ 11 callers
Method
HasRecord
HasRecord return true if a log record from the internal buffer is exactly matching provided attributes.
log/logtest/buffer.go:92
↓ 11 callers
Method
Implementation
Implementation returns the [ResolvedCronJob] cron job implementation.
fxcron/resolve.go:22
↓ 11 callers
Method
SetStatus
SetStatus sets the [WorkerExecution] status.
worker/execution.go:68
↓ 11 callers
Method
Status
Status returns the [WorkerExecution] status.
worker/execution.go:60
↓ 11 callers
Method
applyAfterHooks
(ctx context.Context, event *HookEvent)
sql/connection.go:315
↓ 11 callers
Method
applyBeforeHooks
(ctx context.Context, event *HookEvent)
sql/connection.go:307
↓ 11 callers
Function
createTestContext
(logger *yokailog.Logger, tracerProvider *otelsdktrace.TracerProvider)
sql/register_test.go:804
↓ 10 callers
Method
Before
(context.Context, *HookEvent)
sql/hook.go:11
↓ 10 callers
Method
Create
(options ...TracerProviderOption)
trace/factory.go:13
↓ 10 callers
Method
CurrentExecutionAttempt
CurrentExecutionAttempt returns the [WorkerExecution] current execution attempt.
worker/execution.go:78
↓ 10 callers
Method
Error
Error logs with error level.
orm/logger.go:37
↓ 10 callers
Method
Middlewares
()
fxhttpserver/resolve.go:39
↓ 10 callers
Method
Reset
()
log/logtest/buffer.go:17
↓ 10 callers
Method
Shutdown
Shutdown is just for [otelsdktrace.SpanProcessor] compliance.
fxcron/trace.go:44
next →
1–100 of 2,008, ranked by callers