slate

package module

Go to main page

Versions in this module

v0

v0.30.2

Nov 15, 2023

v0.30.1

Oct 31, 2023

v0.30.0

Oct 29, 2023

Changes in this version

+ const ConfigAggregateSourceCreatorContainerID

+ const ConfigAggregateSupplierTag

+ const ConfigAllAggregateSuppliersContainerID

+ const ConfigAllParserCreatorsContainerID

+ const ConfigAllSupplierCreatorsContainerID

+ const ConfigContainerID

+ const ConfigDirSourceCreatorContainerID

+ const ConfigEnvID

+ const ConfigEnvSourceCreatorContainerID

+ const ConfigFileSourceCreatorContainerID

+ const ConfigFormatJSON

+ const ConfigFormatYAML

+ const ConfigJSONDecoderCreatorContainerID

+ const ConfigLoaderContainerID

+ const ConfigObsFileSourceCreatorContainerID

+ const ConfigObsRestSourceCreatorContainerID

+ const ConfigParserContainerID

+ const ConfigParserCreatorTag

+ const ConfigParserFactoryContainerID

+ const ConfigRestSourceCreatorContainerID

+ const ConfigSupplierContainerID

+ const ConfigSupplierCreatorTag

+ const ConfigSupplierFactoryContainerID

+ const ConfigTypeAggregate

+ const ConfigTypeDir

+ const ConfigTypeEnv

+ const ConfigTypeFile

+ const ConfigTypeObsFile

+ const ConfigTypeObsRest

+ const ConfigTypeRest

+ const ConfigYAMLDecoderCreatorContainerID

+ const FileSystemContainerID

+ const LogAllFormatterCreatorsContainerID

+ const LogAllWriterCreatorsContainerID

+ const LogConsoleStreamCreatorContainerID

+ const LogContainerID

+ const LogEnvID

+ const LogFileStreamCreatorContainerID

+ const LogFormatJSON

+ const LogFormatterContainerID

+ const LogFormatterCreatorTag

+ const LogFormatterFactoryContainerID

+ const LogJSONEncoderCreatorContainerID

+ const LogLoaderContainerID

+ const LogRotatingFileStreamCreatorContainerID

+ const LogTypeConsole

+ const LogTypeFile

+ const LogTypeRotatingFile

+ const LogWriterContainerID

+ const LogWriterCreatorTag

+ const LogWriterFactoryContainerID

+ const MigratorAllMigrationsContainerID

+ const MigratorContainerID

+ const MigratorDAOContainerID

+ const MigratorEnvID

+ const MigratorMigrationTag

+ const RdbAllDialectCreatorsContainerID

+ const RdbConfigContainerID

+ const RdbConnectionContainerID

+ const RdbConnectionFactoryContainerID

+ const RdbContainerID

+ const RdbDialectContainerID

+ const RdbDialectCreatorTag

+ const RdbDialectFactoryContainerID

+ const RdbEnvID

+ const RdbPrimaryConnectionContainerID

+ const WatchdogAllLogFormatterCreatorsContainerID

+ const WatchdogAllProcessesContainerID

+ const WatchdogContainerID

+ const WatchdogDefaultLogFormatterCreatorContainerID

+ const WatchdogEnvID

+ const WatchdogFactoryContainerID

+ const WatchdogLogFormatterContainerID

+ const WatchdogLogFormatterCreatorTag

+ const WatchdogLogFormatterFactoryContainerID

+ const WatchdogLogFormatterTypeDefault

+ const WatchdogProcessTag

+ var ConfigDefaultFileFormat = EnvString(ConfigEnvID + "_DEFAULT_FILE_FORMAT", "yaml")

+ var ConfigDefaultRestFormat = EnvString(ConfigEnvID + "_DEFAULT_REST_FORMAT", "json")

+ var ConfigLoaderActive = EnvBool(ConfigEnvID + "_LOADER_ACTIVE", true)

+ var ConfigLoaderFileSupplierPath = EnvString(ConfigEnvID + "_LOADER_FILE_SUPPLIER_PATH", "config/suppliers.yaml")

+ var ConfigLoaderSupplierFormat = EnvString(ConfigEnvID + "_LOADER_SUPPLIER_FORMAT", "yaml")

+ var ConfigLoaderSupplierID = EnvString(ConfigEnvID + "_LOADER_SUPPLIER_ID", "_suppliers")

+ var ConfigLoaderSupplierListPath = EnvString(ConfigEnvID + "_LOADER_SUPPLIER_LIST_PATH", "slate.config.suppliers")

