Skip to content

Commit ac846ea

Browse files
pruthvidhoddapruthvidhodda
authored
Add support for metadata in state API requests (#50)
1 parent e732cc7 commit ac846ea

File tree

2 files changed

+155
-4
lines changed

2 files changed

+155
-4
lines changed

‎src/dapr/proto/runtime/v1/dapr_pb.d.ts‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,10 @@ export class GetStateRequest extends jspb.Message {
4747
setConsistency(value: dapr_proto_common_v1_common_pb.StateOptions.StateConsistency): void;
4848

4949

50+
getMetadataMap(): jspb.Map<string, string>;
51+
clearMetadataMap(): void;
52+
53+
5054
serializeBinary(): Uint8Array;
5155
toObject(includeInstance?: boolean): GetStateRequest.AsObject;
5256
static toObject(includeInstance: boolean, msg: GetStateRequest): GetStateRequest.AsObject;
@@ -62,6 +66,8 @@ export namespace GetStateRequest {
6266
storeName: string,
6367
key: string,
6468
consistency: dapr_proto_common_v1_common_pb.StateOptions.StateConsistency,
69+
70+
metadataMap: Array<[string, string]>,
6571
}
6672
}
6773

@@ -78,6 +84,10 @@ export class GetBulkStateRequest extends jspb.Message {
7884
setParallelism(value: number): void;
7985

8086

87+
getMetadataMap(): jspb.Map<string, string>;
88+
clearMetadataMap(): void;
89+
90+
8191
serializeBinary(): Uint8Array;
8292
toObject(includeInstance?: boolean): GetBulkStateRequest.AsObject;
8393
static toObject(includeInstance: boolean, msg: GetBulkStateRequest): GetBulkStateRequest.AsObject;
@@ -93,6 +103,8 @@ export namespace GetBulkStateRequest {
93103
storeName: string,
94104
keysList: Array<string>,
95105
parallelism: number,
106+
107+
metadataMap: Array<[string, string]>,
96108
}
97109
}
98110

@@ -131,6 +143,9 @@ export class BulkStateItem extends jspb.Message {
131143
getEtag(): string;
132144
setEtag(value: string): void;
133145

146+
getError(): string;
147+
setError(value: string): void;
148+
134149

135150
serializeBinary(): Uint8Array;
136151
toObject(includeInstance?: boolean): BulkStateItem.AsObject;
@@ -147,6 +162,7 @@ export namespace BulkStateItem {
147162
key: string,
148163
data: Uint8Array | string,
149164
etag: string,
165+
error: string,
150166
}
151167
}
152168

@@ -194,6 +210,10 @@ export class DeleteStateRequest extends jspb.Message {
194210
setOptions(value?: dapr_proto_common_v1_common_pb.StateOptions): void;
195211

196212

213+
getMetadataMap(): jspb.Map<string, string>;
214+
clearMetadataMap(): void;
215+
216+
197217
serializeBinary(): Uint8Array;
198218
toObject(includeInstance?: boolean): DeleteStateRequest.AsObject;
199219
static toObject(includeInstance: boolean, msg: DeleteStateRequest): DeleteStateRequest.AsObject;
@@ -210,6 +230,8 @@ export namespace DeleteStateRequest {
210230
key: string,
211231
etag: string,
212232
options?: dapr_proto_common_v1_common_pb.StateOptions.AsObject,
233+
234+
metadataMap: Array<[string, string]>,
213235
}
214236
}
215237

‎src/dapr/proto/runtime/v1/dapr_pb.js‎

Lines changed: 133 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -561,7 +561,8 @@ proto.dapr.proto.runtime.v1.GetStateRequest.toObject = function(includeInstance,
561561
var f, obj = {
562562
storeName: jspb.Message.getFieldWithDefault(msg, 1, ""),
563563
key: jspb.Message.getFieldWithDefault(msg, 2, ""),
564-
consistency: jspb.Message.getFieldWithDefault(msg, 3, 0)
564+
consistency: jspb.Message.getFieldWithDefault(msg, 3, 0),
565+
metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : []
565566
};
566567

567568
if (includeInstance) {
@@ -610,6 +611,12 @@ proto.dapr.proto.runtime.v1.GetStateRequest.deserializeBinaryFromReader = functi
610611
var value = /** @type {!proto.dapr.proto.common.v1.StateOptions.StateConsistency} */ (reader.readEnum());
611612
msg.setConsistency(value);
612613
break;
614+
case 4:
615+
var value = msg.getMetadataMap();
616+
reader.readMessage(value, function(message, reader) {
617+
jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", "");
618+
});
619+
break;
613620
default:
614621
reader.skipField();
615622
break;
@@ -660,6 +667,10 @@ proto.dapr.proto.runtime.v1.GetStateRequest.serializeBinaryToWriter = function(m
660667
f
661668
);
662669
}
670+
f = message.getMetadataMap(true);
671+
if (f && f.getLength() > 0) {
672+
f.serializeBinary(4, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString);
673+
}
663674
};
664675

665676

@@ -717,6 +728,28 @@ proto.dapr.proto.runtime.v1.GetStateRequest.prototype.setConsistency = function(
717728
};
718729

719730

731+
/**
732+
* map<string, string> metadata = 4;
733+
* @param {boolean=} opt_noLazyCreate Do not create the map if
734+
* empty, instead returning `undefined`
735+
* @return {!jspb.Map<string,string>}
736+
*/
737+
proto.dapr.proto.runtime.v1.GetStateRequest.prototype.getMetadataMap = function(opt_noLazyCreate) {
738+
return /** @type {!jspb.Map<string,string>} */ (
739+
jspb.Message.getMapField(this, 4, opt_noLazyCreate,
740+
null));
741+
};
742+
743+
744+
/**
745+
* Clears values from the map. The map will be non-null.
746+
* @return {!proto.dapr.proto.runtime.v1.GetStateRequest} returns this
747+
*/
748+
proto.dapr.proto.runtime.v1.GetStateRequest.prototype.clearMetadataMap = function() {
749+
this.getMetadataMap().clear();
750+
return this;};
751+
752+
720753

721754
/**
722755
* List of repeated fields within this message type.
@@ -758,7 +791,8 @@ proto.dapr.proto.runtime.v1.GetBulkStateRequest.toObject = function(includeInsta
758791
var f, obj = {
759792
storeName: jspb.Message.getFieldWithDefault(msg, 1, ""),
760793
keysList: (f = jspb.Message.getRepeatedField(msg, 2)) == null ? undefined : f,
761-
parallelism: jspb.Message.getFieldWithDefault(msg, 3, 0)
794+
parallelism: jspb.Message.getFieldWithDefault(msg, 3, 0),
795+
metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : []
762796
};
763797

764798
if (includeInstance) {
@@ -807,6 +841,12 @@ proto.dapr.proto.runtime.v1.GetBulkStateRequest.deserializeBinaryFromReader = fu
807841
var value = /** @type {number} */ (reader.readInt32());
808842
msg.setParallelism(value);
809843
break;
844+
case 4:
845+
var value = msg.getMetadataMap();
846+
reader.readMessage(value, function(message, reader) {
847+
jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", "");
848+
});
849+
break;
810850
default:
811851
reader.skipField();
812852
break;
@@ -857,6 +897,10 @@ proto.dapr.proto.runtime.v1.GetBulkStateRequest.serializeBinaryToWriter = functi
857897
f
858898
);
859899
}
900+
f = message.getMetadataMap(true);
901+
if (f && f.getLength() > 0) {
902+
f.serializeBinary(4, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString);
903+
}
860904
};
861905

