3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-07-14 07:18:21 +02:00
Code Issues Projects Releases Packages Wiki Activity

reconciler: allow custom comparison function (#4727)

Browse source 
reconciler: allow custom comparison function (#4726)

Co-authored-by: Denis Mishin <dmishin@pomerium.com>
This commit is contained in:
backport-actions-token[bot] 2023-11-08 20:30:06 -05:00 • committed by GitHub
parent da9b14db44
commit c9583c828c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 19 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

5
pkg/grpc/databroker/reconciler.go
View file

@ -17,6 +17,7 @@ type Reconciler struct {
name string
client DataBrokerServiceClient
currentStateBuilder StateBuilderFn
cmpFn RecordCompareFn
targetStateBuilder StateBuilderFn
setCurrentState func([]*Record)
trigger chan struct{}
@ -58,6 +59,7 @@ func NewReconciler(
currentStateBuilder StateBuilderFn,
targetStateBuilder StateBuilderFn,
setCurrentState func([]*Record),
cmpFn RecordCompareFn,
opts ...ReconcilerOption,
) *Reconciler {
return &Reconciler{
@ -68,6 +70,7 @@ func NewReconciler(
currentStateBuilder: currentStateBuilder,
targetStateBuilder: targetStateBuilder,
setCurrentState: setCurrentState,
cmpFn: cmpFn,
}
}
@ -119,7 +122,7 @@ func (r *Reconciler) reconcile(ctx context.Context) error {
return fmt.Errorf("get config record sets: %w", err)
}
updates := GetChangeSet(current, target)
updates := GetChangeSet(current, target, r.cmpFn)
err = r.applyChanges(ctx, updates)
if err != nil {