Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

final pbs #51

Merged
merged 1 commit into from
Nov 7, 2024
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
4 changes: 2 additions & 2 deletions api/buf.lock
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@ deps:
- remote: buf.build
owner: googleapis
repository: googleapis
commit: e7f8d366f5264595bcc4cd4139af9973
digest: shake256:e5e5f1c12f82e028ea696faa43b4f9dc6258a6d1226282962a8c8b282e10946281d815884f574bd279ebd9cd7588629beb3db17b892af6c33b56f92f8f67f509
commit: f52d4f76a8434cc5966798b1d3b4f110
digest: shake256:71566dd80e39b7d85fdaa9b7f82107385181d5b6d17ea56c0aacce61099b35f9f1bcf7333ad9838ca19d24d7f076b039de7c9c09c55d23bb4c2fddfceff4d2c2
- remote: buf.build
owner: srikrsna
repository: protoc-gen-gotag
Expand Down
90 changes: 37 additions & 53 deletions api/core/message_broker/actors/v1/consumer.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

33 changes: 0 additions & 33 deletions api/core/message_broker/actors/v1/consumer.pb.validate.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 2 additions & 4 deletions api/core/message_broker/actors/v1/consumer.proto
Original file line number Diff line number Diff line change
Expand Up @@ -11,11 +11,9 @@ service Consumer {
}

message ConsumeRequest {
Message message = 1;

optional Count count = 2;
CloudEvent message = 1;
}

message ConsumeResponse {
Message message = 1;
CloudEvent message = 1;
}
7 changes: 3 additions & 4 deletions api/core/message_broker/actors/v1/consumer_pb.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,15 @@
// @ts-nocheck

import { proto3 } from "@bufbuild/protobuf";
import { Count, Message } from "./models_pb.js";
import { CloudEvent } from "./models_pb.js";

/**
* @generated from message core.message_broker.actors.v1.ConsumeRequest
*/
export const ConsumeRequest = proto3.makeMessageType(
"core.message_broker.actors.v1.ConsumeRequest",
() => [
{ no: 1, name: "message", kind: "message", T: Message },
{ no: 2, name: "count", kind: "message", T: Count, opt: true },
{ no: 1, name: "message", kind: "message", T: CloudEvent },
],
);

Expand All @@ -23,7 +22,7 @@ export const ConsumeRequest = proto3.makeMessageType(
export const ConsumeResponse = proto3.makeMessageType(
"core.message_broker.actors.v1.ConsumeResponse",
() => [
{ no: 1, name: "message", kind: "message", T: Message },
{ no: 1, name: "message", kind: "message", T: CloudEvent },
],
);

20 changes: 7 additions & 13 deletions api/core/message_broker/actors/v1/consumer_pb.ts
Original file line number Diff line number Diff line change
Expand Up @@ -5,21 +5,16 @@

import type { BinaryReadOptions, FieldList, JsonReadOptions, JsonValue, PartialMessage, PlainMessage } from "@bufbuild/protobuf";
import { Message, proto3 } from "@bufbuild/protobuf";
import { Count, Message as Message$1 } from "./models_pb.js";
import { CloudEvent } from "./models_pb.js";

/**
* @generated from message core.message_broker.actors.v1.ConsumeRequest
*/
export class ConsumeRequest extends Message<ConsumeRequest> {
/**
* @generated from field: core.message_broker.actors.v1.Message message = 1;
* @generated from field: core.message_broker.actors.v1.CloudEvent message = 1;
*/
message?: Message$1;

/**
* @generated from field: optional core.message_broker.actors.v1.Count count = 2;
*/
count?: Count;
message?: CloudEvent;

constructor(data?: PartialMessage<ConsumeRequest>) {
super();
Expand All @@ -29,8 +24,7 @@ export class ConsumeRequest extends Message<ConsumeRequest> {
static readonly runtime: typeof proto3 = proto3;
static readonly typeName = "core.message_broker.actors.v1.ConsumeRequest";
static readonly fields: FieldList = proto3.util.newFieldList(() => [
{ no: 1, name: "message", kind: "message", T: Message$1 },
{ no: 2, name: "count", kind: "message", T: Count, opt: true },
{ no: 1, name: "message", kind: "message", T: CloudEvent },
]);

static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): ConsumeRequest {
Expand All @@ -55,9 +49,9 @@ export class ConsumeRequest extends Message<ConsumeRequest> {
*/
export class ConsumeResponse extends Message<ConsumeResponse> {
/**
* @generated from field: core.message_broker.actors.v1.Message message = 1;
* @generated from field: core.message_broker.actors.v1.CloudEvent message = 1;
*/
message?: Message$1;
message?: CloudEvent;

constructor(data?: PartialMessage<ConsumeResponse>) {
super();
Expand All @@ -67,7 +61,7 @@ export class ConsumeResponse extends Message<ConsumeResponse> {
static readonly runtime: typeof proto3 = proto3;
static readonly typeName = "core.message_broker.actors.v1.ConsumeResponse";
static readonly fields: FieldList = proto3.util.newFieldList(() => [
{ no: 1, name: "message", kind: "message", T: Message$1 },
{ no: 1, name: "message", kind: "message", T: CloudEvent },
]);

static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): ConsumeResponse {
Expand Down
Loading
Loading