Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(config *RegisterConfig, logger *slog.Logger) (*service.Environment, error)
func NewWithEnvironment ¶
func NewWithEnvironment(env *service.Environment, config *RegisterConfig, logger *slog.Logger) (*service.Environment, error)
Types ¶
type MongoConfig ¶
type MongoConfig struct {
Provider neosync_benthos_mongodb.MongoPoolProvider
}
type RegisterConfig ¶
type RegisterConfig struct {
Meter metric.Meter // nil to disable
SqlConfig *SqlConfig // nil to disable
MongoConfig *MongoConfig // nil to disable
StopChannel chan<- error
}
type SqlConfig ¶
type SqlConfig struct {
Provider neosync_benthos_sql.DbPoolProvider
IsRetry bool
}
Click to show internal directories.
Click to hide internal directories.