Skip to content

Commit e786c85

Browse files
Add PendingQueue messages (#1759)
1 parent 31ad843 commit e786c85

File tree

2 files changed

+176
-21
lines changed

2 files changed

+176
-21
lines changed

pkg/capabilities/actions/vault/messages.pb.go

Lines changed: 158 additions & 21 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pkg/capabilities/actions/vault/messages.proto

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,7 @@
11
syntax = "proto3";
22

3+
import "google/protobuf/any.proto";
4+
35
option go_package = "github.com/smartcontractkit/chainlink-common/pkg/capabilities/actions/vault";
46

57
package vault;
@@ -136,6 +138,8 @@ message Observation {
136138

137139
message Observations {
138140
repeated Observation observations = 1;
141+
repeated bytes pending_queue_items = 2;
142+
bytes sortNonce = 3;
139143
}
140144

141145
message Outcome {
@@ -187,6 +191,19 @@ message StoredMetadata {
187191
repeated SecretIdentifier secret_identifiers = 2;
188192
}
189193

194+
// IMPORTANT: this record is persisted so any changes must be
195+
// backwards compatible
196+
message StoredPendingQueueIndex {
197+
int64 length = 1;
198+
}
199+
200+
// IMPORTANT: this record is persisted so any changes must be
201+
// backwards compatible
202+
message StoredPendingQueueItem {
203+
google.protobuf.Any item = 1;
204+
string id = 2;
205+
}
206+
190207
message ReportingPluginConfig {
191208
// Plugin-specific configuration
192209
int32 BatchSize = 1;
@@ -196,6 +213,7 @@ message ReportingPluginConfig {
196213
int32 MaxIdentifierOwnerLengthBytes = 5;
197214
int32 MaxIdentifierNamespaceLengthBytes = 6;
198215
optional string DKGInstanceID = 7;
216+
bool EnableDeterministicPendingQueue = 8;
199217

200218
// OCR 3.1 ReportInfo configuration
201219
int32 LimitsMaxQueryLength = 20;

0 commit comments

Comments
 (0)