gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename proto field from DestroyTime to expire_at_sec

Browse Source 
For TTL volume converted into EC volume, this change may leave the volumes staying.
This commit is contained in:
chrislu
2024-10-24 21:35:11 -07:00
parent 1c2b10303a
commit ae5bd0667a
25 changed files with 2052 additions and 2578 deletions
Download Patch File Download Diff File Expand all files Collapse all files

128
weed/pb/mq_pb/mq.pb.go
View File

@@ -1,7 +1,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc v4.25.3
// protoc-gen-go v1.34.2
// protoc v5.28.1
// source: mq.proto
package mq_pb
@@ -3770,7 +3770,7 @@ func file_mq_proto_rawDescGZIP() []byte {
var file_mq_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_mq_proto_msgTypes = make([]protoimpl.MessageInfo, 54)
var file_mq_proto_goTypes = []interface{}{
var file_mq_proto_goTypes = []any{
(PartitionOffsetStartType)(0), // 0: messaging_pb.PartitionOffsetStartType
(*FindBrokerLeaderRequest)(nil), // 1: messaging_pb.FindBrokerLeaderRequest
(*FindBrokerLeaderResponse)(nil), // 2: messaging_pb.FindBrokerLeaderResponse
@@ -3925,7 +3925,7 @@ func file_mq_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_mq_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*FindBrokerLeaderRequest); i {
case 0:
return &v.state
@@ -3937,7 +3937,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*FindBrokerLeaderResponse); i {
case 0:
return &v.state
@@ -3949,7 +3949,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*Topic); i {
case 0:
return &v.state
@@ -3961,7 +3961,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*Partition); i {
case 0:
return &v.state
@@ -3973,7 +3973,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*Offset); i {
case 0:
return &v.state
@@ -3985,7 +3985,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*PartitionOffset); i {
case 0:
return &v.state
@@ -3997,7 +3997,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*BrokerStats); i {
case 0:
return &v.state
@@ -4009,7 +4009,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[7].Exporter = func(v any, i int) any {
switch v := v.(*TopicPartitionStats); i {
case 0:
return &v.state
@@ -4021,7 +4021,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[8].Exporter = func(v any, i int) any {
switch v := v.(*PublisherToPubBalancerRequest); i {
case 0:
return &v.state
@@ -4033,7 +4033,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[9].Exporter = func(v any, i int) any {
switch v := v.(*PublisherToPubBalancerResponse); i {
case 0:
return &v.state
@@ -4045,7 +4045,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[10].Exporter = func(v any, i int) any {
switch v := v.(*BalanceTopicsRequest); i {
case 0:
return &v.state
@@ -4057,7 +4057,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[11].Exporter = func(v any, i int) any {
switch v := v.(*BalanceTopicsResponse); i {
case 0:
return &v.state
@@ -4069,7 +4069,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[12].Exporter = func(v any, i int) any {
switch v := v.(*ConfigureTopicRequest); i {
case 0:
return &v.state
@@ -4081,7 +4081,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[13].Exporter = func(v any, i int) any {
switch v := v.(*ConfigureTopicResponse); i {
case 0:
return &v.state
@@ -4093,7 +4093,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[14].Exporter = func(v any, i int) any {
switch v := v.(*ListTopicsRequest); i {
case 0:
return &v.state
@@ -4105,7 +4105,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[15].Exporter = func(v any, i int) any {
switch v := v.(*ListTopicsResponse); i {
case 0:
return &v.state
@@ -4117,7 +4117,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[16].Exporter = func(v any, i int) any {
switch v := v.(*LookupTopicBrokersRequest); i {
case 0:
return &v.state
@@ -4129,7 +4129,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[17].Exporter = func(v any, i int) any {
switch v := v.(*LookupTopicBrokersResponse); i {
case 0:
return &v.state
@@ -4141,7 +4141,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[18].Exporter = func(v any, i int) any {
switch v := v.(*BrokerPartitionAssignment); i {
case 0:
return &v.state
@@ -4153,7 +4153,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[19].Exporter = func(v any, i int) any {
switch v := v.(*AssignTopicPartitionsRequest); i {
case 0:
return &v.state
@@ -4165,7 +4165,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[20].Exporter = func(v any, i int) any {
switch v := v.(*AssignTopicPartitionsResponse); i {
case 0:
return &v.state
@@ -4177,7 +4177,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[21].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorRequest); i {
case 0:
return &v.state
@@ -4189,7 +4189,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[22].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorResponse); i {
case 0:
return &v.state
@@ -4201,7 +4201,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[23].Exporter = func(v any, i int) any {
switch v := v.(*ControlMessage); i {
case 0:
return &v.state
@@ -4213,7 +4213,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[24].Exporter = func(v any, i int) any {
switch v := v.(*DataMessage); i {
case 0:
return &v.state
@@ -4225,7 +4225,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[25].Exporter = func(v any, i int) any {
switch v := v.(*PublishMessageRequest); i {
case 0:
return &v.state
@@ -4237,7 +4237,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[26].Exporter = func(v any, i int) any {
switch v := v.(*PublishMessageResponse); i {
case 0:
return &v.state
@@ -4249,7 +4249,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[27].Exporter = func(v any, i int) any {
switch v := v.(*PublishFollowMeRequest); i {
case 0:
return &v.state
@@ -4261,7 +4261,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[28].Exporter = func(v any, i int) any {
switch v := v.(*PublishFollowMeResponse); i {
case 0:
return &v.state
@@ -4273,7 +4273,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[29].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeMessageRequest); i {
case 0:
return &v.state
@@ -4285,7 +4285,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[30].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeMessageResponse); i {
case 0:
return &v.state
@@ -4297,7 +4297,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[31].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeFollowMeRequest); i {
case 0:
return &v.state
@@ -4309,7 +4309,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[32].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeFollowMeResponse); i {
case 0:
return &v.state
@@ -4321,7 +4321,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[33].Exporter = func(v any, i int) any {
switch v := v.(*ClosePublishersRequest); i {
case 0:
return &v.state
@@ -4333,7 +4333,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[34].Exporter = func(v any, i int) any {
switch v := v.(*ClosePublishersResponse); i {
case 0:
return &v.state
@@ -4345,7 +4345,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[35].Exporter = func(v any, i int) any {
switch v := v.(*CloseSubscribersRequest); i {
case 0:
return &v.state
@@ -4357,7 +4357,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[36].Exporter = func(v any, i int) any {
switch v := v.(*CloseSubscribersResponse); i {
case 0:
return &v.state
@@ -4369,7 +4369,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[38].Exporter = func(v any, i int) any {
switch v := v.(*PublisherToPubBalancerRequest_InitMessage); i {
case 0:
return &v.state
@@ -4381,7 +4381,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[39].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorRequest_InitMessage); i {
case 0:
return &v.state
@@ -4393,7 +4393,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[40].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[40].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorRequest_AckUnAssignmentMessage); i {
case 0:
return &v.state
@@ -4405,7 +4405,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[41].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorRequest_AckAssignmentMessage); i {
case 0:
return &v.state
@@ -4417,7 +4417,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[42].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[42].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorResponse_Assignment); i {
case 0:
return &v.state
@@ -4429,7 +4429,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[43].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[43].Exporter = func(v any, i int) any {
switch v := v.(*SubscriberToSubCoordinatorResponse_UnAssignment); i {
case 0:
return &v.state
@@ -4441,7 +4441,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[44].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[44].Exporter = func(v any, i int) any {
switch v := v.(*PublishMessageRequest_InitMessage); i {
case 0:
return &v.state
@@ -4453,7 +4453,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[45].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[45].Exporter = func(v any, i int) any {
switch v := v.(*PublishFollowMeRequest_InitMessage); i {
case 0:
return &v.state
@@ -4465,7 +4465,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[46].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[46].Exporter = func(v any, i int) any {
switch v := v.(*PublishFollowMeRequest_FlushMessage); i {
case 0:
return &v.state
@@ -4477,7 +4477,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[47].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[47].Exporter = func(v any, i int) any {
switch v := v.(*PublishFollowMeRequest_CloseMessage); i {
case 0:
return &v.state
@@ -4489,7 +4489,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[48].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeMessageRequest_InitMessage); i {
case 0:
return &v.state
@@ -4501,7 +4501,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[49].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[49].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeMessageRequest_AckMessage); i {
case 0:
return &v.state
@@ -4513,7 +4513,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[50].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[50].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeMessageResponse_SubscribeCtrlMessage); i {
case 0:
return &v.state
@@ -4525,7 +4525,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[51].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[51].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeFollowMeRequest_InitMessage); i {
case 0:
return &v.state
@@ -4537,7 +4537,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[52].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[52].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeFollowMeRequest_AckMessage); i {
case 0:
return &v.state
@@ -4549,7 +4549,7 @@ func file_mq_proto_init() {
return nil
}
}
file_mq_proto_msgTypes[53].Exporter = func(v interface{}, i int) interface{} {
file_mq_proto_msgTypes[53].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeFollowMeRequest_CloseMessage); i {
case 0:
return &v.state
@@ -4562,38 +4562,38 @@ func file_mq_proto_init() {
}
}
}
file_mq_proto_msgTypes[8].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[8].OneofWrappers = []any{
(*PublisherToPubBalancerRequest_Init)(nil),
(*PublisherToPubBalancerRequest_Stats)(nil),
}
file_mq_proto_msgTypes[21].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[21].OneofWrappers = []any{
(*SubscriberToSubCoordinatorRequest_Init)(nil),
(*SubscriberToSubCoordinatorRequest_AckAssignment)(nil),
(*SubscriberToSubCoordinatorRequest_AckUnAssignment)(nil),
}
file_mq_proto_msgTypes[22].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[22].OneofWrappers = []any{
(*SubscriberToSubCoordinatorResponse_Assignment_)(nil),
(*SubscriberToSubCoordinatorResponse_UnAssignment_)(nil),
}
file_mq_proto_msgTypes[25].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[25].OneofWrappers = []any{
(*PublishMessageRequest_Init)(nil),
(*PublishMessageRequest_Data)(nil),
}
file_mq_proto_msgTypes[27].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[27].OneofWrappers = []any{
(*PublishFollowMeRequest_Init)(nil),
(*PublishFollowMeRequest_Data)(nil),
(*PublishFollowMeRequest_Flush)(nil),
(*PublishFollowMeRequest_Close)(nil),
}
file_mq_proto_msgTypes[29].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[29].OneofWrappers = []any{
(*SubscribeMessageRequest_Init)(nil),
(*SubscribeMessageRequest_Ack)(nil),
}
file_mq_proto_msgTypes[30].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[30].OneofWrappers = []any{
(*SubscribeMessageResponse_Ctrl)(nil),
(*SubscribeMessageResponse_Data)(nil),
}
file_mq_proto_msgTypes[31].OneofWrappers = []interface{}{
file_mq_proto_msgTypes[31].OneofWrappers = []any{
(*SubscribeFollowMeRequest_Init)(nil),
(*SubscribeFollowMeRequest_Ack)(nil),
(*SubscribeFollowMeRequest_Close)(nil),

420
weed/pb/mq_pb/mq_grpc.pb.go
View File

@@ -1,7 +1,7 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v4.25.3
// - protoc-gen-go-grpc v1.5.1
// - protoc v5.28.1
// source: mq.proto
package mq_pb
@@ -15,8 +15,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9
const (
SeaweedMessaging_FindBrokerLeader_FullMethodName = "/messaging_pb.SeaweedMessaging/FindBrokerLeader"
@@ -42,7 +42,7 @@ type SeaweedMessagingClient interface {
// control plane
FindBrokerLeader(ctx context.Context, in *FindBrokerLeaderRequest, opts ...grpc.CallOption) (*FindBrokerLeaderResponse, error)
// control plane for balancer
PublisherToPubBalancer(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublisherToPubBalancerClient, error)
PublisherToPubBalancer(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse], error)
BalanceTopics(ctx context.Context, in *BalanceTopicsRequest, opts ...grpc.CallOption) (*BalanceTopicsResponse, error)
// control plane for topic partitions
ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
@@ -53,13 +53,13 @@ type SeaweedMessagingClient interface {
ClosePublishers(ctx context.Context, in *ClosePublishersRequest, opts ...grpc.CallOption) (*ClosePublishersResponse, error)
CloseSubscribers(ctx context.Context, in *CloseSubscribersRequest, opts ...grpc.CallOption) (*CloseSubscribersResponse, error)
// subscriber connects to broker balancer, which coordinates with the subscribers
SubscriberToSubCoordinator(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscriberToSubCoordinatorClient, error)
SubscriberToSubCoordinator(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse], error)
// data plane for each topic partition
PublishMessage(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishMessageClient, error)
SubscribeMessage(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeMessageClient, error)
PublishMessage(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishMessageRequest, PublishMessageResponse], error)
SubscribeMessage(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeMessageRequest, SubscribeMessageResponse], error)
// The lead broker asks a follower broker to follow itself
PublishFollowMe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishFollowMeClient, error)
SubscribeFollowMe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeFollowMeClient, error)
PublishFollowMe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishFollowMeRequest, PublishFollowMeResponse], error)
SubscribeFollowMe(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SubscribeFollowMeRequest, SubscribeFollowMeResponse], error)
}
type seaweedMessagingClient struct {
@@ -71,48 +71,32 @@ func NewSeaweedMessagingClient(cc grpc.ClientConnInterface) SeaweedMessagingClie
}
func (c *seaweedMessagingClient) FindBrokerLeader(ctx context.Context, in *FindBrokerLeaderRequest, opts ...grpc.CallOption) (*FindBrokerLeaderResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(FindBrokerLeaderResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_FindBrokerLeader_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_FindBrokerLeader_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *seaweedMessagingClient) PublisherToPubBalancer(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublisherToPubBalancerClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[0], SeaweedMessaging_PublisherToPubBalancer_FullMethodName, opts...)
func (c *seaweedMessagingClient) PublisherToPubBalancer(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[0], SeaweedMessaging_PublisherToPubBalancer_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingPublisherToPubBalancerClient{stream}
x := &grpc.GenericClientStream[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_PublisherToPubBalancerClient interface {
Send(*PublisherToPubBalancerRequest) error
Recv() (*PublisherToPubBalancerResponse, error)
grpc.ClientStream
}
type seaweedMessagingPublisherToPubBalancerClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingPublisherToPubBalancerClient) Send(m *PublisherToPubBalancerRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingPublisherToPubBalancerClient) Recv() (*PublisherToPubBalancerResponse, error) {
m := new(PublisherToPubBalancerResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublisherToPubBalancerClient = grpc.BidiStreamingClient[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]
func (c *seaweedMessagingClient) BalanceTopics(ctx context.Context, in *BalanceTopicsRequest, opts ...grpc.CallOption) (*BalanceTopicsResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(BalanceTopicsResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_BalanceTopics_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_BalanceTopics_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -120,8 +104,9 @@ func (c *seaweedMessagingClient) BalanceTopics(ctx context.Context, in *BalanceT
}
func (c *seaweedMessagingClient) ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ListTopicsResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_ListTopics_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_ListTopics_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -129,8 +114,9 @@ func (c *seaweedMessagingClient) ListTopics(ctx context.Context, in *ListTopicsR
}
func (c *seaweedMessagingClient) ConfigureTopic(ctx context.Context, in *ConfigureTopicRequest, opts ...grpc.CallOption) (*ConfigureTopicResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ConfigureTopicResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_ConfigureTopic_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_ConfigureTopic_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -138,8 +124,9 @@ func (c *seaweedMessagingClient) ConfigureTopic(ctx context.Context, in *Configu
}
func (c *seaweedMessagingClient) LookupTopicBrokers(ctx context.Context, in *LookupTopicBrokersRequest, opts ...grpc.CallOption) (*LookupTopicBrokersResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(LookupTopicBrokersResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_LookupTopicBrokers_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_LookupTopicBrokers_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -147,8 +134,9 @@ func (c *seaweedMessagingClient) LookupTopicBrokers(ctx context.Context, in *Loo
}
func (c *seaweedMessagingClient) AssignTopicPartitions(ctx context.Context, in *AssignTopicPartitionsRequest, opts ...grpc.CallOption) (*AssignTopicPartitionsResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AssignTopicPartitionsResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_AssignTopicPartitions_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_AssignTopicPartitions_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -156,8 +144,9 @@ func (c *seaweedMessagingClient) AssignTopicPartitions(ctx context.Context, in *
}
func (c *seaweedMessagingClient) ClosePublishers(ctx context.Context, in *ClosePublishersRequest, opts ...grpc.CallOption) (*ClosePublishersResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ClosePublishersResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_ClosePublishers_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_ClosePublishers_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
@@ -165,180 +154,88 @@ func (c *seaweedMessagingClient) ClosePublishers(ctx context.Context, in *CloseP
}
func (c *seaweedMessagingClient) CloseSubscribers(ctx context.Context, in *CloseSubscribersRequest, opts ...grpc.CallOption) (*CloseSubscribersResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CloseSubscribersResponse)
err := c.cc.Invoke(ctx, SeaweedMessaging_CloseSubscribers_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, SeaweedMessaging_CloseSubscribers_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *seaweedMessagingClient) SubscriberToSubCoordinator(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscriberToSubCoordinatorClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[1], SeaweedMessaging_SubscriberToSubCoordinator_FullMethodName, opts...)
func (c *seaweedMessagingClient) SubscriberToSubCoordinator(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[1], SeaweedMessaging_SubscriberToSubCoordinator_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingSubscriberToSubCoordinatorClient{stream}
x := &grpc.GenericClientStream[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_SubscriberToSubCoordinatorClient interface {
Send(*SubscriberToSubCoordinatorRequest) error
Recv() (*SubscriberToSubCoordinatorResponse, error)
grpc.ClientStream
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscriberToSubCoordinatorClient = grpc.BidiStreamingClient[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]
type seaweedMessagingSubscriberToSubCoordinatorClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingSubscriberToSubCoordinatorClient) Send(m *SubscriberToSubCoordinatorRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingSubscriberToSubCoordinatorClient) Recv() (*SubscriberToSubCoordinatorResponse, error) {
m := new(SubscriberToSubCoordinatorResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *seaweedMessagingClient) PublishMessage(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishMessageClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[2], SeaweedMessaging_PublishMessage_FullMethodName, opts...)
func (c *seaweedMessagingClient) PublishMessage(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishMessageRequest, PublishMessageResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[2], SeaweedMessaging_PublishMessage_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingPublishMessageClient{stream}
x := &grpc.GenericClientStream[PublishMessageRequest, PublishMessageResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_PublishMessageClient interface {
Send(*PublishMessageRequest) error
Recv() (*PublishMessageResponse, error)
grpc.ClientStream
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublishMessageClient = grpc.BidiStreamingClient[PublishMessageRequest, PublishMessageResponse]
type seaweedMessagingPublishMessageClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingPublishMessageClient) Send(m *PublishMessageRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingPublishMessageClient) Recv() (*PublishMessageResponse, error) {
m := new(PublishMessageResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *seaweedMessagingClient) SubscribeMessage(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeMessageClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[3], SeaweedMessaging_SubscribeMessage_FullMethodName, opts...)
func (c *seaweedMessagingClient) SubscribeMessage(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeMessageRequest, SubscribeMessageResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[3], SeaweedMessaging_SubscribeMessage_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingSubscribeMessageClient{stream}
x := &grpc.GenericClientStream[SubscribeMessageRequest, SubscribeMessageResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_SubscribeMessageClient interface {
Send(*SubscribeMessageRequest) error
Recv() (*SubscribeMessageResponse, error)
grpc.ClientStream
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscribeMessageClient = grpc.BidiStreamingClient[SubscribeMessageRequest, SubscribeMessageResponse]
type seaweedMessagingSubscribeMessageClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingSubscribeMessageClient) Send(m *SubscribeMessageRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingSubscribeMessageClient) Recv() (*SubscribeMessageResponse, error) {
m := new(SubscribeMessageResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *seaweedMessagingClient) PublishFollowMe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishFollowMeClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[4], SeaweedMessaging_PublishFollowMe_FullMethodName, opts...)
func (c *seaweedMessagingClient) PublishFollowMe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishFollowMeRequest, PublishFollowMeResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[4], SeaweedMessaging_PublishFollowMe_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingPublishFollowMeClient{stream}
x := &grpc.GenericClientStream[PublishFollowMeRequest, PublishFollowMeResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_PublishFollowMeClient interface {
Send(*PublishFollowMeRequest) error
Recv() (*PublishFollowMeResponse, error)
grpc.ClientStream
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublishFollowMeClient = grpc.BidiStreamingClient[PublishFollowMeRequest, PublishFollowMeResponse]
type seaweedMessagingPublishFollowMeClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingPublishFollowMeClient) Send(m *PublishFollowMeRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingPublishFollowMeClient) Recv() (*PublishFollowMeResponse, error) {
m := new(PublishFollowMeResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *seaweedMessagingClient) SubscribeFollowMe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeFollowMeClient, error) {
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[5], SeaweedMessaging_SubscribeFollowMe_FullMethodName, opts...)
func (c *seaweedMessagingClient) SubscribeFollowMe(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SubscribeFollowMeRequest, SubscribeFollowMeResponse], error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[5], SeaweedMessaging_SubscribeFollowMe_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &seaweedMessagingSubscribeFollowMeClient{stream}
x := &grpc.GenericClientStream[SubscribeFollowMeRequest, SubscribeFollowMeResponse]{ClientStream: stream}
return x, nil
}
type SeaweedMessaging_SubscribeFollowMeClient interface {
Send(*SubscribeFollowMeRequest) error
CloseAndRecv() (*SubscribeFollowMeResponse, error)
grpc.ClientStream
}
type seaweedMessagingSubscribeFollowMeClient struct {
grpc.ClientStream
}
func (x *seaweedMessagingSubscribeFollowMeClient) Send(m *SubscribeFollowMeRequest) error {
return x.ClientStream.SendMsg(m)
}
func (x *seaweedMessagingSubscribeFollowMeClient) CloseAndRecv() (*SubscribeFollowMeResponse, error) {
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
m := new(SubscribeFollowMeResponse)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscribeFollowMeClient = grpc.ClientStreamingClient[SubscribeFollowMeRequest, SubscribeFollowMeResponse]
// SeaweedMessagingServer is the server API for SeaweedMessaging service.
// All implementations must embed UnimplementedSeaweedMessagingServer
// for forward compatibility
// for forward compatibility.
type SeaweedMessagingServer interface {
// control plane
FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error)
// control plane for balancer
PublisherToPubBalancer(SeaweedMessaging_PublisherToPubBalancerServer) error
PublisherToPubBalancer(grpc.BidiStreamingServer[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]) error
BalanceTopics(context.Context, *BalanceTopicsRequest) (*BalanceTopicsResponse, error)
// control plane for topic partitions
ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
@@ -349,24 +246,27 @@ type SeaweedMessagingServer interface {
ClosePublishers(context.Context, *ClosePublishersRequest) (*ClosePublishersResponse, error)
CloseSubscribers(context.Context, *CloseSubscribersRequest) (*CloseSubscribersResponse, error)
// subscriber connects to broker balancer, which coordinates with the subscribers
SubscriberToSubCoordinator(SeaweedMessaging_SubscriberToSubCoordinatorServer) error
SubscriberToSubCoordinator(grpc.BidiStreamingServer[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]) error
// data plane for each topic partition
PublishMessage(SeaweedMessaging_PublishMessageServer) error
SubscribeMessage(SeaweedMessaging_SubscribeMessageServer) error
PublishMessage(grpc.BidiStreamingServer[PublishMessageRequest, PublishMessageResponse]) error
SubscribeMessage(grpc.BidiStreamingServer[SubscribeMessageRequest, SubscribeMessageResponse]) error
// The lead broker asks a follower broker to follow itself
PublishFollowMe(SeaweedMessaging_PublishFollowMeServer) error
SubscribeFollowMe(SeaweedMessaging_SubscribeFollowMeServer) error
PublishFollowMe(grpc.BidiStreamingServer[PublishFollowMeRequest, PublishFollowMeResponse]) error
SubscribeFollowMe(grpc.ClientStreamingServer[SubscribeFollowMeRequest, SubscribeFollowMeResponse]) error
mustEmbedUnimplementedSeaweedMessagingServer()
}
// UnimplementedSeaweedMessagingServer must be embedded to have forward compatible implementations.
type UnimplementedSeaweedMessagingServer struct {
}
// UnimplementedSeaweedMessagingServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedSeaweedMessagingServer struct{}
func (UnimplementedSeaweedMessagingServer) FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindBrokerLeader not implemented")
}
func (UnimplementedSeaweedMessagingServer) PublisherToPubBalancer(SeaweedMessaging_PublisherToPubBalancerServer) error {
func (UnimplementedSeaweedMessagingServer) PublisherToPubBalancer(grpc.BidiStreamingServer[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]) error {
return status.Errorf(codes.Unimplemented, "method PublisherToPubBalancer not implemented")
}
func (UnimplementedSeaweedMessagingServer) BalanceTopics(context.Context, *BalanceTopicsRequest) (*BalanceTopicsResponse, error) {
@@ -390,22 +290,23 @@ func (UnimplementedSeaweedMessagingServer) ClosePublishers(context.Context, *Clo
func (UnimplementedSeaweedMessagingServer) CloseSubscribers(context.Context, *CloseSubscribersRequest) (*CloseSubscribersResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method CloseSubscribers not implemented")
}
func (UnimplementedSeaweedMessagingServer) SubscriberToSubCoordinator(SeaweedMessaging_SubscriberToSubCoordinatorServer) error {
func (UnimplementedSeaweedMessagingServer) SubscriberToSubCoordinator(grpc.BidiStreamingServer[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]) error {
return status.Errorf(codes.Unimplemented, "method SubscriberToSubCoordinator not implemented")
}
func (UnimplementedSeaweedMessagingServer) PublishMessage(SeaweedMessaging_PublishMessageServer) error {
func (UnimplementedSeaweedMessagingServer) PublishMessage(grpc.BidiStreamingServer[PublishMessageRequest, PublishMessageResponse]) error {
return status.Errorf(codes.Unimplemented, "method PublishMessage not implemented")
}
func (UnimplementedSeaweedMessagingServer) SubscribeMessage(SeaweedMessaging_SubscribeMessageServer) error {
func (UnimplementedSeaweedMessagingServer) SubscribeMessage(grpc.BidiStreamingServer[SubscribeMessageRequest, SubscribeMessageResponse]) error {
return status.Errorf(codes.Unimplemented, "method SubscribeMessage not implemented")
}
func (UnimplementedSeaweedMessagingServer) PublishFollowMe(SeaweedMessaging_PublishFollowMeServer) error {
func (UnimplementedSeaweedMessagingServer) PublishFollowMe(grpc.BidiStreamingServer[PublishFollowMeRequest, PublishFollowMeResponse]) error {
return status.Errorf(codes.Unimplemented, "method PublishFollowMe not implemented")
}
func (UnimplementedSeaweedMessagingServer) SubscribeFollowMe(SeaweedMessaging_SubscribeFollowMeServer) error {
func (UnimplementedSeaweedMessagingServer) SubscribeFollowMe(grpc.ClientStreamingServer[SubscribeFollowMeRequest, SubscribeFollowMeResponse]) error {
return status.Errorf(codes.Unimplemented, "method SubscribeFollowMe not implemented")
}
func (UnimplementedSeaweedMessagingServer) mustEmbedUnimplementedSeaweedMessagingServer() {}
func (UnimplementedSeaweedMessagingServer) testEmbeddedByValue() {}
// UnsafeSeaweedMessagingServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to SeaweedMessagingServer will
@@ -415,6 +316,13 @@ type UnsafeSeaweedMessagingServer interface {
}
func RegisterSeaweedMessagingServer(s grpc.ServiceRegistrar, srv SeaweedMessagingServer) {
// If the following call pancis, it indicates UnimplementedSeaweedMessagingServer was
// embedded by pointer and is nil. This will cause panics if an
// unimplemented method is ever invoked, so we test this at initialization
// time to prevent it from happening at runtime later due to I/O.
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
t.testEmbeddedByValue()
}
s.RegisterService(&SeaweedMessaging_ServiceDesc, srv)
}
@@ -437,30 +345,11 @@ func _SeaweedMessaging_FindBrokerLeader_Handler(srv interface{}, ctx context.Con
}
func _SeaweedMessaging_PublisherToPubBalancer_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).PublisherToPubBalancer(&seaweedMessagingPublisherToPubBalancerServer{stream})
return srv.(SeaweedMessagingServer).PublisherToPubBalancer(&grpc.GenericServerStream[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]{ServerStream: stream})
}
type SeaweedMessaging_PublisherToPubBalancerServer interface {
Send(*PublisherToPubBalancerResponse) error
Recv() (*PublisherToPubBalancerRequest, error)
grpc.ServerStream
}
type seaweedMessagingPublisherToPubBalancerServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingPublisherToPubBalancerServer) Send(m *PublisherToPubBalancerResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingPublisherToPubBalancerServer) Recv() (*PublisherToPubBalancerRequest, error) {
m := new(PublisherToPubBalancerRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublisherToPubBalancerServer = grpc.BidiStreamingServer[PublisherToPubBalancerRequest, PublisherToPubBalancerResponse]
func _SeaweedMessaging_BalanceTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BalanceTopicsRequest)
@@ -589,134 +478,39 @@ func _SeaweedMessaging_CloseSubscribers_Handler(srv interface{}, ctx context.Con
}
func _SeaweedMessaging_SubscriberToSubCoordinator_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).SubscriberToSubCoordinator(&seaweedMessagingSubscriberToSubCoordinatorServer{stream})
return srv.(SeaweedMessagingServer).SubscriberToSubCoordinator(&grpc.GenericServerStream[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]{ServerStream: stream})
}
type SeaweedMessaging_SubscriberToSubCoordinatorServer interface {
Send(*SubscriberToSubCoordinatorResponse) error
Recv() (*SubscriberToSubCoordinatorRequest, error)
grpc.ServerStream
}
type seaweedMessagingSubscriberToSubCoordinatorServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingSubscriberToSubCoordinatorServer) Send(m *SubscriberToSubCoordinatorResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingSubscriberToSubCoordinatorServer) Recv() (*SubscriberToSubCoordinatorRequest, error) {
m := new(SubscriberToSubCoordinatorRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscriberToSubCoordinatorServer = grpc.BidiStreamingServer[SubscriberToSubCoordinatorRequest, SubscriberToSubCoordinatorResponse]
func _SeaweedMessaging_PublishMessage_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).PublishMessage(&seaweedMessagingPublishMessageServer{stream})
return srv.(SeaweedMessagingServer).PublishMessage(&grpc.GenericServerStream[PublishMessageRequest, PublishMessageResponse]{ServerStream: stream})
}
type SeaweedMessaging_PublishMessageServer interface {
Send(*PublishMessageResponse) error
Recv() (*PublishMessageRequest, error)
grpc.ServerStream
}
type seaweedMessagingPublishMessageServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingPublishMessageServer) Send(m *PublishMessageResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingPublishMessageServer) Recv() (*PublishMessageRequest, error) {
m := new(PublishMessageRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublishMessageServer = grpc.BidiStreamingServer[PublishMessageRequest, PublishMessageResponse]
func _SeaweedMessaging_SubscribeMessage_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).SubscribeMessage(&seaweedMessagingSubscribeMessageServer{stream})
return srv.(SeaweedMessagingServer).SubscribeMessage(&grpc.GenericServerStream[SubscribeMessageRequest, SubscribeMessageResponse]{ServerStream: stream})
}
type SeaweedMessaging_SubscribeMessageServer interface {
Send(*SubscribeMessageResponse) error
Recv() (*SubscribeMessageRequest, error)
grpc.ServerStream
}
type seaweedMessagingSubscribeMessageServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingSubscribeMessageServer) Send(m *SubscribeMessageResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingSubscribeMessageServer) Recv() (*SubscribeMessageRequest, error) {
m := new(SubscribeMessageRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscribeMessageServer = grpc.BidiStreamingServer[SubscribeMessageRequest, SubscribeMessageResponse]
func _SeaweedMessaging_PublishFollowMe_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).PublishFollowMe(&seaweedMessagingPublishFollowMeServer{stream})
return srv.(SeaweedMessagingServer).PublishFollowMe(&grpc.GenericServerStream[PublishFollowMeRequest, PublishFollowMeResponse]{ServerStream: stream})
}
type SeaweedMessaging_PublishFollowMeServer interface {
Send(*PublishFollowMeResponse) error
Recv() (*PublishFollowMeRequest, error)
grpc.ServerStream
}
type seaweedMessagingPublishFollowMeServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingPublishFollowMeServer) Send(m *PublishFollowMeResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingPublishFollowMeServer) Recv() (*PublishFollowMeRequest, error) {
m := new(PublishFollowMeRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_PublishFollowMeServer = grpc.BidiStreamingServer[PublishFollowMeRequest, PublishFollowMeResponse]
func _SeaweedMessaging_SubscribeFollowMe_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(SeaweedMessagingServer).SubscribeFollowMe(&seaweedMessagingSubscribeFollowMeServer{stream})
return srv.(SeaweedMessagingServer).SubscribeFollowMe(&grpc.GenericServerStream[SubscribeFollowMeRequest, SubscribeFollowMeResponse]{ServerStream: stream})
}
type SeaweedMessaging_SubscribeFollowMeServer interface {
SendAndClose(*SubscribeFollowMeResponse) error
Recv() (*SubscribeFollowMeRequest, error)
grpc.ServerStream
}
type seaweedMessagingSubscribeFollowMeServer struct {
grpc.ServerStream
}
func (x *seaweedMessagingSubscribeFollowMeServer) SendAndClose(m *SubscribeFollowMeResponse) error {
return x.ServerStream.SendMsg(m)
}
func (x *seaweedMessagingSubscribeFollowMeServer) Recv() (*SubscribeFollowMeRequest, error) {
m := new(SubscribeFollowMeRequest)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SeaweedMessaging_SubscribeFollowMeServer = grpc.ClientStreamingServer[SubscribeFollowMeRequest, SubscribeFollowMeResponse]
// SeaweedMessaging_ServiceDesc is the grpc.ServiceDesc for SeaweedMessaging service.
// It's only intended for direct use with grpc.RegisterService,