Skip to content

Commit bac813b

Browse files
w1amw1am
committed
Rename proto package namespace
1 parent 88f6db5 commit bac813b

File tree

7 files changed

+96
-96
lines changed

7 files changed

+96
-96
lines changed

‎db-client-java/src/main/java/io/kurrent/dbclient/ServerFeatures.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,9 @@ private static CompletableFuture<ServerInfo> getSupportedFeaturesInternal(Server
6969

7070
int features = FeatureFlags.NOTHING;
7171
for (Serverfeatures.SupportedMethod method : resp.getMethodsList()) {
72-
if (method.getMethodName().equals("batchappend") && method.getServiceName().equals("event_store.client.streams.streams")) {
72+
if (method.getMethodName().equals("batchappend") && method.getServiceName().equals("kurrent.client.streams.streams")) {
7373
features |= FeatureFlags.BATCH_APPEND;
74-
} else if (method.getServiceName().equals("event_store.client.persistent_subscriptions.persistentsubscriptions")) {
74+
} else if (method.getServiceName().equals("kurrent.client.persistent_subscriptions.persistentsubscriptions")) {
7575
switch (method.getMethodName()) {
7676
case "create":
7777
for (String feat : method.getFeaturesList()) {

‎db-client-java/src/main/proto/gossip.proto‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
syntax = "proto3";
2-
package event_store.client.gossip;
2+
package kurrent.client.gossip;
33
option java_package = "io.kurrent.dbclient.proto.gossip";
44

55
import "shared.proto";
66

77
service Gossip {
8-
rpc Read (event_store.client.Empty) returns (ClusterInfo);
8+
rpc Read (kurrent.client.Empty) returns (ClusterInfo);
99
}
1010

1111
message ClusterInfo {
@@ -36,7 +36,7 @@ message MemberInfo {
3636
ReadOnlyReplica = 14;
3737
ResigningLeader = 15;
3838
}
39-
event_store.client.UUID instance_id = 1;
39+
kurrent.client.UUID instance_id = 1;
4040
int64 time_stamp = 2;
4141
VNodeState state = 3;
4242
bool is_alive = 4;

‎db-client-java/src/main/proto/persistent.proto‎

Lines changed: 36 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
syntax = "proto3";
2-
package event_store.client.persistent_subscriptions;
2+
package kurrent.client.persistent_subscriptions;
33
option java_package = "io.kurrent.dbclient.proto.persistentsubscriptions";
44

55
import "shared.proto";
@@ -12,7 +12,7 @@ service PersistentSubscriptions {
1212
rpc GetInfo (GetInfoReq) returns (GetInfoResp);
1313
rpc ReplayParked (ReplayParkedReq) returns (ReplayParkedResp);
1414
rpc List (ListReq) returns (ListResp);
15-
rpc RestartSubsystem (event_store.client.Empty) returns (event_store.client.Empty);
15+
rpc RestartSubsystem (kurrent.client.Empty) returns (kurrent.client.Empty);
1616
}
1717

1818
message ReadReq {
@@ -24,8 +24,8 @@ message ReadReq {
2424

2525
message Options {
2626
oneof stream_option {
27-
event_store.client.StreamIdentifier stream_identifier = 1;
28-
event_store.client.Empty all = 5;
27+
kurrent.client.StreamIdentifier stream_identifier = 1;
28+
kurrent.client.Empty all = 5;
2929
}
3030

3131
string group_name = 2;
@@ -34,20 +34,20 @@ message ReadReq {
3434

3535
message UUIDOption {
3636
oneof content {
37-
event_store.client.Empty structured = 1;
38-
event_store.client.Empty string = 2;
37+
kurrent.client.Empty structured = 1;
38+
kurrent.client.Empty string = 2;
3939
}
4040
}
4141
}
4242

4343
message Ack {
4444
bytes id = 1;
45-
repeated event_store.client.UUID ids = 2;
45+
repeated kurrent.client.UUID ids = 2;
4646
}
4747

4848
message Nack {
4949
bytes id = 1;
50-
repeated event_store.client.UUID ids = 2;
50+
repeated kurrent.client.UUID ids = 2;
5151
Action action = 3;
5252
string reason = 4;
5353

@@ -71,15 +71,15 @@ message ReadResp {
7171
RecordedEvent link = 2;
7272
oneof position {
7373
uint64 commit_position = 3;
74-
event_store.client.Empty no_position = 4;
74+
kurrent.client.Empty no_position = 4;
7575
}
7676
oneof count {
7777
int32 retry_count = 5;
78-
event_store.client.Empty no_retry_count = 6;
78+
kurrent.client.Empty no_retry_count = 6;
7979
}
8080
message RecordedEvent {
81-
event_store.client.UUID id = 1;
82-
event_store.client.StreamIdentifier stream_identifier = 2;
81+
kurrent.client.UUID id = 1;
82+
kurrent.client.StreamIdentifier stream_identifier = 2;
8383
uint64 stream_revision = 3;
8484
uint64 prepare_position = 4;
8585
uint64 commit_position = 5;
@@ -101,29 +101,29 @@ message CreateReq {
101101
StreamOptions stream = 4;
102102
AllOptions all = 5;
103103
}
104-
event_store.client.StreamIdentifier stream_identifier = 1 [deprecated=true];
104+
kurrent.client.StreamIdentifier stream_identifier = 1 [deprecated=true];
105105
string group_name = 2;
106106
Settings settings = 3;
107107
}
108108

109109
message StreamOptions {
110-
event_store.client.StreamIdentifier stream_identifier = 1;
110+
kurrent.client.StreamIdentifier stream_identifier = 1;
111111
oneof revision_option {
112112
uint64 revision = 2;
113-
event_store.client.Empty start = 3;
114-
event_store.client.Empty end = 4;
113+
kurrent.client.Empty start = 3;
114+
kurrent.client.Empty end = 4;
115115
}
116116
}
117117

118118
message AllOptions {
119119
oneof all_option {
120120
Position position = 1;
121-
event_store.client.Empty start = 2;
122-
event_store.client.Empty end = 3;
121+
kurrent.client.Empty start = 2;
122+
kurrent.client.Empty end = 3;
123123
}
124124
oneof filter_option {
125125
FilterOptions filter = 4;
126-
event_store.client.Empty no_filter = 5;
126+
kurrent.client.Empty no_filter = 5;
127127
}
128128
message FilterOptions {
129129
oneof filter {
@@ -132,7 +132,7 @@ message CreateReq {
132132
}
133133
oneof window {
134134
uint32 max = 3;
135-
event_store.client.Empty count = 4;
135+
kurrent.client.Empty count = 4;
136136
}
137137
uint32 checkpointIntervalMultiplier = 5;
138138

@@ -189,25 +189,25 @@ message UpdateReq {
189189
StreamOptions stream = 4;
190190
AllOptions all = 5;
191191
}
192-
event_store.client.StreamIdentifier stream_identifier = 1 [deprecated = true];
192+
kurrent.client.StreamIdentifier stream_identifier = 1 [deprecated = true];
193193
string group_name = 2;
194194
Settings settings = 3;
195195
}
196196

197197
message StreamOptions {
198-
event_store.client.StreamIdentifier stream_identifier = 1;
198+
kurrent.client.StreamIdentifier stream_identifier = 1;
199199
oneof revision_option {
200200
uint64 revision = 2;
201-
event_store.client.Empty start = 3;
202-
event_store.client.Empty end = 4;
201+
kurrent.client.Empty start = 3;
202+
kurrent.client.Empty end = 4;
203203
}
204204
}
205205

206206
message AllOptions {
207207
oneof all_option {
208208
Position position = 1;
209-
event_store.client.Empty start = 2;
210-
event_store.client.Empty end = 3;
209+
kurrent.client.Empty start = 2;
210+
kurrent.client.Empty end = 3;
211211
}
212212
}
213213

@@ -253,8 +253,8 @@ message DeleteReq {
253253

254254
message Options {
255255
oneof stream_option {
256-
event_store.client.StreamIdentifier stream_identifier = 1;
257-
event_store.client.Empty all = 3;
256+
kurrent.client.StreamIdentifier stream_identifier = 1;
257+
kurrent.client.Empty all = 3;
258258
}
259259

260260
string group_name = 2;
@@ -269,8 +269,8 @@ message GetInfoReq {
269269

270270
message Options {
271271
oneof stream_option {
272-
event_store.client.StreamIdentifier stream_identifier = 1;
273-
event_store.client.Empty all = 2;
272+
kurrent.client.StreamIdentifier stream_identifier = 1;
273+
kurrent.client.Empty all = 2;
274274
}
275275

276276
string group_name = 3;
@@ -335,12 +335,12 @@ message ReplayParkedReq {
335335
message Options {
336336
string group_name = 1;
337337
oneof stream_option {
338-
event_store.client.StreamIdentifier stream_identifier = 2;
339-
event_store.client.Empty all = 3;
338+
kurrent.client.StreamIdentifier stream_identifier = 2;
339+
kurrent.client.Empty all = 3;
340340
}
341341
oneof stop_at_option {
342342
int64 stop_at = 4;
343-
event_store.client.Empty no_limit = 5;
343+
kurrent.client.Empty no_limit = 5;
344344
}
345345
}
346346
}
@@ -353,14 +353,14 @@ message ListReq {
353353

354354
message Options {
355355
oneof list_option {
356-
event_store.client.Empty list_all_subscriptions = 1;
356+
kurrent.client.Empty list_all_subscriptions = 1;
357357
StreamOption list_for_stream = 2;
358358
}
359359
}
360360
message StreamOption {
361361
oneof stream_option {
362-
event_store.client.StreamIdentifier stream = 1;
363-
event_store.client.Empty all = 2;
362+
kurrent.client.StreamIdentifier stream = 1;
363+
kurrent.client.Empty all = 2;
364364
}
365365
}
366366
}

‎db-client-java/src/main/proto/projectionmanagement.proto‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
syntax = "proto3";
2-
package event_store.client.projections;
2+
package kurrent.client.projections;
33
option java_package = "io.kurrent.dbclient.proto.projections";
44

55
import "google/protobuf/struct.proto";
@@ -15,15 +15,15 @@ service Projections {
1515
rpc Reset (ResetReq) returns (ResetResp);
1616
rpc State (StateReq) returns (StateResp);
1717
rpc Result (ResultReq) returns (ResultResp);
18-
rpc RestartSubsystem (event_store.client.Empty) returns (event_store.client.Empty);
18+
rpc RestartSubsystem (kurrent.client.Empty) returns (kurrent.client.Empty);
1919
}
2020

2121
message CreateReq {
2222
Options options = 1;
2323

2424
message Options {
2525
oneof mode {
26-
event_store.client.Empty one_time = 1;
26+
kurrent.client.Empty one_time = 1;
2727
Transient transient = 2;
2828
Continuous continuous = 3;
2929
}
@@ -50,7 +50,7 @@ message UpdateReq {
5050
string query = 2;
5151
oneof emit_option {
5252
bool emit_enabled = 3;
53-
event_store.client.Empty no_emit_options = 4;
53+
kurrent.client.Empty no_emit_options = 4;
5454
}
5555
}
5656
}
@@ -77,10 +77,10 @@ message StatisticsReq {
7777
message Options {
7878
oneof mode {
7979
string name = 1;
80-
event_store.client.Empty all = 2;
81-
event_store.client.Empty transient = 3;
82-
event_store.client.Empty continuous = 4;
83-
event_store.client.Empty one_time = 5;
80+
kurrent.client.Empty all = 2;
81+
kurrent.client.Empty transient = 3;
82+
kurrent.client.Empty continuous = 4;
83+
kurrent.client.Empty one_time = 5;
8484
}
8585
}
8686
}

‎db-client-java/src/main/proto/serverfeatures.proto‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
syntax = "proto3";
2-
package event_store.client.server_features;
2+
package kurrent.client.server_features;
33
option java_package = "io.kurrent.dbclient.proto.serverfeatures";
44
import "shared.proto";
55

66
service ServerFeatures {
7-
rpc GetSupportedMethods (event_store.client.Empty) returns (SupportedMethods);
7+
rpc GetSupportedMethods (kurrent.client.Empty) returns (SupportedMethods);
88
}
99

1010
message SupportedMethods {

‎db-client-java/src/main/proto/shared.proto‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
syntax = "proto3";
2-
package event_store.client;
2+
package kurrent.client;
33
option java_package = "io.kurrent.dbclient.proto.shared";
44
import "google/protobuf/empty.proto";
55

0 commit comments

Comments
 (0)