+ var ConfigObserveFrequency = EnvInt(ConfigEnvID + "_OBSERVE_FREQUENCY", 0)

+ var ConfigPathSeparator = EnvString(ConfigEnvID + "_PATH_SEPARATOR", ".")

+ var ErrConfigPathNotFound = fmt.Errorf("config path not found")

+ var ErrConfigSupplierNotFound = fmt.Errorf("config supplier not found")

+ var ErrDuplicateConfigSupplier = fmt.Errorf("config supplier already registered")

+ var ErrDuplicateLogWriter = fmt.Errorf("log writer already registered")

+ var ErrDuplicateWatchdog = fmt.Errorf("duplicate watchdog")

+ var ErrInvalidConfigFormat = fmt.Errorf("invalid config format")

+ var ErrInvalidConfigSupplier = fmt.Errorf("invalid config supplier")

+ var ErrInvalidEmptyConfigPath = fmt.Errorf("invalid empty config path")

+ var ErrInvalidLogConfig = fmt.Errorf("invalid log writer config")

+ var ErrInvalidLogFormat = fmt.Errorf("invalid log format")

+ var ErrInvalidLogLevel = fmt.Errorf("invalid log level")

+ var ErrInvalidWatchdogLogWriter = fmt.Errorf("invalid watchdog log writer")

+ var ErrLogWriterNotFound = fmt.Errorf("log writer not found")

+ var ErrNonFunctionServiceFactory = NewError("non-function service factory")

+ var ErrServiceContainer = NewError("service di error")

+ var ErrServiceFactoryWithoutResult = NewError("service factory without result")

+ var ErrUnknownRdbDialect = fmt.Errorf("unknown database dialect")

+ var LogFlushFrequency = EnvInt(LogEnvID + "_FLUSH_FREQUENCY", 0)

+ var LogLevelMap = map[string]LogLevel

+ var LogLevelMapName = map[LogLevel]string

+ var LogLoaderActive = EnvBool(LogEnvID + "_LOADER_ACTIVE", true)

+ var LogLoaderConfigPath = EnvString(LogEnvID + "_LOADER_CONFIG_PATH", "slate.log.writers")

+ var LogLoaderObserveConfig = EnvBool(LogEnvID + "_LOADER_OBSERVE_CONFIG", true)

+ var MigratorAutoMigrate = EnvBool(MigratorEnvID + "_AUTO_MIGRATE", true)

+ var MigratorDatabase = EnvString(MigratorEnvID + "_DATABASE", "primary")

+ var RdbConnectionsConfigPath = EnvString(RdbEnvID + "_CONNECTIONS_CONFIG_PATH", "slate.rdb.connections")

+ var RdbObserveConfig = EnvBool(RdbEnvID + "_OBSERVE_CONFIG", true)

+ var RdbPrimary = EnvString(RdbEnvID + "_PRIMARY", "primary")

+ var WatchdogConfigPathPrefix = EnvString(WatchdogEnvID + "_CONFIG_PATH", "slate.watchdog.services")

+ var WatchdogDefaultFormatter = EnvString(WatchdogEnvID + "_DEFAULT_FORMATTER", WatchdogLogFormatterTypeDefault)

+ var WatchdogLogChannel = EnvString(WatchdogEnvID + "_LOG_CHANNEL", "watchdog")

+ var WatchdogLogDoneLevel = EnvString(WatchdogEnvID + "_LOG_DONE_LEVEL", "notice")

+ var WatchdogLogDoneMessage = EnvString(WatchdogEnvID + "_LOG_DONE_MESSAGE", "[watchdog:%s] execution terminated")

+ var WatchdogLogErrorLevel = EnvString(WatchdogEnvID + "_LOG_ERROR_LEVEL", "error")

+ var WatchdogLogErrorMessage = EnvString(WatchdogEnvID + "_LOG_ERROR_MESSAGE", "[watchdog:%s] execution error (%v)")

+ var WatchdogLogStartLevel = EnvString(WatchdogEnvID + "_LOG_START_LEVEL", "notice")

+ var WatchdogLogStartMessage = EnvString(WatchdogEnvID + "_LOG_START_MESSAGE", "[watchdog:%s] start execution")

+ func ConfigConvert(val interface{}) interface

+ func EnvBool(name string, def ...bool) bool

+ func EnvInt(name string, def ...int) int

+ func EnvList(name string, def ...[]string) []string

