Function composeControllerWatcherFilters

workers/scaleset/util.go:22–37

(entity params.ForgeEntity)

)

func composeControllerWatcherFilters(entity params.ForgeEntity) dbCommon.PayloadFilterFunc {
	return watcher.WithAny(
		watcher.WithAll(
			watcher.WithEntityScaleSetFilter(entity),
			watcher.WithAny(
				watcher.WithOperationTypeFilter(dbCommon.CreateOperation),
				watcher.WithOperationTypeFilter(dbCommon.UpdateOperation),
				watcher.WithOperationTypeFilter(dbCommon.DeleteOperation),
			),
		),
		watcher.WithAll(
			watcher.WithEntityFilter(entity),
			watcher.WithOperationTypeFilter(dbCommon.UpdateOperation),
		),
	)
}