862906

@@ -933,6 +977,28 @@ proto.dapr.proto.runtime.v1.GetBulkStateRequest.prototype.setParallelism = funct
933977
};
934978

935979

980+
/**
981+
* map<string, string> metadata = 4;
982+
* @param {boolean=} opt_noLazyCreate Do not create the map if
983+
* empty, instead returning `undefined`
984+
* @return {!jspb.Map<string,string>}
985+
*/
986+
proto.dapr.proto.runtime.v1.GetBulkStateRequest.prototype.getMetadataMap = function(opt_noLazyCreate) {
987+
return /** @type {!jspb.Map<string,string>} */ (
988+
jspb.Message.getMapField(this, 4, opt_noLazyCreate,
989+
null));
990+
};
991+
992+
993+
/**
994+
* Clears values from the map. The map will be non-null.
995+
* @return {!proto.dapr.proto.runtime.v1.GetBulkStateRequest} returns this
996+
*/
997+
proto.dapr.proto.runtime.v1.GetBulkStateRequest.prototype.clearMetadataMap = function() {
998+
this.getMetadataMap().clear();
999+
return this;};
1000+
1001+
9361002

9371003
/**
9381004
* List of repeated fields within this message type.
@@ -1127,7 +1193,8 @@ proto.dapr.proto.runtime.v1.BulkStateItem.toObject = function(includeInstance, m
11271193
var f, obj = {
11281194
key: jspb.Message.getFieldWithDefault(msg, 1, ""),
11291195
data: msg.getData_asB64(),
1130-
etag: jspb.Message.getFieldWithDefault(msg, 3, "")
1196+
etag: jspb.Message.getFieldWithDefault(msg, 3, ""),
1197+
error: jspb.Message.getFieldWithDefault(msg, 4, "")
11311198
};
11321199

11331200
if (includeInstance) {
@@ -1176,6 +1243,10 @@ proto.dapr.proto.runtime.v1.BulkStateItem.deserializeBinaryFromReader = function
11761243
var value = /** @type {string} */ (reader.readString());
11771244
msg.setEtag(value);
11781245
break;
1246+
case 4:
1247+
var value = /** @type {string} */ (reader.readString());
1248+
msg.setError(value);
1249+
break;
11791250
default:
11801251
reader.skipField();
11811252
break;
@@ -1226,6 +1297,13 @@ proto.dapr.proto.runtime.v1.BulkStateItem.serializeBinaryToWriter = function(mes
12261297
f
12271298
);
12281299
}
1300+
f = message.getError();
1301+
if (f.length > 0) {
1302+
writer.writeString(
1303+
4,
1304+
f
1305+
);
1306+
}
12291307
};
12301308

