From 24f9f4d5499c7e7f758471646791462abe0a2bc0 Mon Sep 17 00:00:00 2001 From: Denis Mishin Date: Thu, 2 Nov 2023 13:26:11 -0400 Subject: [PATCH] add ChangeSet.GetUpdates --- pkg/grpc/databroker/changeset.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/pkg/grpc/databroker/changeset.go b/pkg/grpc/databroker/changeset.go index 94804ca98..f95b62f9f 100644 --- a/pkg/grpc/databroker/changeset.go +++ b/pkg/grpc/databroker/changeset.go @@ -38,6 +38,11 @@ func (cs *ChangeSet) Upsert(record *Record) { }) } +// Updates returns the change set's updates. +func (cs *ChangeSet) Updates() []*Record { + return cs.updates +} + // ApplyChanges applies the changes to the databroker. func ApplyChanges(ctx context.Context, client DataBrokerServiceClient, changes *ChangeSet) error { updates := OptimumPutRequestsFromRecords(changes.updates)