Skip to content

Commit

Permalink
feat: add presence channel and unauthorize consumer
Browse files Browse the repository at this point in the history
Signed-off-by: Nick Aguilar <nickaguilarh@gmail.com>
  • Loading branch information
nickaguilarh committed May 8, 2024
1 parent 553962c commit 6ff34c0
Show file tree
Hide file tree
Showing 3 changed files with 45 additions and 1 deletion.
2 changes: 1 addition & 1 deletion buf.lock
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ deps:
- remote: buf.build
owner: googleapis
repository: googleapis
commit: a51f4a87c68c47f9901f3892e1ac4a0b
commit: 14bdc09318b24694992b8c84f63e3681
digest: shake256:7149cf5e9955c692d381e557830555d4e93f205a0f1b8e2dfdae46d029369aa3fc1980e35df0d310f7cc3b622f93e19ad276769a283a967dd3065ddfd3a40e13
33 changes: 33 additions & 0 deletions queuer/consumers/v1/presence.proto
Original file line number Diff line number Diff line change
@@ -0,0 +1,33 @@
syntax = "proto3";

package queuer.consumers.v1;

import "google/api/annotations.proto";
import "google/api/field_behavior.proto";
import "google/protobuf/wrappers.proto";
import "google/protobuf/empty.proto";
import "google/protobuf/timestamp.proto";
import "validate/validate.proto";

import "queuer/entities/v1/consumer.proto";
import "queuer/entities/v1/stream.proto";
import "queuer/entities/v1/message.proto";
import "queuer/entities/v1/command.proto";
import "queuer/entities/v1/stats.proto";
import "queuer/entities/v1/result.proto";
import "queuer/entities/v1/session.proto";

// Defines the import path that should be used to import the generated package,
// and the package name.
option go_package = "github.com/gsols/goproto/queuer/consumers/v1;v1";
option php_namespace = "GSols\\PHPProto\\Queuer\\Consumers\\v1";
option php_metadata_namespace = "GSols\\PHPProto\\Queuer\\Consumers\\v1\\Metadata";


message IAmAliveRequest {
google.protobuf.Timestamp timestamp = 1;
}

message IAmAliveResponse {
google.protobuf.Timestamp timestamp = 1;
}
11 changes: 11 additions & 0 deletions queuer/consumers/v1/service.proto
Original file line number Diff line number Diff line change
Expand Up @@ -17,13 +17,24 @@ import "queuer/entities/v1/stats.proto";


import "queuer/consumers/v1/messages.proto";
import "queuer/consumers/v1/presence.proto";

// Defines the import path that should be used to import the generated package,
// and the package name.
option go_package = "github.com/gsols/goproto/queuer/consumers/v1;v1";
option php_namespace = "GSols\\PHPProto\\Queuer\\Consumers\\v1";
option php_metadata_namespace = "GSols\\PHPProto\\Queuer\\Consumers\\v1\\Metadata";

service PresenceService {
rpc IAmAlive(IAmAliveRequest) returns (IAmAliveResponse) {
option (google.api.http) = {
post: "/v1/presence/live"
body: "*"
};
}
}


service ConsumerService {
rpc RegisterConsumer(RegisterConsumerRequest) returns (RegisterConsumerResponse) {
option (google.api.http) = {
Expand Down

0 comments on commit 6ff34c0

Please sign in to comment.