+ func EnvString(name string, def ...string) string

+ func NewLogRotatingFileWriter(fileSystem afero.Fs, file string) (io.Writer, error)

+ type App struct

+ func NewApp() *App

+ func (a *App) Boot() error

+ func (a *App) Provide(provider ServiceProvider) error

+ type Config struct

+ func NewConfig() *Config

+ func (c *Config) AddObserver(path string, callback ConfigObserver) error

+ func (c *Config) AddSupplier(id string, priority int, supplier ConfigSupplier) error

+ func (c *Config) Bool(path string, def ...bool) (bool, error)

+ func (c *Config) Close() error

+ func (c *Config) Entries() []string

+ func (c *Config) Float(path string, def ...float64) (float64, error)

+ func (c *Config) Get(path string, def ...interface{}) (interface{}, error)

+ func (c *Config) Has(path string) bool

+ func (c *Config) HasObserver(path string) bool

+ func (c *Config) HasSupplier(id string) bool

+ func (c *Config) Int(path string, def ...int) (int, error)

+ func (c *Config) List(path string, def ...[]interface{}) ([]interface{}, error)

+ func (c *Config) Partial(path string, def ...ConfigPartial) (ConfigPartial, error)

+ func (c *Config) Populate(path string, data interface{}, insensitive ...bool) (interface{}, error)

+ func (c *Config) RemoveAllSuppliers() error

+ func (c *Config) RemoveObserver(path string)

+ func (c *Config) RemoveSupplier(id string) error

+ func (c *Config) String(path string, def ...string) (string, error)

+ func (c *Config) Supplier(id string) (ConfigSupplier, error)

+ func (c *Config) SupplierPriority(id string, priority int) error

+ type ConfigAggregateSource struct

+ func NewConfigAggregateSource(suppliers []ConfigSupplier) (*ConfigAggregateSource, error)

+ type ConfigAggregateSourceCreator struct

+ func NewConfigAggregateSourceCreator(suppliers []ConfigSupplier) (*ConfigAggregateSourceCreator, error)

+ func (s ConfigAggregateSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigAggregateSourceCreator) Create(_ *ConfigPartial) (ConfigSupplier, error)

+ type ConfigDecoder struct

+ Reader io.Reader

+ UnderlyingDecoder ConfigUnderlyingDecoder

+ func NewConfigDecoder(reader io.Reader, decoder ConfigUnderlyingDecoder) *ConfigDecoder

+ func (d *ConfigDecoder) Close() error

+ func (d *ConfigDecoder) Parse() (*ConfigPartial, error)

+ type ConfigDirSource struct

+ func NewConfigDirSource(path, format string, recursive bool, fileSystem afero.Fs, ...) (*ConfigDirSource, error)

+ type ConfigDirSourceCreator struct

+ func NewConfigDirSourceCreator(fileSystem afero.Fs, parserFactory *ConfigParserFactory) (*ConfigDirSourceCreator, error)