12311309

@@ -1307,6 +1385,24 @@ proto.dapr.proto.runtime.v1.BulkStateItem.prototype.setEtag = function(value) {
13071385
};
13081386

13091387

1388+
/**
1389+
* optional string error = 4;
1390+
* @return {string}
1391+
*/
1392+
proto.dapr.proto.runtime.v1.BulkStateItem.prototype.getError = function() {
1393+
return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 4, ""));
1394+
};
1395+
1396+
1397+
/**
1398+
* @param {string} value
1399+
* @return {!proto.dapr.proto.runtime.v1.BulkStateItem} returns this
1400+
*/
1401+
proto.dapr.proto.runtime.v1.BulkStateItem.prototype.setError = function(value) {
1402+
return jspb.Message.setProto3StringField(this, 4, value);
1403+
};
1404+
1405+
13101406

13111407

13121408

@@ -1526,7 +1622,8 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.toObject = function(includeInstan
15261622
storeName: jspb.Message.getFieldWithDefault(msg, 1, ""),
15271623
key: jspb.Message.getFieldWithDefault(msg, 2, ""),
15281624
etag: jspb.Message.getFieldWithDefault(msg, 3, ""),
1529-
options: (f = msg.getOptions()) && dapr_proto_common_v1_common_pb.StateOptions.toObject(includeInstance, f)
1625+
options: (f = msg.getOptions()) && dapr_proto_common_v1_common_pb.StateOptions.toObject(includeInstance, f),
1626+
metadataMap: (f = msg.getMetadataMap()) ? f.toObject(includeInstance, undefined) : []
15301627
};
15311628

15321629
if (includeInstance) {
@@ -1580,6 +1677,12 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.deserializeBinaryFromReader = fun
15801677
reader.readMessage(value,dapr_proto_common_v1_common_pb.StateOptions.deserializeBinaryFromReader);
15811678
msg.setOptions(value);
15821679
break;
1680+
case 5:
1681+
var value = msg.getMetadataMap();
1682+
reader.readMessage(value, function(message, reader) {
1683+
jspb.Map.deserializeBinary(message, reader, jspb.BinaryReader.prototype.readString, jspb.BinaryReader.prototype.readString, null, "", "");
1684+
});
1685+
break;
15831686
default:
15841687
reader.skipField();
15851688
break;
@@ -1638,6 +1741,10 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.serializeBinaryToWriter = functio
16381741
dapr_proto_common_v1_common_pb.StateOptions.serializeBinaryToWriter
16391742
);
16401743
}
1744+
f = message.getMetadataMap(true);
1745+
if (f && f.getLength() > 0) {
1746+
f.serializeBinary(5, writer, jspb.BinaryWriter.prototype.writeString, jspb.BinaryWriter.prototype.writeString);
1747+
}
16411748
};
16421749

16431750

@@ -1732,6 +1839,28 @@ proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.hasOptions = function()
17321839
};
17331840

17341841

1842+
/**
1843+
* map<string, string> metadata = 5;
1844+
* @param {boolean=} opt_noLazyCreate Do not create the map if
1845+
* empty, instead returning `undefined`
1846+
* @return {!jspb.Map<string,string>}
1847+
*/
1848+
proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.getMetadataMap = function(opt_noLazyCreate) {
1849+
return /** @type {!jspb.Map<string,string>} */ (
1850+
jspb.Message.getMapField(this, 5, opt_noLazyCreate,
1851+
null));
1852+
};
1853+
1854+
1855+
/**
1856+
* Clears values from the map. The map will be non-null.
1857+
* @return {!proto.dapr.proto.runtime.v1.DeleteStateRequest} returns this
1858+
*/
1859+
proto.dapr.proto.runtime.v1.DeleteStateRequest.prototype.clearMetadataMap = function() {
1860+
this.getMetadataMap().clear();
1861+
return this;};
1862+
1863+
17351864

17361865
/**
17371866
* List of repeated fields within this message type.

0 commit comments

Comments
 (0)