application

Documentation

Index

• func Default(options ...Option) kernel.Kernel
• func New(options ...Option) kernel.Kernel
• func NewMetadataServer(_ context.Context, config cfg.Config, logger log.Logger) (kernel.Module, error)
• 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 WithProfiling(app *App)
• func WithTaskRunner(app *App)
• func WithTracing(app *App)
• type App
• type ConfigOption
• type ErrorHandler
• type KernelOption
• type LoggerOption
• type MetadataServer
  • func (s *MetadataServer) Run(ctx context.Context) error
• 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 WithUTCClock(useUTC bool) Option
• type SetupOption

Functions

func Default

func Default(options ...Option) kernel.Kernel

func New

func New(options ...Option) kernel.Kernel

func NewMetadataServer

func NewMetadataServer(_ context.Context, config cfg.Config, logger log.Logger) (kernel.Module, error)

func NewWithInterfaces

func NewWithInterfaces(ctx context.Context, config cfg.GosoConf, logger log.GosoLogger, options ...Option) (kernel.Kernel, error)

func Run

func Run(options ...Option)

func RunConsumer

func RunConsumer(callback stream.ConsumerCallbackFactory, options ...Option)

func RunConsumers

func RunConsumers(consumers stream.ConsumerCallbackMap, options ...Option)

func RunFunc

func RunFunc(f func(ctx context.Context, config cfg.Config, logger log.Logger) (kernel.ModuleRunFunc, error), options ...Option)

func RunHttpDefaultServer

func RunHttpDefaultServer(definer httpserver.Definer, options ...Option)

func RunHttpServers

func RunHttpServers(servers map[string]httpserver.Definer, options ...Option)

func RunMdlSubscriber

func RunMdlSubscriber(transformers mdlsub.TransformerMapTypeVersionFactories, options ...Option)

func RunModule

func RunModule(name string, moduleFactory kernel.ModuleFactory, 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

func WithHttpHealthCheck(app *App)

func WithHttpServerShares

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 WithProfiling

func WithProfiling(app *App)

func WithTaskRunner

func WithTaskRunner(app *App)

func WithTracing

func WithTracing(app *App)

Types

type App

type App struct {
	// contains filtered or unexported fields
}

type ConfigOption

type ConfigOption func(config cfg.GosoConf) error

type ErrorHandler

type ErrorHandler func(msg string, args ...interface{})

type KernelOption

type KernelOption func(config cfg.GosoConf) kernelPkg.Option

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
}

func (*MetadataServer) Run

func (s *MetadataServer) Run(ctx context.Context) error

type MetadataServerSettings

type MetadataServerSettings struct {
	Port int `cfg:"port" default:"8070"`
}

type Option

type Option func(app *App)

func WithConfigEnvKeyPrefix

func WithConfigEnvKeyPrefix(prefix string) Option

func WithConfigEnvKeyReplacer

func WithConfigEnvKeyReplacer(replacer *strings.Replacer) Option

func WithConfigErrorHandlers

func WithConfigErrorHandlers(handlers ...cfg.ErrorHandler) Option

func WithConfigFile

func WithConfigFile(filePath string, fileType string) Option

func WithConfigMap

func WithConfigMap(configMap map[string]interface{}, mergeOptions ...cfg.MergeOption) Option

func WithConfigPostProcessor

func WithConfigPostProcessor(processor cfg.PostProcessor) Option

func WithConfigSanitizers

func WithConfigSanitizers(sanitizers ...cfg.Sanitizer) Option

func WithConfigSetting

func WithConfigSetting(key string, settings interface{}) Option

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 WithLoggerHandlers(handler ...log.Handler) Option

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 WithUTCClock

func WithUTCClock(useUTC bool) Option

type SetupOption

type SetupOption func(config cfg.GosoConf, logger log.GosoLogger) error