Documentation
¶
Index ¶
- func Default(options ...Option) kernel.Kernel
- func New(options ...Option) kernel.Kernel
- func NewMetadataServer() kernel.ModuleFactory
- func NewWithInterfaces(ctx context.Context, config cfg.GosoConf, logger log.GosoLogger, ...) (kernel.Kernel, error)
- func Run(options ...Option)
- func RunConsumer(callback stream.ConsumerCallbackFactory, options ...Option)
- func RunConsumers(consumers stream.ConsumerCallbackMap, options ...Option)
- func RunFunc(...)
- func RunHttpDefaultServer(definer httpserver.Definer, options ...Option)
- func RunHttpServers(servers map[string]httpserver.Definer, options ...Option)
- func RunMdlSubscriber(transformers mdlsub.TransformerMapTypeVersionFactories, options ...Option)
- func RunModule(name string, moduleFactory kernel.ModuleFactory, options ...Option)
- func WithConfigFileFlag(app *App)
- func WithConsumerMessagesPerRunnerMetrics(app *App)
- func WithDbRepoChangeHistory(app *App)
- func WithExecBackoffInfinite(app *App)
- func WithHttpHealthCheck(app *App)
- func WithHttpServerShares(app *App)
- func WithLoggerApplicationTag(app *App)
- func WithLoggerContextFieldsMessageEncoder(app *App)
- func WithLoggerGroupTag(app *App)
- func WithLoggerHandlersFromConfig(app *App)
- func WithLoggerMetricHandler(app *App)
- func WithMetadataServer(app *App)
- func WithMetrics(app *App)
- func WithProducerDaemon(app *App)
- func WithTracing(app *App)
- type App
- type ConfigOption
- type ErrorHandler
- type KernelOption
- type LoggerOption
- type MetadataServer
- type MetadataServerSettings
- type Option
- func WithConfigEnvKeyPrefix(prefix string) Option
- func WithConfigEnvKeyReplacer(replacer *strings.Replacer) Option
- func WithConfigErrorHandlers(handlers ...cfg.ErrorHandler) Option
- func WithConfigFile(filePath string, fileType string) Option
- func WithConfigMap(configMap map[string]interface{}, mergeOptions ...cfg.MergeOption) Option
- func WithConfigPostProcessor(processor cfg.PostProcessor) Option
- func WithConfigSanitizers(sanitizers ...cfg.Sanitizer) Option
- func WithConfigSetting(key string, settings interface{}) Option
- func WithExecBackoffSettings(settings *exec.BackoffSettings) Option
- func WithFixtureBuilderFactory(factory fixtures.FixtureBuilderFactory) Option
- func WithKernelExitHandler(handler kernelPkg.ExitHandler) Option
- func WithLoggerContextFieldsResolver(resolver ...log.ContextFieldsResolverFunction) Option
- func WithLoggerHandlers(handler ...log.Handler) Option
- func WithLoggerSentryHandler(contextProvider ...log.SentryContextProvider) Option
- func WithMiddlewareFactory(factory kernelPkg.MiddlewareFactory, position kernelPkg.Position) Option
- func WithModuleFactory(name string, moduleFactory kernelPkg.ModuleFactory, ...) Option
- func WithModuleMultiFactory(factory kernelPkg.ModuleMultiFactory) Option
- func WithProfiling() Option
- func WithUTCClock(useUTC bool) Option
- type SetupOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMetadataServer ¶
func NewMetadataServer() kernel.ModuleFactory
func NewWithInterfaces ¶
func RunConsumer ¶
func RunConsumer(callback stream.ConsumerCallbackFactory, options ...Option)
func RunConsumers ¶
func RunConsumers(consumers stream.ConsumerCallbackMap, options ...Option)
func RunHttpDefaultServer ¶ added in v0.15.0
func RunHttpDefaultServer(definer httpserver.Definer, options ...Option)
func RunHttpServers ¶ added in v0.15.0
func RunHttpServers(servers map[string]httpserver.Definer, options ...Option)
func RunMdlSubscriber ¶
func RunMdlSubscriber(transformers mdlsub.TransformerMapTypeVersionFactories, options ...Option)
func WithConfigFileFlag ¶
func WithConfigFileFlag(app *App)
func WithConsumerMessagesPerRunnerMetrics ¶
func WithConsumerMessagesPerRunnerMetrics(app *App)
func WithDbRepoChangeHistory ¶
func WithDbRepoChangeHistory(app *App)
func WithExecBackoffInfinite ¶
func WithExecBackoffInfinite(app *App)
func WithHttpHealthCheck ¶ added in v0.15.0
func WithHttpHealthCheck(app *App)
func WithHttpServerShares ¶ added in v0.15.0
func WithHttpServerShares(app *App)
func WithLoggerApplicationTag ¶
func WithLoggerApplicationTag(app *App)
func WithLoggerContextFieldsMessageEncoder ¶
func WithLoggerContextFieldsMessageEncoder(app *App)
func WithLoggerGroupTag ¶
func WithLoggerGroupTag(app *App)
func WithLoggerHandlersFromConfig ¶
func WithLoggerHandlersFromConfig(app *App)
func WithLoggerMetricHandler ¶
func WithLoggerMetricHandler(app *App)
func WithMetadataServer ¶
func WithMetadataServer(app *App)
func WithMetrics ¶
func WithMetrics(app *App)
func WithProducerDaemon ¶
func WithProducerDaemon(app *App)
func WithTracing ¶
func WithTracing(app *App)
Types ¶
type ConfigOption ¶
type ErrorHandler ¶
type ErrorHandler func(msg string, args ...interface{})
type LoggerOption ¶
type LoggerOption func(config cfg.GosoConf, logger log.GosoLogger) error
type MetadataServer ¶
type MetadataServer struct { kernel.BackgroundModule kernel.ServiceStage // contains filtered or unexported fields }
type MetadataServerSettings ¶
type MetadataServerSettings struct {
Port int `cfg:"port" default:"8070"`
}
type Option ¶
type Option func(app *App)
func WithConfigEnvKeyPrefix ¶
func WithConfigErrorHandlers ¶
func WithConfigErrorHandlers(handlers ...cfg.ErrorHandler) Option
func WithConfigFile ¶
func WithConfigMap ¶
func WithConfigMap(configMap map[string]interface{}, mergeOptions ...cfg.MergeOption) Option
func WithConfigPostProcessor ¶
func WithConfigPostProcessor(processor cfg.PostProcessor) Option
func WithConfigSanitizers ¶
func WithConfigSetting ¶
func WithExecBackoffSettings ¶
func WithExecBackoffSettings(settings *exec.BackoffSettings) Option
func WithFixtureBuilderFactory ¶
func WithFixtureBuilderFactory(factory fixtures.FixtureBuilderFactory) Option
func WithKernelExitHandler ¶
func WithKernelExitHandler(handler kernelPkg.ExitHandler) Option
func WithLoggerContextFieldsResolver ¶
func WithLoggerContextFieldsResolver(resolver ...log.ContextFieldsResolverFunction) Option
func WithLoggerHandlers ¶
func WithLoggerSentryHandler ¶
func WithLoggerSentryHandler(contextProvider ...log.SentryContextProvider) Option
func WithMiddlewareFactory ¶
func WithMiddlewareFactory(factory kernelPkg.MiddlewareFactory, position kernelPkg.Position) Option
func WithModuleFactory ¶
func WithModuleFactory(name string, moduleFactory kernelPkg.ModuleFactory, opts ...kernelPkg.ModuleOption) Option
func WithModuleMultiFactory ¶
func WithModuleMultiFactory(factory kernelPkg.ModuleMultiFactory) Option
func WithProfiling ¶
func WithProfiling() Option
func WithUTCClock ¶
type SetupOption ¶
type SetupOption func(config cfg.GosoConf, logger log.GosoLogger) error
Click to show internal directories.
Click to hide internal directories.