logsinkservices

Documentation

Index

• func Manifold(config ManifoldConfig) dependency.Manifold
• func NewLogSinkServices(modelUUID coremodel.UUID, dbGetter changestream.WatchableDBGetter, ...) services.LogSinkServices
• func NewLogSinkServicesGetter(newLogSinkServices LogSinkServicesFn, dbGetter changestream.WatchableDBGetter, ...) services.LogSinkServicesGetter
• func NewWorker(config Config) (worker.Worker, error)
• type Config
  • func (config Config) Validate() error
• type LogSinkServicesFn
• type LogSinkServicesGetterFn
• type ManifoldConfig
  • func (config ManifoldConfig) Validate() error

Functions

func Manifold

func Manifold(config ManifoldConfig) dependency.Manifold

Manifold returns a dependency.Manifold that will run an provider service.

func NewLogSinkServices

func NewLogSinkServices(
	modelUUID coremodel.UUID,
	dbGetter changestream.WatchableDBGetter,
	logger logger.Logger,
) services.LogSinkServices

NewLogSinkServices returns a new provider domain services.

func NewLogSinkServicesGetter

func NewLogSinkServicesGetter(
	newLogSinkServices LogSinkServicesFn,
	dbGetter changestream.WatchableDBGetter,
	logger logger.Logger,
) services.LogSinkServicesGetter

NewLogSinkServicesGetter returns a new domain services getter.

func NewWorker

func NewWorker(config Config) (worker.Worker, error)

NewWorker returns a new domain services worker, with the given configuration.

Types

type Config

type Config struct {
	// DBGetter supplies WatchableDB implementations by namespace.
	DBGetter changestream.WatchableDBGetter

	Logger logger.Logger

	NewLogSinkServicesGetter LogSinkServicesGetterFn
	NewLogSinkServices       LogSinkServicesFn
}

Config is the configuration required for domain services worker.

func (Config) Validate

func (config Config) Validate() error

Validate validates the domain services configuration.

type LogSinkServicesFn

type LogSinkServicesFn func(
	coremodel.UUID,
	changestream.WatchableDBGetter,
	logger.Logger,
) services.LogSinkServices

LogSinkServicesFn is a function that returns a provider service factory.

type LogSinkServicesGetterFn

type LogSinkServicesGetterFn func(
	LogSinkServicesFn,
	changestream.WatchableDBGetter,
	logger.Logger,
) services.LogSinkServicesGetter

LogSinkServicesGetterFn is a function that returns a provider service factory getter.

type ManifoldConfig

type ManifoldConfig struct {
	ChangeStreamName string
	Logger           logger.Logger
	NewWorker        func(Config) (worker.Worker, error)

	// NewLogSinkServicesGetter returns a new provider domain services
	// getter, to select a provider domain services per model UUID.
	NewLogSinkServicesGetter LogSinkServicesGetterFn

	// NewLogSinkServices returns a new provider domain services for
	// the given model UUID.
	NewLogSinkServices LogSinkServicesFn
}

ManifoldConfig holds the information necessary to run a provider service factory worker in a dependency.Engine.

func (ManifoldConfig) Validate

func (config ManifoldConfig) Validate() error

Validate validates the manifold configuration.