ttl_watcher

Documentation

Index

• func NewTtlWatcher(ctx context.Context, wg *sync.WaitGroup, db db.DBConnector, ...) *watchers.WatcherImpl
• func TtlWatcherAction(baseCtx context.Context, period time.Duration, db db.DBConnector, ...)

Functions

func NewTtlWatcher

func NewTtlWatcher(
	ctx context.Context,
	wg *sync.WaitGroup,
	db db.DBConnector,
	queryBuilderFactory queries.WriteQueryBulderFactory,
	options ...watchers.Option,
) *watchers.WatcherImpl

func TtlWatcherAction

func TtlWatcherAction(
	baseCtx context.Context,
	period time.Duration,
	db db.DBConnector,
	queryBuilderFactory queries.WriteQueryBulderFactory,
)