Documentation ¶
Index ¶
- Variables
- func RegisterSeaweedMessagingServer(s grpc.ServiceRegistrar, srv SeaweedMessagingServer)
- type AssignSegmentBrokersRequest
- func (*AssignSegmentBrokersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AssignSegmentBrokersRequest) GetSegment() *Segment
- func (*AssignSegmentBrokersRequest) ProtoMessage()
- func (x *AssignSegmentBrokersRequest) ProtoReflect() protoreflect.Message
- func (x *AssignSegmentBrokersRequest) Reset()
- func (x *AssignSegmentBrokersRequest) String() string
- type AssignSegmentBrokersResponse
- func (*AssignSegmentBrokersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AssignSegmentBrokersResponse) GetBrokers() []string
- func (*AssignSegmentBrokersResponse) ProtoMessage()
- func (x *AssignSegmentBrokersResponse) ProtoReflect() protoreflect.Message
- func (x *AssignSegmentBrokersResponse) Reset()
- func (x *AssignSegmentBrokersResponse) String() string
- type CheckBrokerLoadRequest
- type CheckBrokerLoadResponse
- func (*CheckBrokerLoadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBrokerLoadResponse) GetBytesCount() int64
- func (x *CheckBrokerLoadResponse) GetMessageCount() int64
- func (*CheckBrokerLoadResponse) ProtoMessage()
- func (x *CheckBrokerLoadResponse) ProtoReflect() protoreflect.Message
- func (x *CheckBrokerLoadResponse) Reset()
- func (x *CheckBrokerLoadResponse) String() string
- type CheckSegmentStatusRequest
- func (*CheckSegmentStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckSegmentStatusRequest) GetSegment() *Segment
- func (*CheckSegmentStatusRequest) ProtoMessage()
- func (x *CheckSegmentStatusRequest) ProtoReflect() protoreflect.Message
- func (x *CheckSegmentStatusRequest) Reset()
- func (x *CheckSegmentStatusRequest) String() string
- type CheckSegmentStatusResponse
- func (*CheckSegmentStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckSegmentStatusResponse) GetIsActive() bool
- func (*CheckSegmentStatusResponse) ProtoMessage()
- func (x *CheckSegmentStatusResponse) ProtoReflect() protoreflect.Message
- func (x *CheckSegmentStatusResponse) Reset()
- func (x *CheckSegmentStatusResponse) String() string
- type FindBrokerLeaderRequest
- func (*FindBrokerLeaderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindBrokerLeaderRequest) GetFilerGroup() string
- func (*FindBrokerLeaderRequest) ProtoMessage()
- func (x *FindBrokerLeaderRequest) ProtoReflect() protoreflect.Message
- func (x *FindBrokerLeaderRequest) Reset()
- func (x *FindBrokerLeaderRequest) String() string
- type FindBrokerLeaderResponse
- func (*FindBrokerLeaderResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FindBrokerLeaderResponse) GetBroker() string
- func (*FindBrokerLeaderResponse) ProtoMessage()
- func (x *FindBrokerLeaderResponse) ProtoReflect() protoreflect.Message
- func (x *FindBrokerLeaderResponse) Reset()
- func (x *FindBrokerLeaderResponse) String() string
- type Partition
- func (*Partition) Descriptor() ([]byte, []int)deprecated
- func (x *Partition) GetRangeStart() int32
- func (x *Partition) GetRangeStop() int32
- func (x *Partition) GetRingSize() int32
- func (*Partition) ProtoMessage()
- func (x *Partition) ProtoReflect() protoreflect.Message
- func (x *Partition) Reset()
- func (x *Partition) String() string
- type SeaweedMessagingClient
- type SeaweedMessagingServer
- type Segment
- func (*Segment) Descriptor() ([]byte, []int)deprecated
- func (x *Segment) GetId() int32
- func (x *Segment) GetNamespace() string
- func (x *Segment) GetPartition() *Partition
- func (x *Segment) GetTopic() string
- func (*Segment) ProtoMessage()
- func (x *Segment) ProtoReflect() protoreflect.Message
- func (x *Segment) Reset()
- func (x *Segment) String() string
- type SegmentInfo
- func (*SegmentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SegmentInfo) GetBrokers() []string
- func (x *SegmentInfo) GetNextSegments() []int32
- func (x *SegmentInfo) GetPreviousSegments() []int32
- func (x *SegmentInfo) GetSegment() *Segment
- func (x *SegmentInfo) GetStartTsNs() int64
- func (x *SegmentInfo) GetStopTsNs() int64
- func (*SegmentInfo) ProtoMessage()
- func (x *SegmentInfo) ProtoReflect() protoreflect.Message
- func (x *SegmentInfo) Reset()
- func (x *SegmentInfo) String() string
- type UnimplementedSeaweedMessagingServer
- func (UnimplementedSeaweedMessagingServer) AssignSegmentBrokers(context.Context, *AssignSegmentBrokersRequest) (*AssignSegmentBrokersResponse, error)
- func (UnimplementedSeaweedMessagingServer) CheckBrokerLoad(context.Context, *CheckBrokerLoadRequest) (*CheckBrokerLoadResponse, error)
- func (UnimplementedSeaweedMessagingServer) CheckSegmentStatus(context.Context, *CheckSegmentStatusRequest) (*CheckSegmentStatusResponse, error)
- func (UnimplementedSeaweedMessagingServer) FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error)
- type UnsafeSeaweedMessagingServer
Constants ¶
This section is empty.
Variables ¶
var File_mq_proto protoreflect.FileDescriptor
var SeaweedMessaging_ServiceDesc = grpc.ServiceDesc{ ServiceName: "messaging_pb.SeaweedMessaging", HandlerType: (*SeaweedMessagingServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FindBrokerLeader", Handler: _SeaweedMessaging_FindBrokerLeader_Handler, }, { MethodName: "AssignSegmentBrokers", Handler: _SeaweedMessaging_AssignSegmentBrokers_Handler, }, { MethodName: "CheckSegmentStatus", Handler: _SeaweedMessaging_CheckSegmentStatus_Handler, }, { MethodName: "CheckBrokerLoad", Handler: _SeaweedMessaging_CheckBrokerLoad_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mq.proto", }
SeaweedMessaging_ServiceDesc is the grpc.ServiceDesc for SeaweedMessaging service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSeaweedMessagingServer ¶
func RegisterSeaweedMessagingServer(s grpc.ServiceRegistrar, srv SeaweedMessagingServer)
Types ¶
type AssignSegmentBrokersRequest ¶
type AssignSegmentBrokersRequest struct { Segment *Segment `protobuf:"bytes,1,opt,name=segment,proto3" json:"segment,omitempty"` // contains filtered or unexported fields }
func (*AssignSegmentBrokersRequest) Descriptor
deprecated
func (*AssignSegmentBrokersRequest) Descriptor() ([]byte, []int)
Deprecated: Use AssignSegmentBrokersRequest.ProtoReflect.Descriptor instead.
func (*AssignSegmentBrokersRequest) GetSegment ¶
func (x *AssignSegmentBrokersRequest) GetSegment() *Segment
func (*AssignSegmentBrokersRequest) ProtoMessage ¶
func (*AssignSegmentBrokersRequest) ProtoMessage()
func (*AssignSegmentBrokersRequest) ProtoReflect ¶
func (x *AssignSegmentBrokersRequest) ProtoReflect() protoreflect.Message
func (*AssignSegmentBrokersRequest) Reset ¶
func (x *AssignSegmentBrokersRequest) Reset()
func (*AssignSegmentBrokersRequest) String ¶
func (x *AssignSegmentBrokersRequest) String() string
type AssignSegmentBrokersResponse ¶
type AssignSegmentBrokersResponse struct { Brokers []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"` // contains filtered or unexported fields }
func (*AssignSegmentBrokersResponse) Descriptor
deprecated
func (*AssignSegmentBrokersResponse) Descriptor() ([]byte, []int)
Deprecated: Use AssignSegmentBrokersResponse.ProtoReflect.Descriptor instead.
func (*AssignSegmentBrokersResponse) GetBrokers ¶
func (x *AssignSegmentBrokersResponse) GetBrokers() []string
func (*AssignSegmentBrokersResponse) ProtoMessage ¶
func (*AssignSegmentBrokersResponse) ProtoMessage()
func (*AssignSegmentBrokersResponse) ProtoReflect ¶
func (x *AssignSegmentBrokersResponse) ProtoReflect() protoreflect.Message
func (*AssignSegmentBrokersResponse) Reset ¶
func (x *AssignSegmentBrokersResponse) Reset()
func (*AssignSegmentBrokersResponse) String ¶
func (x *AssignSegmentBrokersResponse) String() string
type CheckBrokerLoadRequest ¶
type CheckBrokerLoadRequest struct {
// contains filtered or unexported fields
}
func (*CheckBrokerLoadRequest) Descriptor
deprecated
func (*CheckBrokerLoadRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckBrokerLoadRequest.ProtoReflect.Descriptor instead.
func (*CheckBrokerLoadRequest) ProtoMessage ¶
func (*CheckBrokerLoadRequest) ProtoMessage()
func (*CheckBrokerLoadRequest) ProtoReflect ¶
func (x *CheckBrokerLoadRequest) ProtoReflect() protoreflect.Message
func (*CheckBrokerLoadRequest) Reset ¶
func (x *CheckBrokerLoadRequest) Reset()
func (*CheckBrokerLoadRequest) String ¶
func (x *CheckBrokerLoadRequest) String() string
type CheckBrokerLoadResponse ¶
type CheckBrokerLoadResponse struct { MessageCount int64 `protobuf:"varint,1,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"` BytesCount int64 `protobuf:"varint,2,opt,name=bytes_count,json=bytesCount,proto3" json:"bytes_count,omitempty"` // contains filtered or unexported fields }
func (*CheckBrokerLoadResponse) Descriptor
deprecated
func (*CheckBrokerLoadResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckBrokerLoadResponse.ProtoReflect.Descriptor instead.
func (*CheckBrokerLoadResponse) GetBytesCount ¶
func (x *CheckBrokerLoadResponse) GetBytesCount() int64
func (*CheckBrokerLoadResponse) GetMessageCount ¶
func (x *CheckBrokerLoadResponse) GetMessageCount() int64
func (*CheckBrokerLoadResponse) ProtoMessage ¶
func (*CheckBrokerLoadResponse) ProtoMessage()
func (*CheckBrokerLoadResponse) ProtoReflect ¶
func (x *CheckBrokerLoadResponse) ProtoReflect() protoreflect.Message
func (*CheckBrokerLoadResponse) Reset ¶
func (x *CheckBrokerLoadResponse) Reset()
func (*CheckBrokerLoadResponse) String ¶
func (x *CheckBrokerLoadResponse) String() string
type CheckSegmentStatusRequest ¶
type CheckSegmentStatusRequest struct { Segment *Segment `protobuf:"bytes,1,opt,name=segment,proto3" json:"segment,omitempty"` // contains filtered or unexported fields }
func (*CheckSegmentStatusRequest) Descriptor
deprecated
func (*CheckSegmentStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckSegmentStatusRequest.ProtoReflect.Descriptor instead.
func (*CheckSegmentStatusRequest) GetSegment ¶
func (x *CheckSegmentStatusRequest) GetSegment() *Segment
func (*CheckSegmentStatusRequest) ProtoMessage ¶
func (*CheckSegmentStatusRequest) ProtoMessage()
func (*CheckSegmentStatusRequest) ProtoReflect ¶
func (x *CheckSegmentStatusRequest) ProtoReflect() protoreflect.Message
func (*CheckSegmentStatusRequest) Reset ¶
func (x *CheckSegmentStatusRequest) Reset()
func (*CheckSegmentStatusRequest) String ¶
func (x *CheckSegmentStatusRequest) String() string
type CheckSegmentStatusResponse ¶
type CheckSegmentStatusResponse struct { IsActive bool `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"` // contains filtered or unexported fields }
func (*CheckSegmentStatusResponse) Descriptor
deprecated
func (*CheckSegmentStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckSegmentStatusResponse.ProtoReflect.Descriptor instead.
func (*CheckSegmentStatusResponse) GetIsActive ¶
func (x *CheckSegmentStatusResponse) GetIsActive() bool
func (*CheckSegmentStatusResponse) ProtoMessage ¶
func (*CheckSegmentStatusResponse) ProtoMessage()
func (*CheckSegmentStatusResponse) ProtoReflect ¶
func (x *CheckSegmentStatusResponse) ProtoReflect() protoreflect.Message
func (*CheckSegmentStatusResponse) Reset ¶
func (x *CheckSegmentStatusResponse) Reset()
func (*CheckSegmentStatusResponse) String ¶
func (x *CheckSegmentStatusResponse) String() string
type FindBrokerLeaderRequest ¶
type FindBrokerLeaderRequest struct { FilerGroup string `protobuf:"bytes,1,opt,name=filer_group,json=filerGroup,proto3" json:"filer_group,omitempty"` // contains filtered or unexported fields }
func (*FindBrokerLeaderRequest) Descriptor
deprecated
func (*FindBrokerLeaderRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindBrokerLeaderRequest.ProtoReflect.Descriptor instead.
func (*FindBrokerLeaderRequest) GetFilerGroup ¶
func (x *FindBrokerLeaderRequest) GetFilerGroup() string
func (*FindBrokerLeaderRequest) ProtoMessage ¶
func (*FindBrokerLeaderRequest) ProtoMessage()
func (*FindBrokerLeaderRequest) ProtoReflect ¶
func (x *FindBrokerLeaderRequest) ProtoReflect() protoreflect.Message
func (*FindBrokerLeaderRequest) Reset ¶
func (x *FindBrokerLeaderRequest) Reset()
func (*FindBrokerLeaderRequest) String ¶
func (x *FindBrokerLeaderRequest) String() string
type FindBrokerLeaderResponse ¶
type FindBrokerLeaderResponse struct { Broker string `protobuf:"bytes,1,opt,name=broker,proto3" json:"broker,omitempty"` // contains filtered or unexported fields }
func (*FindBrokerLeaderResponse) Descriptor
deprecated
func (*FindBrokerLeaderResponse) Descriptor() ([]byte, []int)
Deprecated: Use FindBrokerLeaderResponse.ProtoReflect.Descriptor instead.
func (*FindBrokerLeaderResponse) GetBroker ¶
func (x *FindBrokerLeaderResponse) GetBroker() string
func (*FindBrokerLeaderResponse) ProtoMessage ¶
func (*FindBrokerLeaderResponse) ProtoMessage()
func (*FindBrokerLeaderResponse) ProtoReflect ¶
func (x *FindBrokerLeaderResponse) ProtoReflect() protoreflect.Message
func (*FindBrokerLeaderResponse) Reset ¶
func (x *FindBrokerLeaderResponse) Reset()
func (*FindBrokerLeaderResponse) String ¶
func (x *FindBrokerLeaderResponse) String() string
type Partition ¶
type Partition struct { RingSize int32 `protobuf:"varint,1,opt,name=ring_size,json=ringSize,proto3" json:"ring_size,omitempty"` RangeStart int32 `protobuf:"varint,2,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"` RangeStop int32 `protobuf:"varint,3,opt,name=range_stop,json=rangeStop,proto3" json:"range_stop,omitempty"` // contains filtered or unexported fields }
func (*Partition) Descriptor
deprecated
func (*Partition) GetRangeStart ¶
func (*Partition) GetRangeStop ¶
func (*Partition) GetRingSize ¶
func (*Partition) ProtoMessage ¶
func (*Partition) ProtoMessage()
func (*Partition) ProtoReflect ¶
func (x *Partition) ProtoReflect() protoreflect.Message
type SeaweedMessagingClient ¶
type SeaweedMessagingClient interface { FindBrokerLeader(ctx context.Context, in *FindBrokerLeaderRequest, opts ...grpc.CallOption) (*FindBrokerLeaderResponse, error) AssignSegmentBrokers(ctx context.Context, in *AssignSegmentBrokersRequest, opts ...grpc.CallOption) (*AssignSegmentBrokersResponse, error) CheckSegmentStatus(ctx context.Context, in *CheckSegmentStatusRequest, opts ...grpc.CallOption) (*CheckSegmentStatusResponse, error) CheckBrokerLoad(ctx context.Context, in *CheckBrokerLoadRequest, opts ...grpc.CallOption) (*CheckBrokerLoadResponse, error) }
SeaweedMessagingClient is the client API for SeaweedMessaging 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.
func NewSeaweedMessagingClient ¶
func NewSeaweedMessagingClient(cc grpc.ClientConnInterface) SeaweedMessagingClient
type SeaweedMessagingServer ¶
type SeaweedMessagingServer interface { FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error) AssignSegmentBrokers(context.Context, *AssignSegmentBrokersRequest) (*AssignSegmentBrokersResponse, error) CheckSegmentStatus(context.Context, *CheckSegmentStatusRequest) (*CheckSegmentStatusResponse, error) CheckBrokerLoad(context.Context, *CheckBrokerLoadRequest) (*CheckBrokerLoadResponse, error) // contains filtered or unexported methods }
SeaweedMessagingServer is the server API for SeaweedMessaging service. All implementations must embed UnimplementedSeaweedMessagingServer for forward compatibility
type Segment ¶
type Segment struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Id int32 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Partition *Partition `protobuf:"bytes,4,opt,name=partition,proto3" json:"partition,omitempty"` // contains filtered or unexported fields }
func (*Segment) Descriptor
deprecated
func (*Segment) GetNamespace ¶
func (*Segment) GetPartition ¶
func (*Segment) ProtoMessage ¶
func (*Segment) ProtoMessage()
func (*Segment) ProtoReflect ¶
func (x *Segment) ProtoReflect() protoreflect.Message
type SegmentInfo ¶
type SegmentInfo struct { Segment *Segment `protobuf:"bytes,1,opt,name=segment,proto3" json:"segment,omitempty"` StartTsNs int64 `protobuf:"varint,2,opt,name=start_ts_ns,json=startTsNs,proto3" json:"start_ts_ns,omitempty"` Brokers []string `protobuf:"bytes,3,rep,name=brokers,proto3" json:"brokers,omitempty"` StopTsNs int64 `protobuf:"varint,4,opt,name=stop_ts_ns,json=stopTsNs,proto3" json:"stop_ts_ns,omitempty"` PreviousSegments []int32 `protobuf:"varint,5,rep,packed,name=previous_segments,json=previousSegments,proto3" json:"previous_segments,omitempty"` NextSegments []int32 `protobuf:"varint,6,rep,packed,name=next_segments,json=nextSegments,proto3" json:"next_segments,omitempty"` // contains filtered or unexported fields }
////////////////////////////////////////////////
func (*SegmentInfo) Descriptor
deprecated
func (*SegmentInfo) Descriptor() ([]byte, []int)
Deprecated: Use SegmentInfo.ProtoReflect.Descriptor instead.
func (*SegmentInfo) GetBrokers ¶
func (x *SegmentInfo) GetBrokers() []string
func (*SegmentInfo) GetNextSegments ¶
func (x *SegmentInfo) GetNextSegments() []int32
func (*SegmentInfo) GetPreviousSegments ¶
func (x *SegmentInfo) GetPreviousSegments() []int32
func (*SegmentInfo) GetSegment ¶
func (x *SegmentInfo) GetSegment() *Segment
func (*SegmentInfo) GetStartTsNs ¶
func (x *SegmentInfo) GetStartTsNs() int64
func (*SegmentInfo) GetStopTsNs ¶
func (x *SegmentInfo) GetStopTsNs() int64
func (*SegmentInfo) ProtoMessage ¶
func (*SegmentInfo) ProtoMessage()
func (*SegmentInfo) ProtoReflect ¶
func (x *SegmentInfo) ProtoReflect() protoreflect.Message
func (*SegmentInfo) Reset ¶
func (x *SegmentInfo) Reset()
func (*SegmentInfo) String ¶
func (x *SegmentInfo) String() string
type UnimplementedSeaweedMessagingServer ¶
type UnimplementedSeaweedMessagingServer struct { }
UnimplementedSeaweedMessagingServer must be embedded to have forward compatible implementations.
func (UnimplementedSeaweedMessagingServer) AssignSegmentBrokers ¶
func (UnimplementedSeaweedMessagingServer) AssignSegmentBrokers(context.Context, *AssignSegmentBrokersRequest) (*AssignSegmentBrokersResponse, error)
func (UnimplementedSeaweedMessagingServer) CheckBrokerLoad ¶
func (UnimplementedSeaweedMessagingServer) CheckBrokerLoad(context.Context, *CheckBrokerLoadRequest) (*CheckBrokerLoadResponse, error)
func (UnimplementedSeaweedMessagingServer) CheckSegmentStatus ¶
func (UnimplementedSeaweedMessagingServer) CheckSegmentStatus(context.Context, *CheckSegmentStatusRequest) (*CheckSegmentStatusResponse, error)
func (UnimplementedSeaweedMessagingServer) FindBrokerLeader ¶
func (UnimplementedSeaweedMessagingServer) FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error)
type UnsafeSeaweedMessagingServer ¶
type UnsafeSeaweedMessagingServer interface {
// contains filtered or unexported methods
}
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 result in compilation errors.