logsinkservices

Documentation

Index

• func Manifold(config ManifoldConfig) dependency.Manifold
• func NewLogSinkServices(dbGetter changestream.WatchableDBGetter, logger logger.Logger) services.LogSinkServices
• func NewWorker(config Config) (worker.Worker, error)
• type Config
  • func (config Config) Validate() error
• type LogSinkServicesFn
• 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 logsink service.

func NewLogSinkServices

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

NewLogSinkServices returns a new logsink domain services.

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

	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(
	changestream.WatchableDBGetter,
	logger.Logger,
) services.LogSinkServices

LogSinkServicesFn is a function that returns a logsink service factory.

type ManifoldConfig

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

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

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

func (ManifoldConfig) Validate

func (config ManifoldConfig) Validate() error

Validate validates the manifold configuration.