+ func (s ConfigDirSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigDirSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigEnvSource struct

+ func NewConfigEnvSource(mappings map[string]string) (*ConfigEnvSource, error)

+ type ConfigEnvSourceCreator struct

+ func NewConfigEnvSourceCreator() *ConfigEnvSourceCreator

+ func (s ConfigEnvSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigEnvSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigFileSource struct

+ func NewConfigFileSource(path, format string, fileSystem afero.Fs, parserFactory *ConfigParserFactory) (*ConfigFileSource, error)

+ type ConfigFileSourceCreator struct

+ func NewConfigFileSourceCreator(fileSystem afero.Fs, parserFactory *ConfigParserFactory) (*ConfigFileSourceCreator, error)

+ func (s ConfigFileSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigFileSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigJSONDecoder struct

+ func NewConfigJSONDecoder(reader io.Reader) (*ConfigJSONDecoder, error)

+ type ConfigJSONDecoderCreator struct

+ func NewConfigJSONDecoderCreator() *ConfigJSONDecoderCreator

+ func (ConfigJSONDecoderCreator) Accept(format string) bool

+ func (ConfigJSONDecoderCreator) Create(args ...interface{}) (ConfigParser, error)

+ type ConfigLoader struct

+ func NewConfigLoader(config *Config, supplierFactory *ConfigSupplierFactory) (*ConfigLoader, error)

+ func (l ConfigLoader) Load() error

+ type ConfigObsFileSource struct

+ func NewConfigObsFileSource(path, format string, fileSystem afero.Fs, parserFactory *ConfigParserFactory) (*ConfigObsFileSource, error)

+ func (s *ConfigObsFileSource) Reload() (bool, error)

+ type ConfigObsFileSourceCreator struct

+ func NewConfigObsFileSourceCreator(fileSystem afero.Fs, parserFactory *ConfigParserFactory) (*ConfigObsFileSourceCreator, error)

+ func (s ConfigObsFileSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigObsFileSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigObsRestSource struct

+ func NewConfigObsRestSource(client configRestRequester, uri, format string, ...) (*ConfigObsRestSource, error)

+ func (s *ConfigObsRestSource) Reload() (bool, error)

+ type ConfigObsRestSourceCreator struct

+ func NewConfigObsRestSourceCreator(parserFactory *ConfigParserFactory) (*ConfigObsRestSourceCreator, error)

+ func (s ConfigObsRestSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigObsRestSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigObsSupplier interface

+ Reload func() (bool, error)

+ type ConfigObserver func(old, new interface{})

+ type ConfigParser interface

+ Parse func() (*ConfigPartial, error)

+ type ConfigParserCreator interface

+ Accept func(format string) bool

+ Create func(args ...interface{}) (ConfigParser, error)

+ type ConfigParserFactory []ConfigParserCreator

+ func NewConfigParserFactory(creators []ConfigParserCreator) *ConfigParserFactory

+ func (f *ConfigParserFactory) Create(format string, args ...interface{}) (ConfigParser, error)

+ type ConfigPartial map[interface{}]interface

+ func (p *ConfigPartial) Bool(path string, def ...bool) (bool, error)

+ func (p *ConfigPartial) Clone() ConfigPartial

+ func (p *ConfigPartial) Entries() []string

+ func (p *ConfigPartial) Float(path string, def ...float64) (float64, error)

+ func (p *ConfigPartial) Get(path string, def ...interface{}) (interface{}, error)

+ func (p *ConfigPartial) Has(path string) bool

+ func (p *ConfigPartial) Int(path string, def ...int) (int, error)

+ func (p *ConfigPartial) List(path string, def ...[]interface{}) ([]interface{}, error)

+ func (p *ConfigPartial) Merge(src ConfigPartial)

+ func (p *ConfigPartial) Partial(path string, def ...ConfigPartial) (ConfigPartial, error)

+ func (p *ConfigPartial) Populate(path string, data interface{}, insensitive ...bool) (interface{}, error)

+ func (p *ConfigPartial) Set(path string, value interface{}) (*ConfigPartial, error)

+ func (p *ConfigPartial) String(path string, def ...string) (string, error)

+ type ConfigRestSource struct

+ func NewConfigRestSource(client configRestRequester, uri, format string, ...) (*ConfigRestSource, error)

+ type ConfigRestSourceCreator struct

+ func NewConfigRestSourceCreator(parserFactory *ConfigParserFactory) (*ConfigRestSourceCreator, error)

+ func (s ConfigRestSourceCreator) Accept(config *ConfigPartial) bool

+ func (s ConfigRestSourceCreator) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigServiceRegister struct

+ func NewConfigServiceRegister(app ...*App) *ConfigServiceRegister

+ func (sr ConfigServiceRegister) Boot(container *ServiceContainer) (e error)

+ func (sr ConfigServiceRegister) Provide(container *ServiceContainer) error

+ type ConfigSource struct

+ Mutex sync.Locker

+ Partial ConfigPartial

+ func NewConfigSource() *ConfigSource

+ func (s *ConfigSource) Get(path string, def ...interface{}) (interface{}, error)

+ func (s *ConfigSource) Has(path string) bool

+ type ConfigSupplier interface

+ Get func(path string, def ...interface{}) (interface{}, error)

+ Has func(path string) bool

+ type ConfigSupplierCreator interface

+ Accept func(config *ConfigPartial) bool

+ Create func(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigSupplierFactory []ConfigSupplierCreator

+ func NewConfigSupplierFactory(creators []ConfigSupplierCreator) *ConfigSupplierFactory

+ func (f *ConfigSupplierFactory) Create(config *ConfigPartial) (ConfigSupplier, error)

+ type ConfigUnderlyingDecoder interface

+ Decode func(config interface{}) error

+ type ConfigYAMLDecoder struct

+ func NewConfigYAMLDecoder(reader io.Reader) (*ConfigYAMLDecoder, error)

+ func (d ConfigYAMLDecoder) Parse() (*ConfigPartial, error)

+ type ConfigYAMLDecoderCreator struct

+ func NewConfigYAMLDecoderCreator() *ConfigYAMLDecoderCreator

+ func (ConfigYAMLDecoderCreator) Accept(format string) bool

+ func (ConfigYAMLDecoderCreator) Create(args ...interface{}) (ConfigParser, error)

+ type FileSystemServiceRegister struct

+ func NewFileSystemServiceRegister(app ...*App) *FileSystemServiceRegister

+ func (FileSystemServiceRegister) Provide(container *ServiceContainer) error

+ type Log struct

+ func NewLog() *Log

+ func (l *Log) AddWriter(id string, writer LogWriter) error

+ func (l *Log) Broadcast(level LogLevel, msg string, ctx ...LogContext) error

+ func (l *Log) Close() error

+ func (l *Log) Flush() error

+ func (l *Log) HasWriter(id string) bool

+ func (l *Log) ListWriters() []string

+ func (l *Log) RemoveAllWriters()

+ func (l *Log) RemoveWriter(id string)

+ func (l *Log) Signal(channel string, level LogLevel, msg string, ctx ...LogContext) error

+ func (l *Log) Writer(id string) (LogWriter, error)

+ type LogConsoleStream struct

+ func NewLogConsoleStream(level LogLevel, formatter LogFormatter, channels []string) (*LogConsoleStream, error)

+ type LogConsoleStreamCreator struct

+ func NewLogConsoleStreamCreator(formatterFactory *LogFormatterFactory) (*LogConsoleStreamCreator, error)

+ func (s LogConsoleStreamCreator) Accept(config *ConfigPartial) bool

+ func (s LogConsoleStreamCreator) Create(config *ConfigPartial) (LogWriter, error)

+ type LogContext map[string]interface

+ type LogFileStream struct

+ func NewLogFileStream(level LogLevel, formatter LogFormatter, channels []string, writer io.Writer) (*LogFileStream, error)

+ func (s *LogFileStream) Close() error

+ type LogFileStreamCreator struct

+ func NewLogFileStreamCreator(fileSystem afero.Fs, formatterFactory *LogFormatterFactory) (*LogFileStreamCreator, error)

+ func (s LogFileStreamCreator) Accept(config *ConfigPartial) bool

+ func (s LogFileStreamCreator) Create(config *ConfigPartial) (LogWriter, error)

+ type LogFormatter interface

+ Format func(level LogLevel, message string, ctx ...LogContext) string

+ type LogFormatterCreator interface

+ Accept func(format string) bool

+ Create func(args ...interface{}) (LogFormatter, error)

+ type LogFormatterFactory []LogFormatterCreator

+ func NewLogFormatterFactory(creators []LogFormatterCreator) *LogFormatterFactory

+ func (f *LogFormatterFactory) Create(format string, args ...interface{}) (LogFormatter, error)

+ type LogJSONEncoder struct

+ func NewLogJSONEncoder() *LogJSONEncoder

+ func (f LogJSONEncoder) Format(level LogLevel, message string, ctx ...LogContext) string

+ type LogJSONEncoderCreator struct

+ func NewLogJSONEncoderCreator() *LogJSONEncoderCreator

+ func (LogJSONEncoderCreator) Accept(format string) bool

+ func (LogJSONEncoderCreator) Create(_ ...interface{}) (LogFormatter, error)

+ type LogLevel int

+ const DEBUG

+ const ERROR

+ const FATAL

+ const INFO

+ const NOTICE

+ const WARNING

+ type LogLoader struct

+ func NewLogLoader(config *Config, log *Log, writerFactory *LogWriterFactory) (*LogLoader, error)

+ func (l LogLoader) Load() error

+ type LogRotatingFileStreamCreator struct

+ func NewLogRotatingFileStreamCreator(fileSystem afero.Fs, formatterFactory *LogFormatterFactory) (*LogRotatingFileStreamCreator, error)

+ func (s LogRotatingFileStreamCreator) Accept(config *ConfigPartial) bool

+ func (s LogRotatingFileStreamCreator) Create(config *ConfigPartial) (LogWriter, error)

+ type LogRotatingFileWriter struct

+ func (w *LogRotatingFileWriter) Close() error

+ func (w *LogRotatingFileWriter) Write(output []byte) (int, error)

+ type LogServiceRegister struct

+ func NewLogServiceRegister(app ...*App) *LogServiceRegister

+ func (sr LogServiceRegister) Boot(container *ServiceContainer) (e error)

+ func (sr LogServiceRegister) Provide(container *ServiceContainer) error

+ type LogStream struct

+ Buffer []string

+ Channels []string

+ Formatter LogFormatter

+ Level LogLevel

+ Mutex sync.Locker

+ Writer io.Writer

+ func NewLogStream(level LogLevel, formatter LogFormatter, channels []string, writer io.Writer) *LogStream

+ func (s *LogStream) AddChannel(channel string)

+ func (s *LogStream) Broadcast(level LogLevel, msg string, ctx ...LogContext) error

+ func (s *LogStream) Close() error

+ func (s *LogStream) Flush() error

+ func (s *LogStream) Format(level LogLevel, message string, ctx ...LogContext) string

+ func (s *LogStream) HasChannel(channel string) bool

+ func (s *LogStream) ListChannels() []string

+ func (s *LogStream) RemoveChannel(channel string)

+ func (s *LogStream) Signal(channel string, level LogLevel, msg string, ctx ...LogContext) error

+ type LogStreamCreator struct

+ type LogWriter interface

+ AddChannel func(channel string)

+ Broadcast func(level LogLevel, message string, ctx ...LogContext) error

+ Flush func() error

+ HasChannel func(channel string) bool

+ ListChannels func() []string

+ RemoveChannel func(channel string)

+ Signal func(channel string, level LogLevel, message string, ctx ...LogContext) error

+ type LogWriterCreator interface

+ Accept func(config *ConfigPartial) bool

+ Create func(config *ConfigPartial) (LogWriter, error)

+ type LogWriterFactory []LogWriterCreator

+ func NewLogWriterFactory(creators []LogWriterCreator) *LogWriterFactory

+ func (f *LogWriterFactory) Create(config *ConfigPartial) (LogWriter, error)

+ type Migration interface

+ Down func() error

+ Up func() error

+ Version func() uint64

+ type Migrator struct

+ func NewMigrator(dao *MigratorDao, migrations []Migration) (*Migrator, error)

+ func (m *Migrator) AddMigration(migration Migration) error

+ func (m *Migrator) Current() (uint64, error)

+ func (m *Migrator) Down() error

+ func (m *Migrator) Migrate() error

+ func (m *Migrator) Up() error

+ type MigratorDao struct

+ func NewMigratorDao(conn *gorm.DB) (*MigratorDao, error)

+ func (d MigratorDao) Down(last MigratorRecord) error

+ func (d MigratorDao) Last() (MigratorRecord, error)

+ func (d MigratorDao) Up(version uint64) (MigratorRecord, error)

+ type MigratorRecord struct

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ ID uint

+ UpdatedAt time.Time

+ Version uint64

+ func (MigratorRecord) TableName() string

+ type MigratorServiceRegister struct

+ func NewMigratorServiceRegister(app ...*App) *MigratorServiceRegister

+ func (sr MigratorServiceRegister) Boot(container *ServiceContainer) (e error)

+ func (sr MigratorServiceRegister) Provide(container *ServiceContainer) error

+ type RdbConnectionFactory struct

+ func NewRdbConnectionFactory(dialectFactory *RdbDialectFactory) (*RdbConnectionFactory, error)

+ func (f *RdbConnectionFactory) Create(config *ConfigPartial, gormConfig *gorm.Config) (*gorm.DB, error)

+ type RdbConnectionPool struct

+ func NewRdbConnectionPool(config *Config, connectionFactory *RdbConnectionFactory) (*RdbConnectionPool, error)

+ func (f *RdbConnectionPool) Get(name string, gormConfig *gorm.Config) (*gorm.DB, error)

+ type RdbDialectCreator interface

+ Accept func(config *ConfigPartial) bool

+ Create func(config *ConfigPartial) (gorm.Dialector, error)

+ type RdbDialectFactory []RdbDialectCreator

+ func NewRdbDialectFactory(creators []RdbDialectCreator) *RdbDialectFactory

+ func (f *RdbDialectFactory) Create(config *ConfigPartial) (gorm.Dialector, error)

+ type RdbServiceRegister struct

+ func NewRdbServiceRegister(app ...*App) *RdbServiceRegister

+ func (sr RdbServiceRegister) Provide(container *ServiceContainer) error

type ServiceContainer

+ func NewServiceContainer() *ServiceContainer

+ func (c *ServiceContainer) Add(id string, factory interface{}, tags ...string) error

+ func (c *ServiceContainer) Tag(tag string) ([]any, error)

type ServiceProvider

+ Provide func(container *ServiceContainer) error

+ type ServiceRegister struct

+ App *App

+ func NewServiceRegister(app ...*App) *ServiceRegister

+ func (ServiceRegister) Boot(container *ServiceContainer) error

+ func (ServiceRegister) Provide(container *ServiceContainer) error

+ type Trigger interface

+ Delay func() time.Duration

+ type TriggerCallback func() error

+ type TriggerPulse struct

+ func NewTriggerPulse(delay time.Duration, callback TriggerCallback) (*TriggerPulse, error)

+ func (t *TriggerPulse) Close() error

+ func (t TriggerPulse) Delay() time.Duration

+ type TriggerRecurring struct

+ func NewTriggerRecurring(delay time.Duration, callback TriggerCallback) (*TriggerRecurring, error)

+ func (t *TriggerRecurring) Close() error

+ func (t TriggerRecurring) Delay() time.Duration

+ type Watchdog struct

+ func NewWatchdog(logAdapter *WatchdogLogAdapter) (*Watchdog, error)

+ func (w *Watchdog) Run(process WatchdogProcessor) (e error)

+ type WatchdogDefaultLogFormatter struct

+ func NewWatchdogDefaultLogFormatter() *WatchdogDefaultLogFormatter

+ func (WatchdogDefaultLogFormatter) Done(service string) string

+ func (WatchdogDefaultLogFormatter) Error(service string, e error) string

+ func (WatchdogDefaultLogFormatter) Start(service string) string

+ type WatchdogDefaultLogFormatterCreator struct

+ func NewWatchdogDefaultLogFormatterCreator() *WatchdogDefaultLogFormatterCreator

+ func (s WatchdogDefaultLogFormatterCreator) Accept(config *ConfigPartial) bool

+ func (s WatchdogDefaultLogFormatterCreator) Create(_ *ConfigPartial) (WatchdogLogFormatter, error)

+ type WatchdogFactory struct

+ func NewWatchdogFactory(config *Config, logger *Log, logFormatterFactory *WatchdogLogFormatterFactory) (*WatchdogFactory, error)

+ func (f *WatchdogFactory) Create(service string) (*Watchdog, error)

+ type WatchdogKennel struct

+ func NewWatchdogKennel(watchdogFactory *WatchdogFactory, processes []WatchdogProcessor) (*WatchdogKennel, error)

+ func (k *WatchdogKennel) Run() error

+ type WatchdogLogAdapter struct

+ func NewWatchdogLogAdapter(name, channel string, startLevel, errorLevel, doneLevel LogLevel, logger *Log, ...) (*WatchdogLogAdapter, error)

+ func (a *WatchdogLogAdapter) Done() error

+ func (a *WatchdogLogAdapter) Error(e error) error

+ func (a *WatchdogLogAdapter) Start() error

+ type WatchdogLogFormatter interface

+ Done func(service string) string

+ Error func(service string, e error) string

+ Start func(service string) string

+ type WatchdogLogFormatterCreator interface

+ Accept func(config *ConfigPartial) bool

+ Create func(config *ConfigPartial) (WatchdogLogFormatter, error)

+ type WatchdogLogFormatterFactory []WatchdogLogFormatterCreator

+ func NewWatchdogLogFormatterFactory(creators []WatchdogLogFormatterCreator) *WatchdogLogFormatterFactory

+ func (f *WatchdogLogFormatterFactory) Create(config *ConfigPartial) (WatchdogLogFormatter, error)

+ type WatchdogProcess struct

+ func NewWatchdogProcess(service string, runner func() error) (*WatchdogProcess, error)

+ func (p *WatchdogProcess) Runner() func() error

+ func (p *WatchdogProcess) Service() string

+ type WatchdogProcessor interface

+ Runner func() func() error

+ Service func() string

+ type WatchdogServiceRegister struct

+ func NewWatchdogServiceRegister(app ...*App) *WatchdogServiceRegister

+ func (sr WatchdogServiceRegister) Provide(container *ServiceContainer) error

v0.27.0

Sep 17, 2023

v0.26.0

Jun 9, 2023

v0.25.0

Jun 8, 2023

v0.24.0

Jun 8, 2023

v0.23.0

May 29, 2023

Changes in this version

+ type Provider interface

+ Boot func(container *Container) error

+ Register func(container *Container) error

v0.22.0

May 10, 2023

v0.21.1

Apr 9, 2023

v0.21.0

Apr 6, 2023

v0.20.0

Mar 10, 2023

Changes in this version

+ var ErrContainer = NewError("service container error")

+ var ErrConversion = NewError("invalid type conversion")

+ var ErrFactoryWithoutResult = NewError("service factory without result")

+ var ErrNilPointer = NewError("invalid nil pointer")

+ var ErrNonFunctionFactory = NewError("non-function service factory")

+ var ErrServiceNotFound = NewError("service not found")

+ func NewError(msg string, ctx ...map[string]interface{}) error

+ func NewErrorFrom(err error, msg string, ctx ...map[string]interface{}) error

+ type Error struct

+ func (e *Error) Context() map[string]interface{}

+ func (e *Error) Error() string

+ func (e *Error) Unwrap() error

+ type IError interface

+ Context func() map[string]interface{}

+ Unwrap func() error

v0.19.0

Feb 9, 2023

v0.18.0

Feb 6, 2023

v0.17.1

Jan 22, 2023

v0.17.0

Dec 15, 2022

Changes in this version

type Application

+ func (a *Application) Provide(provider IProvider) error

+ func (a *Application) Register(_ ...IContainer) error

type IApplication

+ Provide func(provider IProvider) error

v0.16.0

Dec 14, 2022

Changes in this version

+ const ID

type Application

+ func (a *Application) Provider(provider IProvider) error

+ type Container struct

+ func NewContainer() *Container

+ func (c *Container) Clear() error

+ func (c *Container) Close() error

+ func (c *Container) Get(id string) (any, error)

+ func (c *Container) Has(id string) bool

+ func (c *Container) Remove(id string) error

+ func (c *Container) Service(id string, factory interface{}, tags ...string) error

+ func (c *Container) Tag(tag string) ([]any, error)

type IApplication

+ Provider func(provider IProvider) error

+ type IContainer interface

+ Clear func() error

+ Get func(id string) (any, error)

+ Has func(id string) bool

+ Remove func(id string) error

+ Service func(id string, factory interface{}, tags ...string) error

+ Tag func(tag string) ([]any, error)

+ type IProvider interface

+ Boot func(IContainer) error

+ Register func(IContainer) error

v0.15.0

Jul 31, 2022

v0.14.0

Jul 31, 2022

v0.13.0

Jul 19, 2022

v0.12.0

Jul 19, 2022

v0.11.1

Jul 19, 2022

v0.11.0

Jul 19, 2022

v0.10.0

Jul 18, 2022

Changes in this version

+ type IServiceFactory func() (any, error)

v0.9.0

Jul 13, 2022

Changes in this version

+ type IApplication interface

+ Add func(provider IServiceProvider) error

+ Boot func() error

+ type IServiceContainer interface

+ Clear func() error

+ Factory func(id string, factory ServiceFactory, tags ...string) error

+ Get func(id string) (any, error)

+ Has func(id string) bool

+ Remove func(id string) error

+ Service func(id string, factory ServiceFactory, tags ...string) error

+ Tagged func(tag string) ([]any, error)

+ type IServiceProvider interface

+ Boot func(ServiceContainer) error

+ Register func(ServiceContainer) error

v0.8.0

Jun 24, 2022

v0.7.0

Jun 24, 2022

v0.6.0

Jun 24, 2022

v0.5.1

Jun 24, 2022

v0.5.0

Jun 24, 2022

v0.4.0

Jun 24, 2022

v0.3.0

Jun 23, 2022

v0.2.0

Jun 23, 2022

Changes in this version

+ const EnvID

v0.1.0

Jun 23, 2022

Changes in this version

+ const ContainerID

+ type Application struct

+ Container ServiceContainer

+ func NewApplication() *Application

+ func (a *Application) Add(provider ServiceProvider) error

+ func (a *Application) Boot() (err error)

+ type ServiceContainer map[string]serviceContainerEntry

+ func (c ServiceContainer) Clear() error

+ func (c ServiceContainer) Close() error

+ func (c ServiceContainer) Factory(id string, factory ServiceFactory, tags ...string) error

+ func (c ServiceContainer) Get(id string) (any, error)

+ func (c ServiceContainer) Has(id string) bool

+ func (c ServiceContainer) Remove(id string) error

+ func (c ServiceContainer) Service(id string, factory ServiceFactory, tags ...string) error

+ func (c ServiceContainer) Tagged(tag string) ([]any, error)

+ type ServiceFactory func() (any, error)

+ type ServiceProvider interface

+ Boot func(ServiceContainer) error

+ Register func(ServiceContainer) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL