Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
51 changes: 51 additions & 0 deletions npm/src/proto/messages/com/deno/kv/datapath/Mutation.ts
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,9 @@ export declare namespace $.com.deno.kv.datapath {
value?: KvValue;
mutationType: MutationType;
expireAtMs: string;
sumMin: Uint8Array;
sumMax: Uint8Array;
sumClamp: boolean;
}
}

Expand All @@ -50,6 +53,9 @@ export function getDefaultValue(): $.com.deno.kv.datapath.Mutation {
value: undefined,
mutationType: "M_UNSPECIFIED",
expireAtMs: "0",
sumMin: new Uint8Array(),
sumMax: new Uint8Array(),
sumClamp: false,
};
}

Expand All @@ -66,6 +72,9 @@ export function encodeJson(value: $.com.deno.kv.datapath.Mutation): unknown {
if (value.value !== undefined) result.value = encodeJson_1(value.value);
if (value.mutationType !== undefined) result.mutationType = tsValueToJsonValueFns.enum(value.mutationType);
if (value.expireAtMs !== undefined) result.expireAtMs = tsValueToJsonValueFns.int64(value.expireAtMs);
if (value.sumMin !== undefined) result.sumMin = tsValueToJsonValueFns.bytes(value.sumMin);
if (value.sumMax !== undefined) result.sumMax = tsValueToJsonValueFns.bytes(value.sumMax);
if (value.sumClamp !== undefined) result.sumClamp = tsValueToJsonValueFns.bool(value.sumClamp);
return result;
}

Expand All @@ -75,6 +84,9 @@ export function decodeJson(value: any): $.com.deno.kv.datapath.Mutation {
if (value.value !== undefined) result.value = decodeJson_1(value.value);
if (value.mutationType !== undefined) result.mutationType = jsonValueToTsValueFns.enum(value.mutationType) as MutationType;
if (value.expireAtMs !== undefined) result.expireAtMs = jsonValueToTsValueFns.int64(value.expireAtMs);
if (value.sumMin !== undefined) result.sumMin = jsonValueToTsValueFns.bytes(value.sumMin);
if (value.sumMax !== undefined) result.sumMax = jsonValueToTsValueFns.bytes(value.sumMax);
if (value.sumClamp !== undefined) result.sumClamp = jsonValueToTsValueFns.bool(value.sumClamp);
return result;
}

Expand Down Expand Up @@ -104,6 +116,24 @@ export function encodeBinary(value: $.com.deno.kv.datapath.Mutation): Uint8Array
[4, tsValueToWireValueFns.int64(tsValue)],
);
}
if (value.sumMin !== undefined) {
const tsValue = value.sumMin;
result.push(
[5, tsValueToWireValueFns.bytes(tsValue)],
);
}
if (value.sumMax !== undefined) {
const tsValue = value.sumMax;
result.push(
[6, tsValueToWireValueFns.bytes(tsValue)],
);
}
if (value.sumClamp !== undefined) {
const tsValue = value.sumClamp;
result.push(
[7, tsValueToWireValueFns.bool(tsValue)],
);
}
return serialize(result);
}

Expand Down Expand Up @@ -139,5 +169,26 @@ export function decodeBinary(binary: Uint8Array): $.com.deno.kv.datapath.Mutatio
if (value === undefined) break field;
result.expireAtMs = value;
}
field: {
const wireValue = wireFields.get(5);
if (wireValue === undefined) break field;
const value = wireValueToTsValueFns.bytes(wireValue);
if (value === undefined) break field;
result.sumMin = value;
}
field: {
const wireValue = wireFields.get(6);
if (wireValue === undefined) break field;
const value = wireValueToTsValueFns.bytes(wireValue);
if (value === undefined) break field;
result.sumMax = value;
}
field: {
const wireValue = wireFields.get(7);
if (wireValue === undefined) break field;
const value = wireValueToTsValueFns.bool(wireValue);
if (value === undefined) break field;
result.sumClamp = value;
}
return result;
}
5 changes: 4 additions & 1 deletion npm/src/proto/messages/com/deno/kv/datapath/MutationType.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,8 @@ export declare namespace $.com.deno.kv.datapath {
| "M_DELETE"
| "M_SUM"
| "M_MAX"
| "M_MIN";
| "M_MIN"
| "M_SET_SUFFIX_VERSIONSTAMPED_KEY";
}

export type Type = $.com.deno.kv.datapath.MutationType;
Expand All @@ -18,6 +19,7 @@ export const num2name = {
3: "M_SUM",
4: "M_MAX",
5: "M_MIN",
9: "M_SET_SUFFIX_VERSIONSTAMPED_KEY",
} as const;

export const name2num = {
Expand All @@ -27,4 +29,5 @@ export const name2num = {
M_SUM: 3,
M_MAX: 4,
M_MIN: 5,
M_SET_SUFFIX_VERSIONSTAMPED_KEY: 9,
} as const;
3 changes: 3 additions & 0 deletions npm/src/proto_based.ts
Original file line number Diff line number Diff line change
Expand Up @@ -289,6 +289,9 @@ function computeKvMutationMessage(
expireAtMs: mut.type === "set" && typeof mut.expireIn === "number"
? (Date.now() + mut.expireIn).toString()
: "0",
sumMin: new Uint8Array(),
sumMax: new Uint8Array(),
sumClamp: false,
};
}

Expand Down
Loading