service

Documentation

Index

• type Service
• type State
• type WatchableService
  • func NewWatchableService(st State, watcherFactory WatcherFactory, logger logger.Logger) *WatchableService
• type WatcherFactory

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service provides the API for working with entity removal.

type State

type State interface{}

State describes retrieval and persistence methods for entity removal.

type WatchableService

type WatchableService struct {
	Service
	// contains filtered or unexported fields
}

WatchableService provides the API for working with entity removal, including the ability to create watchers.

func NewWatchableService

func NewWatchableService(
	st State,
	watcherFactory WatcherFactory,
	logger logger.Logger,
) *WatchableService

NewWatchableService creates a new WatchableService for working with entity removal.

type WatcherFactory

type WatcherFactory interface {
	// NewNamespaceWatcher returns a new namespace watcher
	// for events based on the input change mask.
	NewNamespaceWatcher(string, changestream.ChangeType, eventsource.NamespaceQuery) (watcher.StringsWatcher, error)
}

WatcherFactory describes methods for creating watchers.