benthos_environment

Documentation

Index

• func New(config *RegisterConfig) (*service.Environment, error)
• func NewWithEnvironment(env *service.Environment, config *RegisterConfig) (*service.Environment, error)
• type MongoConfig
• type RegisterConfig
• type SqlConfig

Functions

func New

func New(config *RegisterConfig) (*service.Environment, error)

func NewWithEnvironment

func NewWithEnvironment(env *service.Environment, config *RegisterConfig) (*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
}