chrislu
2 months ago
9 changed files with 2872 additions and 891 deletions
-
5weed/pb/Makefile
-
128weed/pb/mq_agent.proto
-
1550weed/pb/mq_agent_pb/mq_agent.pb.go
-
304weed/pb/mq_agent_pb/mq_agent_grpc.pb.go
-
5weed/pb/mq_broker.proto
-
1493weed/pb/mq_pb/mq_broker.pb.go
-
4weed/pb/mq_pb/mq_broker_grpc.pb.go
-
0weed/pb/mq_schema.proto
-
274weed/pb/schema_pb/mq_schema.pb.go
@ -0,0 +1,128 @@ |
|||
syntax = "proto3"; |
|||
|
|||
package messaging_pb; |
|||
|
|||
import "mq_schema.proto"; |
|||
|
|||
option go_package = "github.com/seaweedfs/seaweedfs/weed/pb/mq_agent_pb"; |
|||
option java_package = "seaweedfs.mq_agent"; |
|||
option java_outer_classname = "MessageQueueAgentProto"; |
|||
|
|||
////////////////////////////////////////////////// |
|||
|
|||
service SeaweedMessagingAgent { |
|||
|
|||
// Publishing |
|||
rpc StartPublishSession (StartPublishSessionRequest) returns (StartPublishSessionResponse) { |
|||
} |
|||
rpc ClosePublishSession (ClosePublishSessionRequest) returns (ClosePublishSessionResponse) { |
|||
} |
|||
rpc PublishRecord (stream PublishRecordRequest) returns (stream PublishRecordResponse) { |
|||
} |
|||
|
|||
// Subscribing |
|||
rpc StartSubscribeSession (StartSubscribeSessionRequest) returns (StartSubscribeSessionResponse) { |
|||
} |
|||
rpc CloseSubscribeSession (CloseSubscribeSessionRequest) returns (CloseSubscribeSessionResponse) { |
|||
} |
|||
rpc SubscribeRecord (stream SubscribeRecordRequest) returns (stream SubscribeRecordResponse) { |
|||
} |
|||
|
|||
} |
|||
|
|||
////////////////////////////////////////////////// |
|||
|
|||
message Topic { |
|||
string namespace = 1; |
|||
string name = 2; |
|||
} |
|||
message Partition { |
|||
int32 ring_size = 1; |
|||
int32 range_start = 2; |
|||
int32 range_stop = 3; |
|||
int64 unix_time_ns = 4; |
|||
} |
|||
|
|||
message Offset { |
|||
Topic topic = 1; |
|||
repeated PartitionOffset partition_offsets = 2; |
|||
} |
|||
|
|||
enum PartitionOffsetStartType { |
|||
EARLIEST = 0; |
|||
EARLIEST_IN_MEMORY = 1; |
|||
LATEST = 2; |
|||
} |
|||
|
|||
message PartitionOffset { |
|||
Partition partition = 1; |
|||
int64 start_ts_ns = 2; |
|||
int64 stop_ts_ns = 3; |
|||
PartitionOffsetStartType start_type = 4; |
|||
} |
|||
|
|||
////////////////////////////////////////////////// |
|||
message StartPublishSessionRequest { |
|||
Topic topic = 1; |
|||
int32 partition_count = 2; |
|||
schema_pb.RecordType record_type = 3; |
|||
string publisher_name = 4; |
|||
} |
|||
message StartPublishSessionResponse { |
|||
string error = 1; |
|||
int64 session_id = 2; |
|||
} |
|||
message ClosePublishSessionRequest { |
|||
int64 session_id = 1; |
|||
} |
|||
message ClosePublishSessionResponse { |
|||
string error = 1; |
|||
} |
|||
|
|||
////////////////////////////////////////////////// |
|||
message PublishRecordRequest { |
|||
int64 session_id = 1; // session_id is required for the first record |
|||
bytes key = 2; |
|||
schema_pb.RecordValue value = 3; |
|||
int64 ts_ns = 4; |
|||
} |
|||
message PublishRecordResponse { |
|||
int64 ack_sequence = 1; |
|||
string error = 2; |
|||
} |
|||
////////////////////////////////////////////////// |
|||
message StartSubscribeSessionRequest { |
|||
string consumer_group = 1; |
|||
string consumer_id = 2; |
|||
string client_id = 3; |
|||
Topic topic = 4; |
|||
PartitionOffset partition_offset = 5; |
|||
string filter = 6; |
|||
int32 concurrency = 8; |
|||
} |
|||
message StartSubscribeSessionResponse { |
|||
string error = 1; |
|||
int64 session_id = 2; |
|||
} |
|||
message CloseSubscribeSessionRequest { |
|||
int64 session_id = 1; |
|||
} |
|||
message CloseSubscribeSessionResponse { |
|||
string error = 1; |
|||
} |
|||
////////////////////////////////////////////////// |
|||
message SubscribeRecordRequest { |
|||
int64 session_id = 1; // session_id is required for the first record |
|||
int64 ack_sequence = 2; |
|||
bytes ack_key = 3; |
|||
} |
|||
message SubscribeRecordResponse { |
|||
int64 sequence = 1; |
|||
bytes key = 2; |
|||
schema_pb.RecordValue value = 3; |
|||
int64 ts_ns = 4; |
|||
string error = 5; |
|||
bool is_end_of_stream = 6; |
|||
bool is_end_of_topic = 7; |
|||
} |
|||
////////////////////////////////////////////////// |
1550
weed/pb/mq_agent_pb/mq_agent.pb.go
File diff suppressed because it is too large
View File
File diff suppressed because it is too large
View File
@ -0,0 +1,304 @@ |
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|||
// versions:
|
|||
// - protoc-gen-go-grpc v1.5.1
|
|||
// - protoc v5.28.1
|
|||
// source: mq_agent.proto
|
|||
|
|||
package mq_agent_pb |
|||
|
|||
import ( |
|||
context "context" |
|||
grpc "google.golang.org/grpc" |
|||
codes "google.golang.org/grpc/codes" |
|||
status "google.golang.org/grpc/status" |
|||
) |
|||
|
|||
// 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.64.0 or later.
|
|||
const _ = grpc.SupportPackageIsVersion9 |
|||
|
|||
const ( |
|||
SeaweedMessagingAgent_StartPublishSession_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/StartPublishSession" |
|||
SeaweedMessagingAgent_ClosePublishSession_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/ClosePublishSession" |
|||
SeaweedMessagingAgent_PublishRecord_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/PublishRecord" |
|||
SeaweedMessagingAgent_StartSubscribeSession_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/StartSubscribeSession" |
|||
SeaweedMessagingAgent_CloseSubscribeSession_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/CloseSubscribeSession" |
|||
SeaweedMessagingAgent_SubscribeRecord_FullMethodName = "/messaging_pb.SeaweedMessagingAgent/SubscribeRecord" |
|||
) |
|||
|
|||
// SeaweedMessagingAgentClient is the client API for SeaweedMessagingAgent service.
|
|||
//
|
|||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
|||
type SeaweedMessagingAgentClient interface { |
|||
// Publishing
|
|||
StartPublishSession(ctx context.Context, in *StartPublishSessionRequest, opts ...grpc.CallOption) (*StartPublishSessionResponse, error) |
|||
ClosePublishSession(ctx context.Context, in *ClosePublishSessionRequest, opts ...grpc.CallOption) (*ClosePublishSessionResponse, error) |
|||
PublishRecord(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishRecordRequest, PublishRecordResponse], error) |
|||
// Subscribing
|
|||
StartSubscribeSession(ctx context.Context, in *StartSubscribeSessionRequest, opts ...grpc.CallOption) (*StartSubscribeSessionResponse, error) |
|||
CloseSubscribeSession(ctx context.Context, in *CloseSubscribeSessionRequest, opts ...grpc.CallOption) (*CloseSubscribeSessionResponse, error) |
|||
SubscribeRecord(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeRecordRequest, SubscribeRecordResponse], error) |
|||
} |
|||
|
|||
type seaweedMessagingAgentClient struct { |
|||
cc grpc.ClientConnInterface |
|||
} |
|||
|
|||
func NewSeaweedMessagingAgentClient(cc grpc.ClientConnInterface) SeaweedMessagingAgentClient { |
|||
return &seaweedMessagingAgentClient{cc} |
|||
} |
|||
|
|||
func (c *seaweedMessagingAgentClient) StartPublishSession(ctx context.Context, in *StartPublishSessionRequest, opts ...grpc.CallOption) (*StartPublishSessionResponse, error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
out := new(StartPublishSessionResponse) |
|||
err := c.cc.Invoke(ctx, SeaweedMessagingAgent_StartPublishSession_FullMethodName, in, out, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingAgentClient) ClosePublishSession(ctx context.Context, in *ClosePublishSessionRequest, opts ...grpc.CallOption) (*ClosePublishSessionResponse, error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
out := new(ClosePublishSessionResponse) |
|||
err := c.cc.Invoke(ctx, SeaweedMessagingAgent_ClosePublishSession_FullMethodName, in, out, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingAgentClient) PublishRecord(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PublishRecordRequest, PublishRecordResponse], error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedMessagingAgent_ServiceDesc.Streams[0], SeaweedMessagingAgent_PublishRecord_FullMethodName, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &grpc.GenericClientStream[PublishRecordRequest, PublishRecordResponse]{ClientStream: stream} |
|||
return x, nil |
|||
} |
|||
|
|||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|||
type SeaweedMessagingAgent_PublishRecordClient = grpc.BidiStreamingClient[PublishRecordRequest, PublishRecordResponse] |
|||
|
|||
func (c *seaweedMessagingAgentClient) StartSubscribeSession(ctx context.Context, in *StartSubscribeSessionRequest, opts ...grpc.CallOption) (*StartSubscribeSessionResponse, error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
out := new(StartSubscribeSessionResponse) |
|||
err := c.cc.Invoke(ctx, SeaweedMessagingAgent_StartSubscribeSession_FullMethodName, in, out, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingAgentClient) CloseSubscribeSession(ctx context.Context, in *CloseSubscribeSessionRequest, opts ...grpc.CallOption) (*CloseSubscribeSessionResponse, error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
out := new(CloseSubscribeSessionResponse) |
|||
err := c.cc.Invoke(ctx, SeaweedMessagingAgent_CloseSubscribeSession_FullMethodName, in, out, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingAgentClient) SubscribeRecord(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeRecordRequest, SubscribeRecordResponse], error) { |
|||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedMessagingAgent_ServiceDesc.Streams[1], SeaweedMessagingAgent_SubscribeRecord_FullMethodName, cOpts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &grpc.GenericClientStream[SubscribeRecordRequest, SubscribeRecordResponse]{ClientStream: stream} |
|||
return x, nil |
|||
} |
|||
|
|||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|||
type SeaweedMessagingAgent_SubscribeRecordClient = grpc.BidiStreamingClient[SubscribeRecordRequest, SubscribeRecordResponse] |
|||
|
|||
// SeaweedMessagingAgentServer is the server API for SeaweedMessagingAgent service.
|
|||
// All implementations must embed UnimplementedSeaweedMessagingAgentServer
|
|||
// for forward compatibility.
|
|||
type SeaweedMessagingAgentServer interface { |
|||
// Publishing
|
|||
StartPublishSession(context.Context, *StartPublishSessionRequest) (*StartPublishSessionResponse, error) |
|||
ClosePublishSession(context.Context, *ClosePublishSessionRequest) (*ClosePublishSessionResponse, error) |
|||
PublishRecord(grpc.BidiStreamingServer[PublishRecordRequest, PublishRecordResponse]) error |
|||
// Subscribing
|
|||
StartSubscribeSession(context.Context, *StartSubscribeSessionRequest) (*StartSubscribeSessionResponse, error) |
|||
CloseSubscribeSession(context.Context, *CloseSubscribeSessionRequest) (*CloseSubscribeSessionResponse, error) |
|||
SubscribeRecord(grpc.BidiStreamingServer[SubscribeRecordRequest, SubscribeRecordResponse]) error |
|||
mustEmbedUnimplementedSeaweedMessagingAgentServer() |
|||
} |
|||
|
|||
// UnimplementedSeaweedMessagingAgentServer 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 UnimplementedSeaweedMessagingAgentServer struct{} |
|||
|
|||
func (UnimplementedSeaweedMessagingAgentServer) StartPublishSession(context.Context, *StartPublishSessionRequest) (*StartPublishSessionResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method StartPublishSession not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) ClosePublishSession(context.Context, *ClosePublishSessionRequest) (*ClosePublishSessionResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method ClosePublishSession not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) PublishRecord(grpc.BidiStreamingServer[PublishRecordRequest, PublishRecordResponse]) error { |
|||
return status.Errorf(codes.Unimplemented, "method PublishRecord not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) StartSubscribeSession(context.Context, *StartSubscribeSessionRequest) (*StartSubscribeSessionResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method StartSubscribeSession not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) CloseSubscribeSession(context.Context, *CloseSubscribeSessionRequest) (*CloseSubscribeSessionResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CloseSubscribeSession not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) SubscribeRecord(grpc.BidiStreamingServer[SubscribeRecordRequest, SubscribeRecordResponse]) error { |
|||
return status.Errorf(codes.Unimplemented, "method SubscribeRecord not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingAgentServer) mustEmbedUnimplementedSeaweedMessagingAgentServer() {} |
|||
func (UnimplementedSeaweedMessagingAgentServer) testEmbeddedByValue() {} |
|||
|
|||
// UnsafeSeaweedMessagingAgentServer may be embedded to opt out of forward compatibility for this service.
|
|||
// Use of this interface is not recommended, as added methods to SeaweedMessagingAgentServer will
|
|||
// result in compilation errors.
|
|||
type UnsafeSeaweedMessagingAgentServer interface { |
|||
mustEmbedUnimplementedSeaweedMessagingAgentServer() |
|||
} |
|||
|
|||
func RegisterSeaweedMessagingAgentServer(s grpc.ServiceRegistrar, srv SeaweedMessagingAgentServer) { |
|||
// If the following call pancis, it indicates UnimplementedSeaweedMessagingAgentServer 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(&SeaweedMessagingAgent_ServiceDesc, srv) |
|||
} |
|||
|
|||
func _SeaweedMessagingAgent_StartPublishSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(StartPublishSessionRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingAgentServer).StartPublishSession(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: SeaweedMessagingAgent_StartPublishSession_FullMethodName, |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingAgentServer).StartPublishSession(ctx, req.(*StartPublishSessionRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessagingAgent_ClosePublishSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(ClosePublishSessionRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingAgentServer).ClosePublishSession(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: SeaweedMessagingAgent_ClosePublishSession_FullMethodName, |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingAgentServer).ClosePublishSession(ctx, req.(*ClosePublishSessionRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessagingAgent_PublishRecord_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedMessagingAgentServer).PublishRecord(&grpc.GenericServerStream[PublishRecordRequest, PublishRecordResponse]{ServerStream: stream}) |
|||
} |
|||
|
|||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|||
type SeaweedMessagingAgent_PublishRecordServer = grpc.BidiStreamingServer[PublishRecordRequest, PublishRecordResponse] |
|||
|
|||
func _SeaweedMessagingAgent_StartSubscribeSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(StartSubscribeSessionRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingAgentServer).StartSubscribeSession(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: SeaweedMessagingAgent_StartSubscribeSession_FullMethodName, |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingAgentServer).StartSubscribeSession(ctx, req.(*StartSubscribeSessionRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessagingAgent_CloseSubscribeSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CloseSubscribeSessionRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingAgentServer).CloseSubscribeSession(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: SeaweedMessagingAgent_CloseSubscribeSession_FullMethodName, |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingAgentServer).CloseSubscribeSession(ctx, req.(*CloseSubscribeSessionRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessagingAgent_SubscribeRecord_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedMessagingAgentServer).SubscribeRecord(&grpc.GenericServerStream[SubscribeRecordRequest, SubscribeRecordResponse]{ServerStream: stream}) |
|||
} |
|||
|
|||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|||
type SeaweedMessagingAgent_SubscribeRecordServer = grpc.BidiStreamingServer[SubscribeRecordRequest, SubscribeRecordResponse] |
|||
|
|||
// SeaweedMessagingAgent_ServiceDesc is the grpc.ServiceDesc for SeaweedMessagingAgent service.
|
|||
// It's only intended for direct use with grpc.RegisterService,
|
|||
// and not to be introspected or modified (even as a copy)
|
|||
var SeaweedMessagingAgent_ServiceDesc = grpc.ServiceDesc{ |
|||
ServiceName: "messaging_pb.SeaweedMessagingAgent", |
|||
HandlerType: (*SeaweedMessagingAgentServer)(nil), |
|||
Methods: []grpc.MethodDesc{ |
|||
{ |
|||
MethodName: "StartPublishSession", |
|||
Handler: _SeaweedMessagingAgent_StartPublishSession_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "ClosePublishSession", |
|||
Handler: _SeaweedMessagingAgent_ClosePublishSession_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "StartSubscribeSession", |
|||
Handler: _SeaweedMessagingAgent_StartSubscribeSession_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CloseSubscribeSession", |
|||
Handler: _SeaweedMessagingAgent_CloseSubscribeSession_Handler, |
|||
}, |
|||
}, |
|||
Streams: []grpc.StreamDesc{ |
|||
{ |
|||
StreamName: "PublishRecord", |
|||
Handler: _SeaweedMessagingAgent_PublishRecord_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "SubscribeRecord", |
|||
Handler: _SeaweedMessagingAgent_SubscribeRecord_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
}, |
|||
Metadata: "mq_agent.proto", |
|||
} |
1493
weed/pb/mq_pb/mq_broker.pb.go
File diff suppressed because it is too large
View File
File diff suppressed because it is too large
View File
Reference in new issue
xxxxxxxxxx