Skip to content

Commit 457056b

Browse files
committed
feat: add option to override consolidationPolicy
1 parent 787f7a0 commit 457056b

File tree

1 file changed

+13
-1
lines changed

1 file changed

+13
-1
lines changed

src/database/arangodb/schema-migration/arango-search-helpers.ts

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import {
55
ArangoSearchViewLinkOptions,
66
ArangoSearchViewPropertiesOptions,
77
CreateArangoSearchViewOptions,
8+
TierConsolidationPolicy,
89
View,
910
ViewProperties,
1011
} from 'arangojs/view';
@@ -59,6 +60,12 @@ export interface ArangoSearchConfiguration {
5960
* Wait at least this many commits before removing unused files in the data directory
6061
*/
6162
readonly cleanupIntervalStep?: number;
63+
64+
/**
65+
* Specify options of the consolidation policy. If not specified, new views will use defaults
66+
* and existing views will not be changed.
67+
*/
68+
readonly consolidationPolicy?: TierConsolidationPolicy;
6269
}
6370

6471
export function getRequiredViewsFromModel(model: Model): ReadonlyArray<ArangoSearchDefinition> {
@@ -189,6 +196,8 @@ function getPropertiesFromDefinition(
189196
cleanupIntervalStep:
190197
performanceParams.cleanupIntervalStep ?? configuration?.cleanupIntervalStep ?? 2,
191198

199+
consolidationPolicy: configuration?.consolidationPolicy,
200+
192201
primarySort: definition?.primarySort ? definition.primarySort.slice() : [],
193202
};
194203

@@ -278,7 +287,10 @@ export function isEqualProperties(
278287
definitionProperties.consolidationIntervalMsec,
279288
viewProperties.consolidationIntervalMsec,
280289
) &&
281-
isEqual(definitionProperties.cleanupIntervalStep, viewProperties.cleanupIntervalStep)
290+
isEqual(definitionProperties.cleanupIntervalStep, viewProperties.cleanupIntervalStep) &&
291+
// only compare consolidationPolicy if it's configured
292+
(!definitionProperties.consolidationPolicy ||
293+
isEqual(definitionProperties.consolidationPolicy, viewProperties.consolidationPolicy))
282294
);
283295
}
284296

0 commit comments

Comments
 (0)