Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)
- type Ack
- func (*Ack) Descriptor() ([]byte, []int)deprecated
- func (x *Ack) GetGroupId() string
- func (x *Ack) GetOffsets() map[uint64]uint64
- func (x *Ack) GetTopic() string
- func (m *Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Ack) MarshalToVT(dAtA []byte) (int, error)
- func (m *Ack) MarshalVT() (dAtA []byte, err error)
- func (*Ack) ProtoMessage()
- func (x *Ack) ProtoReflect() protoreflect.Message
- func (x *Ack) Reset()
- func (m *Ack) SizeVT() (n int)
- func (x *Ack) String() string
- func (m *Ack) UnmarshalVT(dAtA []byte) error
- type AckConsumeRequest
- func (*AckConsumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AckConsumeRequest) GetGroupId() string
- func (x *AckConsumeRequest) GetOffsets() map[uint64]uint64
- func (x *AckConsumeRequest) GetTopic() string
- func (m *AckConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AckConsumeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *AckConsumeRequest) MarshalVT() (dAtA []byte, err error)
- func (*AckConsumeRequest) ProtoMessage()
- func (x *AckConsumeRequest) ProtoReflect() protoreflect.Message
- func (x *AckConsumeRequest) Reset()
- func (m *AckConsumeRequest) SizeVT() (n int)
- func (x *AckConsumeRequest) String() string
- func (m *AckConsumeRequest) UnmarshalVT(dAtA []byte) error
- type AckConsumeResponse
- func (*AckConsumeResponse) Descriptor() ([]byte, []int)deprecated
- func (m *AckConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AckConsumeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *AckConsumeResponse) MarshalVT() (dAtA []byte, err error)
- func (*AckConsumeResponse) ProtoMessage()
- func (x *AckConsumeResponse) ProtoReflect() protoreflect.Message
- func (x *AckConsumeResponse) Reset()
- func (m *AckConsumeResponse) SizeVT() (n int)
- func (x *AckConsumeResponse) String() string
- func (m *AckConsumeResponse) UnmarshalVT(dAtA []byte) error
- type AckResult
- func (*AckResult) Descriptor() ([]byte, []int)deprecated
- func (m *AckResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AckResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *AckResult) MarshalVT() (dAtA []byte, err error)
- func (*AckResult) ProtoMessage()
- func (x *AckResult) ProtoReflect() protoreflect.Message
- func (x *AckResult) Reset()
- func (m *AckResult) SizeVT() (n int)
- func (x *AckResult) String() string
- func (m *AckResult) UnmarshalVT(dAtA []byte) error
- type AddMember
- func (*AddMember) Descriptor() ([]byte, []int)deprecated
- func (x *AddMember) GetAddress() string
- func (x *AddMember) GetNodeId() string
- func (m *AddMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AddMember) MarshalToVT(dAtA []byte) (int, error)
- func (m *AddMember) MarshalVT() (dAtA []byte, err error)
- func (*AddMember) ProtoMessage()
- func (x *AddMember) ProtoReflect() protoreflect.Message
- func (x *AddMember) Reset()
- func (m *AddMember) SizeVT() (n int)
- func (x *AddMember) String() string
- func (m *AddMember) UnmarshalVT(dAtA []byte) error
- type AddMemberResult
- func (*AddMemberResult) Descriptor() ([]byte, []int)deprecated
- func (m *AddMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *AddMemberResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *AddMemberResult) MarshalVT() (dAtA []byte, err error)
- func (*AddMemberResult) ProtoMessage()
- func (x *AddMemberResult) ProtoReflect() protoreflect.Message
- func (x *AddMemberResult) Reset()
- func (m *AddMemberResult) SizeVT() (n int)
- func (x *AddMemberResult) String() string
- func (m *AddMemberResult) UnmarshalVT(dAtA []byte) error
- type ConsumeRequest
- func (*ConsumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConsumeRequest) GetGroupId() string
- func (x *ConsumeRequest) GetOffsets() map[uint64]uint64
- func (x *ConsumeRequest) GetTopic() string
- func (m *ConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ConsumeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ConsumeRequest) MarshalVT() (dAtA []byte, err error)
- func (*ConsumeRequest) ProtoMessage()
- func (x *ConsumeRequest) ProtoReflect() protoreflect.Message
- func (x *ConsumeRequest) Reset()
- func (m *ConsumeRequest) SizeVT() (n int)
- func (x *ConsumeRequest) String() string
- func (m *ConsumeRequest) UnmarshalVT(dAtA []byte) error
- type ConsumeResponse
- func (*ConsumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConsumeResponse) GetLastIndex() uint64
- func (x *ConsumeResponse) GetMessages() map[uint64]*Messages
- func (m *ConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ConsumeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ConsumeResponse) MarshalVT() (dAtA []byte, err error)
- func (*ConsumeResponse) ProtoMessage()
- func (x *ConsumeResponse) ProtoReflect() protoreflect.Message
- func (x *ConsumeResponse) Reset()
- func (m *ConsumeResponse) SizeVT() (n int)
- func (x *ConsumeResponse) String() string
- func (m *ConsumeResponse) UnmarshalVT(dAtA []byte) error
- type Consumer
- func (*Consumer) Descriptor() ([]byte, []int)deprecated
- func (x *Consumer) GetId() string
- func (x *Consumer) GetOffset() uint64
- func (x *Consumer) GetPartition() uint64
- func (m *Consumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Consumer) MarshalToVT(dAtA []byte) (int, error)
- func (m *Consumer) MarshalVT() (dAtA []byte, err error)
- func (*Consumer) ProtoMessage()
- func (x *Consumer) ProtoReflect() protoreflect.Message
- func (x *Consumer) Reset()
- func (m *Consumer) SizeVT() (n int)
- func (x *Consumer) String() string
- func (m *Consumer) UnmarshalVT(dAtA []byte) error
- type ConsumerGroup
- func (*ConsumerGroup) Descriptor() ([]byte, []int)deprecated
- func (x *ConsumerGroup) GetConsumers() map[string]*Consumer
- func (x *ConsumerGroup) GetId() string
- func (m *ConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ConsumerGroup) MarshalToVT(dAtA []byte) (int, error)
- func (m *ConsumerGroup) MarshalVT() (dAtA []byte, err error)
- func (*ConsumerGroup) ProtoMessage()
- func (x *ConsumerGroup) ProtoReflect() protoreflect.Message
- func (x *ConsumerGroup) Reset()
- func (m *ConsumerGroup) SizeVT() (n int)
- func (x *ConsumerGroup) String() string
- func (m *ConsumerGroup) UnmarshalVT(dAtA []byte) error
- type CreateConsumer
- func (*CreateConsumer) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumer) GetGroupId() string
- func (x *CreateConsumer) GetTopic() string
- func (m *CreateConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumer) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumer) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumer) ProtoMessage()
- func (x *CreateConsumer) ProtoReflect() protoreflect.Message
- func (x *CreateConsumer) Reset()
- func (m *CreateConsumer) SizeVT() (n int)
- func (x *CreateConsumer) String() string
- func (m *CreateConsumer) UnmarshalVT(dAtA []byte) error
- type CreateConsumerGroup
- func (*CreateConsumerGroup) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerGroup) GetId() string
- func (x *CreateConsumerGroup) GetTopic() string
- func (m *CreateConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroup) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroup) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerGroup) ProtoMessage()
- func (x *CreateConsumerGroup) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerGroup) Reset()
- func (m *CreateConsumerGroup) SizeVT() (n int)
- func (x *CreateConsumerGroup) String() string
- func (m *CreateConsumerGroup) UnmarshalVT(dAtA []byte) error
- type CreateConsumerGroupRequest
- func (*CreateConsumerGroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerGroupRequest) GetId() string
- func (x *CreateConsumerGroupRequest) GetTopic() string
- func (m *CreateConsumerGroupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupRequest) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerGroupRequest) ProtoMessage()
- func (x *CreateConsumerGroupRequest) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerGroupRequest) Reset()
- func (m *CreateConsumerGroupRequest) SizeVT() (n int)
- func (x *CreateConsumerGroupRequest) String() string
- func (m *CreateConsumerGroupRequest) UnmarshalVT(dAtA []byte) error
- type CreateConsumerGroupResponse
- func (*CreateConsumerGroupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerGroupResponse) GetGroup() *ConsumerGroup
- func (x *CreateConsumerGroupResponse) GetId() string
- func (m *CreateConsumerGroupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupResponse) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerGroupResponse) ProtoMessage()
- func (x *CreateConsumerGroupResponse) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerGroupResponse) Reset()
- func (m *CreateConsumerGroupResponse) SizeVT() (n int)
- func (x *CreateConsumerGroupResponse) String() string
- func (m *CreateConsumerGroupResponse) UnmarshalVT(dAtA []byte) error
- type CreateConsumerGroupResult
- func (*CreateConsumerGroupResult) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerGroupResult) GetConsumers() []*Consumer
- func (x *CreateConsumerGroupResult) GetId() string
- func (m *CreateConsumerGroupResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerGroupResult) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerGroupResult) ProtoMessage()
- func (x *CreateConsumerGroupResult) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerGroupResult) Reset()
- func (m *CreateConsumerGroupResult) SizeVT() (n int)
- func (x *CreateConsumerGroupResult) String() string
- func (m *CreateConsumerGroupResult) UnmarshalVT(dAtA []byte) error
- type CreateConsumerRequest
- func (*CreateConsumerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerRequest) GetGroupId() string
- func (x *CreateConsumerRequest) GetTopic() string
- func (m *CreateConsumerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerRequest) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerRequest) ProtoMessage()
- func (x *CreateConsumerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerRequest) Reset()
- func (m *CreateConsumerRequest) SizeVT() (n int)
- func (x *CreateConsumerRequest) String() string
- func (m *CreateConsumerRequest) UnmarshalVT(dAtA []byte) error
- type CreateConsumerResponse
- func (*CreateConsumerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerResponse) GetConsumerId() string
- func (x *CreateConsumerResponse) GetLastIndex() uint64
- func (m *CreateConsumerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerResponse) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerResponse) ProtoMessage()
- func (x *CreateConsumerResponse) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerResponse) Reset()
- func (m *CreateConsumerResponse) SizeVT() (n int)
- func (x *CreateConsumerResponse) String() string
- func (m *CreateConsumerResponse) UnmarshalVT(dAtA []byte) error
- type CreateConsumerResult
- func (*CreateConsumerResult) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerResult) GetConsumer() *Consumer
- func (m *CreateConsumerResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateConsumerResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateConsumerResult) MarshalVT() (dAtA []byte, err error)
- func (*CreateConsumerResult) ProtoMessage()
- func (x *CreateConsumerResult) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerResult) Reset()
- func (m *CreateConsumerResult) SizeVT() (n int)
- func (x *CreateConsumerResult) String() string
- func (m *CreateConsumerResult) UnmarshalVT(dAtA []byte) error
- type CreateTopic
- func (*CreateTopic) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTopic) GetPartitions() []uint64
- func (x *CreateTopic) GetTopic() string
- func (m *CreateTopic) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateTopic) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateTopic) MarshalVT() (dAtA []byte, err error)
- func (*CreateTopic) ProtoMessage()
- func (x *CreateTopic) ProtoReflect() protoreflect.Message
- func (x *CreateTopic) Reset()
- func (m *CreateTopic) SizeVT() (n int)
- func (x *CreateTopic) String() string
- func (m *CreateTopic) UnmarshalVT(dAtA []byte) error
- type CreateTopicRequest
- func (*CreateTopicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTopicRequest) GetPartitions() []uint64
- func (x *CreateTopicRequest) GetTopic() string
- func (m *CreateTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateTopicRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateTopicRequest) MarshalVT() (dAtA []byte, err error)
- func (*CreateTopicRequest) ProtoMessage()
- func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTopicRequest) Reset()
- func (m *CreateTopicRequest) SizeVT() (n int)
- func (x *CreateTopicRequest) String() string
- func (m *CreateTopicRequest) UnmarshalVT(dAtA []byte) error
- type CreateTopicResponse
- func (*CreateTopicResponse) Descriptor() ([]byte, []int)deprecated
- func (m *CreateTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateTopicResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateTopicResponse) MarshalVT() (dAtA []byte, err error)
- func (*CreateTopicResponse) ProtoMessage()
- func (x *CreateTopicResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTopicResponse) Reset()
- func (m *CreateTopicResponse) SizeVT() (n int)
- func (x *CreateTopicResponse) String() string
- func (m *CreateTopicResponse) UnmarshalVT(dAtA []byte) error
- type CreateTopicResult
- func (*CreateTopicResult) Descriptor() ([]byte, []int)deprecated
- func (m *CreateTopicResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateTopicResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateTopicResult) MarshalVT() (dAtA []byte, err error)
- func (*CreateTopicResult) ProtoMessage()
- func (x *CreateTopicResult) ProtoReflect() protoreflect.Message
- func (x *CreateTopicResult) Reset()
- func (m *CreateTopicResult) SizeVT() (n int)
- func (x *CreateTopicResult) String() string
- func (m *CreateTopicResult) UnmarshalVT(dAtA []byte) error
- type GetConsumerGroupsRequest
- func (*GetConsumerGroupsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetConsumerGroupsRequest) GetTopic() string
- func (m *GetConsumerGroupsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetConsumerGroupsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetConsumerGroupsRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetConsumerGroupsRequest) ProtoMessage()
- func (x *GetConsumerGroupsRequest) ProtoReflect() protoreflect.Message
- func (x *GetConsumerGroupsRequest) Reset()
- func (m *GetConsumerGroupsRequest) SizeVT() (n int)
- func (x *GetConsumerGroupsRequest) String() string
- func (m *GetConsumerGroupsRequest) UnmarshalVT(dAtA []byte) error
- type GetConsumerGroupsResponse
- func (*GetConsumerGroupsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConsumerGroupsResponse) GetGroups() map[string]*ConsumerGroup
- func (m *GetConsumerGroupsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetConsumerGroupsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetConsumerGroupsResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetConsumerGroupsResponse) ProtoMessage()
- func (x *GetConsumerGroupsResponse) ProtoReflect() protoreflect.Message
- func (x *GetConsumerGroupsResponse) Reset()
- func (m *GetConsumerGroupsResponse) SizeVT() (n int)
- func (x *GetConsumerGroupsResponse) String() string
- func (m *GetConsumerGroupsResponse) UnmarshalVT(dAtA []byte) error
- type GetMetaRequest
- func (*GetMetaRequest) Descriptor() ([]byte, []int)deprecated
- func (m *GetMetaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetMetaRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetMetaRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetMetaRequest) ProtoMessage()
- func (x *GetMetaRequest) ProtoReflect() protoreflect.Message
- func (x *GetMetaRequest) Reset()
- func (m *GetMetaRequest) SizeVT() (n int)
- func (x *GetMetaRequest) String() string
- func (m *GetMetaRequest) UnmarshalVT(dAtA []byte) error
- type GetMetaResponse
- func (*GetMetaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetaResponse) GetConsumerGroups() map[string]*ConsumerGroup
- func (x *GetMetaResponse) GetTopics() map[string]*Topic
- func (m *GetMetaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetMetaResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetMetaResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetMetaResponse) ProtoMessage()
- func (x *GetMetaResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetaResponse) Reset()
- func (m *GetMetaResponse) SizeVT() (n int)
- func (x *GetMetaResponse) String() string
- func (m *GetMetaResponse) UnmarshalVT(dAtA []byte) error
- type KeyVal
- func (*KeyVal) Descriptor() ([]byte, []int)deprecated
- func (x *KeyVal) GetKey() []byte
- func (x *KeyVal) GetVal() []byte
- func (m *KeyVal) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *KeyVal) MarshalToVT(dAtA []byte) (int, error)
- func (m *KeyVal) MarshalVT() (dAtA []byte, err error)
- func (*KeyVal) ProtoMessage()
- func (x *KeyVal) ProtoReflect() protoreflect.Message
- func (x *KeyVal) Reset()
- func (m *KeyVal) SizeVT() (n int)
- func (x *KeyVal) String() string
- func (m *KeyVal) UnmarshalVT(dAtA []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetKey() []byte
- func (x *Message) GetOffset() uint64
- func (x *Message) GetPartition() uint64
- func (x *Message) GetPayload() []byte
- func (x *Message) GetRaftIndex() uint64
- func (x *Message) GetTopic() string
- func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Message) MarshalToVT(dAtA []byte) (int, error)
- func (m *Message) MarshalVT() (dAtA []byte, err error)
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (m *Message) SizeVT() (n int)
- func (x *Message) String() string
- func (m *Message) UnmarshalVT(dAtA []byte) error
- type MessageServiceClient
- type MessageServiceServer
- type Messages
- func (*Messages) Descriptor() ([]byte, []int)deprecated
- func (x *Messages) GetMessages() []*Message
- func (m *Messages) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Messages) MarshalToVT(dAtA []byte) (int, error)
- func (m *Messages) MarshalVT() (dAtA []byte, err error)
- func (*Messages) ProtoMessage()
- func (x *Messages) ProtoReflect() protoreflect.Message
- func (x *Messages) Reset()
- func (m *Messages) SizeVT() (n int)
- func (x *Messages) String() string
- func (m *Messages) UnmarshalVT(dAtA []byte) error
- type Operation
- type Partition
- func (*Partition) Descriptor() ([]byte, []int)deprecated
- func (x *Partition) GetNum() uint64
- func (x *Partition) GetOffset() uint64
- func (x *Partition) GetTopic() string
- func (m *Partition) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Partition) MarshalToVT(dAtA []byte) (int, error)
- func (m *Partition) MarshalVT() (dAtA []byte, err error)
- func (*Partition) ProtoMessage()
- func (x *Partition) ProtoReflect() protoreflect.Message
- func (x *Partition) Reset()
- func (m *Partition) SizeVT() (n int)
- func (x *Partition) String() string
- func (m *Partition) UnmarshalVT(dAtA []byte) error
- type Publish
- func (*Publish) Descriptor() ([]byte, []int)deprecated
- func (x *Publish) GetMessages() []*KeyVal
- func (x *Publish) GetPartition() uint64
- func (x *Publish) GetTopic() string
- func (m *Publish) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Publish) MarshalToVT(dAtA []byte) (int, error)
- func (m *Publish) MarshalVT() (dAtA []byte, err error)
- func (*Publish) ProtoMessage()
- func (x *Publish) ProtoReflect() protoreflect.Message
- func (x *Publish) Reset()
- func (m *Publish) SizeVT() (n int)
- func (x *Publish) String() string
- func (m *Publish) UnmarshalVT(dAtA []byte) error
- type PublishMessageRequest
- func (*PublishMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishMessageRequest) GetMessages() []*KeyVal
- func (x *PublishMessageRequest) GetPartition() uint64
- func (x *PublishMessageRequest) GetTopic() string
- func (m *PublishMessageRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PublishMessageRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PublishMessageRequest) MarshalVT() (dAtA []byte, err error)
- func (*PublishMessageRequest) ProtoMessage()
- func (x *PublishMessageRequest) ProtoReflect() protoreflect.Message
- func (x *PublishMessageRequest) Reset()
- func (m *PublishMessageRequest) SizeVT() (n int)
- func (x *PublishMessageRequest) String() string
- func (m *PublishMessageRequest) UnmarshalVT(dAtA []byte) error
- type PublishMessageResponse
- func (*PublishMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishMessageResponse) GetLastIndex() uint64
- func (x *PublishMessageResponse) GetMessages() []*Message
- func (m *PublishMessageResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PublishMessageResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *PublishMessageResponse) MarshalVT() (dAtA []byte, err error)
- func (*PublishMessageResponse) ProtoMessage()
- func (x *PublishMessageResponse) ProtoReflect() protoreflect.Message
- func (x *PublishMessageResponse) Reset()
- func (m *PublishMessageResponse) SizeVT() (n int)
- func (x *PublishMessageResponse) String() string
- func (m *PublishMessageResponse) UnmarshalVT(dAtA []byte) error
- type PublishResult
- func (*PublishResult) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResult) GetMessages() []*Message
- func (m *PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PublishResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *PublishResult) MarshalVT() (dAtA []byte, err error)
- func (*PublishResult) ProtoMessage()
- func (x *PublishResult) ProtoReflect() protoreflect.Message
- func (x *PublishResult) Reset()
- func (m *PublishResult) SizeVT() (n int)
- func (x *PublishResult) String() string
- func (m *PublishResult) UnmarshalVT(dAtA []byte) error
- type RemoveMember
- func (*RemoveMember) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveMember) GetNodeId() string
- func (m *RemoveMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RemoveMember) MarshalToVT(dAtA []byte) (int, error)
- func (m *RemoveMember) MarshalVT() (dAtA []byte, err error)
- func (*RemoveMember) ProtoMessage()
- func (x *RemoveMember) ProtoReflect() protoreflect.Message
- func (x *RemoveMember) Reset()
- func (m *RemoveMember) SizeVT() (n int)
- func (x *RemoveMember) String() string
- func (m *RemoveMember) UnmarshalVT(dAtA []byte) error
- type RemoveMemberResult
- func (*RemoveMemberResult) Descriptor() ([]byte, []int)deprecated
- func (m *RemoveMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RemoveMemberResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *RemoveMemberResult) MarshalVT() (dAtA []byte, err error)
- func (*RemoveMemberResult) ProtoMessage()
- func (x *RemoveMemberResult) ProtoReflect() protoreflect.Message
- func (x *RemoveMemberResult) Reset()
- func (m *RemoveMemberResult) SizeVT() (n int)
- func (x *RemoveMemberResult) String() string
- func (m *RemoveMemberResult) UnmarshalVT(dAtA []byte) error
- type ScaleTopicRequest
- func (*ScaleTopicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScaleTopicRequest) GetPartitions() uint64
- func (x *ScaleTopicRequest) GetTopic() string
- func (m *ScaleTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ScaleTopicRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ScaleTopicRequest) MarshalVT() (dAtA []byte, err error)
- func (*ScaleTopicRequest) ProtoMessage()
- func (x *ScaleTopicRequest) ProtoReflect() protoreflect.Message
- func (x *ScaleTopicRequest) Reset()
- func (m *ScaleTopicRequest) SizeVT() (n int)
- func (x *ScaleTopicRequest) String() string
- func (m *ScaleTopicRequest) UnmarshalVT(dAtA []byte) error
- type ScaleTopicResponse
- func (*ScaleTopicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ScaleTopicResponse) GetLastIndex() uint64
- func (m *ScaleTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ScaleTopicResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ScaleTopicResponse) MarshalVT() (dAtA []byte, err error)
- func (*ScaleTopicResponse) ProtoMessage()
- func (x *ScaleTopicResponse) ProtoReflect() protoreflect.Message
- func (x *ScaleTopicResponse) Reset()
- func (m *ScaleTopicResponse) SizeVT() (n int)
- func (x *ScaleTopicResponse) String() string
- func (m *ScaleTopicResponse) UnmarshalVT(dAtA []byte) error
- type Snapshot
- func (*Snapshot) Descriptor() ([]byte, []int)deprecated
- func (m *Snapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Snapshot) MarshalToVT(dAtA []byte) (int, error)
- func (m *Snapshot) MarshalVT() (dAtA []byte, err error)
- func (*Snapshot) ProtoMessage()
- func (x *Snapshot) ProtoReflect() protoreflect.Message
- func (x *Snapshot) Reset()
- func (m *Snapshot) SizeVT() (n int)
- func (x *Snapshot) String() string
- func (m *Snapshot) UnmarshalVT(dAtA []byte) error
- type Topic
- func (*Topic) Descriptor() ([]byte, []int)deprecated
- func (x *Topic) GetName() string
- func (x *Topic) GetPartitions() map[uint64]*Partition
- func (m *Topic) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Topic) MarshalToVT(dAtA []byte) (int, error)
- func (m *Topic) MarshalVT() (dAtA []byte, err error)
- func (*Topic) ProtoMessage()
- func (x *Topic) ProtoReflect() protoreflect.Message
- func (x *Topic) Reset()
- func (m *Topic) SizeVT() (n int)
- func (x *Topic) String() string
- func (m *Topic) UnmarshalVT(dAtA []byte) error
- type UnimplementedMessageServiceServer
- func (UnimplementedMessageServiceServer) AckConsume(context.Context, *AckConsumeRequest) (*AckConsumeResponse, error)
- func (UnimplementedMessageServiceServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
- func (UnimplementedMessageServiceServer) CreateConsumer(context.Context, *CreateConsumerRequest) (*CreateConsumerResponse, error)
- func (UnimplementedMessageServiceServer) CreateConsumerGroup(context.Context, *CreateConsumerGroupRequest) (*CreateConsumerGroupResponse, error)
- func (UnimplementedMessageServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)
- func (UnimplementedMessageServiceServer) GetConsumerGroups(context.Context, *GetConsumerGroupsRequest) (*GetConsumerGroupsResponse, error)
- func (UnimplementedMessageServiceServer) GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)
- func (UnimplementedMessageServiceServer) PublishMessages(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)
- type UnsafeMessageServiceServer
- type WriteOperation
- func (*WriteOperation) Descriptor() ([]byte, []int)deprecated
- func (x *WriteOperation) GetAck() *Ack
- func (x *WriteOperation) GetAddMember() *AddMember
- func (x *WriteOperation) GetCode() Operation
- func (x *WriteOperation) GetCreateConsumer() *CreateConsumer
- func (x *WriteOperation) GetCreateConsumerGroup() *CreateConsumerGroup
- func (x *WriteOperation) GetCreateTopic() *CreateTopic
- func (m *WriteOperation) GetOperation() isWriteOperation_Operation
- func (x *WriteOperation) GetPublish() *Publish
- func (x *WriteOperation) GetRemoveMember() *RemoveMember
- func (m *WriteOperation) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *WriteOperation) MarshalToVT(dAtA []byte) (int, error)
- func (m *WriteOperation) MarshalVT() (dAtA []byte, err error)
- func (*WriteOperation) ProtoMessage()
- func (x *WriteOperation) ProtoReflect() protoreflect.Message
- func (x *WriteOperation) Reset()
- func (m *WriteOperation) SizeVT() (n int)
- func (x *WriteOperation) String() string
- func (m *WriteOperation) UnmarshalVT(dAtA []byte) error
- type WriteOperation_Ack
- type WriteOperation_AddMember
- type WriteOperation_CreateConsumer
- type WriteOperation_CreateConsumerGroup
- type WriteOperation_CreateTopic
- type WriteOperation_Publish
- type WriteOperation_RemoveMember
- type WriteResult
- func (*WriteResult) Descriptor() ([]byte, []int)deprecated
- func (x *WriteResult) GetAckResult() *AckResult
- func (x *WriteResult) GetAddMemberResult() *AddMemberResult
- func (x *WriteResult) GetCreateConsumerGroupResult() *CreateConsumerGroupResult
- func (x *WriteResult) GetCreateConsumerResult() *CreateConsumerResult
- func (x *WriteResult) GetCreateTopicResult() *CreateTopicResult
- func (x *WriteResult) GetPublishResult() *PublishResult
- func (x *WriteResult) GetRemoveMemberResult() *RemoveMemberResult
- func (m *WriteResult) GetResult() isWriteResult_Result
- func (m *WriteResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *WriteResult) MarshalToVT(dAtA []byte) (int, error)
- func (m *WriteResult) MarshalVT() (dAtA []byte, err error)
- func (*WriteResult) ProtoMessage()
- func (x *WriteResult) ProtoReflect() protoreflect.Message
- func (x *WriteResult) Reset()
- func (m *WriteResult) SizeVT() (n int)
- func (x *WriteResult) String() string
- func (m *WriteResult) UnmarshalVT(dAtA []byte) error
- type WriteResult_AckResult
- type WriteResult_AddMemberResult
- type WriteResult_CreateConsumerGroupResult
- type WriteResult_CreateConsumerResult
- type WriteResult_CreateTopicResult
- type WriteResult_PublishResult
- type WriteResult_RemoveMemberResult
Constants ¶
const ( MessageService_PublishMessages_FullMethodName = "/message.MessageService/PublishMessages" MessageService_CreateConsumer_FullMethodName = "/message.MessageService/CreateConsumer" MessageService_CreateConsumerGroup_FullMethodName = "/message.MessageService/CreateConsumerGroup" MessageService_GetConsumerGroups_FullMethodName = "/message.MessageService/GetConsumerGroups" MessageService_Consume_FullMethodName = "/message.MessageService/Consume" MessageService_CreateTopic_FullMethodName = "/message.MessageService/CreateTopic" MessageService_AckConsume_FullMethodName = "/message.MessageService/AckConsume" MessageService_GetMeta_FullMethodName = "/message.MessageService/GetMeta" )
Variables ¶
var ( Operation_name = map[int32]string{ 0: "PUBLISH", 1: "ACK", 2: "CREATE_CONSUMER", 3: "CREATE_TOPIC", 4: "ADD_MEMBER", 5: "REMOVE_MEMBER", 6: "CREATE_CONSUMER_GROUP", } Operation_value = map[string]int32{ "PUBLISH": 0, "ACK": 1, "CREATE_CONSUMER": 2, "CREATE_TOPIC": 3, "ADD_MEMBER": 4, "REMOVE_MEMBER": 5, "CREATE_CONSUMER_GROUP": 6, } )
Enum value maps for Operation.
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_service_proto protoreflect.FileDescriptor
var MessageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "message.MessageService", HandlerType: (*MessageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PublishMessages", Handler: _MessageService_PublishMessages_Handler, }, { MethodName: "CreateConsumer", Handler: _MessageService_CreateConsumer_Handler, }, { MethodName: "CreateConsumerGroup", Handler: _MessageService_CreateConsumerGroup_Handler, }, { MethodName: "GetConsumerGroups", Handler: _MessageService_GetConsumerGroups_Handler, }, { MethodName: "Consume", Handler: _MessageService_Consume_Handler, }, { MethodName: "CreateTopic", Handler: _MessageService_CreateTopic_Handler, }, { MethodName: "AckConsume", Handler: _MessageService_AckConsume_Handler, }, { MethodName: "GetMeta", Handler: _MessageService_GetMeta_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "service.proto", }
MessageService_ServiceDesc is the grpc.ServiceDesc for MessageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMessageServiceServer ¶
func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)
Types ¶
type Ack ¶
type Ack struct { Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */ GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*Ack) Descriptor
deprecated
func (*Ack) GetGroupId ¶
func (*Ack) GetOffsets ¶
func (*Ack) ProtoMessage ¶
func (*Ack) ProtoMessage()
func (*Ack) ProtoReflect ¶
func (x *Ack) ProtoReflect() protoreflect.Message
func (*Ack) UnmarshalVT ¶
type AckConsumeRequest ¶
type AckConsumeRequest struct { Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */ GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*AckConsumeRequest) Descriptor
deprecated
func (*AckConsumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AckConsumeRequest.ProtoReflect.Descriptor instead.
func (*AckConsumeRequest) GetGroupId ¶
func (x *AckConsumeRequest) GetGroupId() string
func (*AckConsumeRequest) GetOffsets ¶
func (x *AckConsumeRequest) GetOffsets() map[uint64]uint64
func (*AckConsumeRequest) GetTopic ¶
func (x *AckConsumeRequest) GetTopic() string
func (*AckConsumeRequest) MarshalToSizedBufferVT ¶
func (m *AckConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AckConsumeRequest) MarshalToVT ¶
func (m *AckConsumeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*AckConsumeRequest) MarshalVT ¶
func (m *AckConsumeRequest) MarshalVT() (dAtA []byte, err error)
func (*AckConsumeRequest) ProtoMessage ¶
func (*AckConsumeRequest) ProtoMessage()
func (*AckConsumeRequest) ProtoReflect ¶
func (x *AckConsumeRequest) ProtoReflect() protoreflect.Message
func (*AckConsumeRequest) Reset ¶
func (x *AckConsumeRequest) Reset()
func (*AckConsumeRequest) SizeVT ¶
func (m *AckConsumeRequest) SizeVT() (n int)
func (*AckConsumeRequest) String ¶
func (x *AckConsumeRequest) String() string
func (*AckConsumeRequest) UnmarshalVT ¶
func (m *AckConsumeRequest) UnmarshalVT(dAtA []byte) error
type AckConsumeResponse ¶
type AckConsumeResponse struct {
// contains filtered or unexported fields
}
func (*AckConsumeResponse) Descriptor
deprecated
func (*AckConsumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use AckConsumeResponse.ProtoReflect.Descriptor instead.
func (*AckConsumeResponse) MarshalToSizedBufferVT ¶
func (m *AckConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AckConsumeResponse) MarshalToVT ¶
func (m *AckConsumeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*AckConsumeResponse) MarshalVT ¶
func (m *AckConsumeResponse) MarshalVT() (dAtA []byte, err error)
func (*AckConsumeResponse) ProtoMessage ¶
func (*AckConsumeResponse) ProtoMessage()
func (*AckConsumeResponse) ProtoReflect ¶
func (x *AckConsumeResponse) ProtoReflect() protoreflect.Message
func (*AckConsumeResponse) Reset ¶
func (x *AckConsumeResponse) Reset()
func (*AckConsumeResponse) SizeVT ¶
func (m *AckConsumeResponse) SizeVT() (n int)
func (*AckConsumeResponse) String ¶
func (x *AckConsumeResponse) String() string
func (*AckConsumeResponse) UnmarshalVT ¶
func (m *AckConsumeResponse) UnmarshalVT(dAtA []byte) error
type AckResult ¶
type AckResult struct {
// contains filtered or unexported fields
}
func (*AckResult) Descriptor
deprecated
func (*AckResult) MarshalToSizedBufferVT ¶
func (*AckResult) ProtoMessage ¶
func (*AckResult) ProtoMessage()
func (*AckResult) ProtoReflect ¶
func (x *AckResult) ProtoReflect() protoreflect.Message
func (*AckResult) UnmarshalVT ¶
type AddMember ¶
type AddMember struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*AddMember) Descriptor
deprecated
func (*AddMember) GetAddress ¶
func (*AddMember) MarshalToSizedBufferVT ¶
func (*AddMember) ProtoMessage ¶
func (*AddMember) ProtoMessage()
func (*AddMember) ProtoReflect ¶
func (x *AddMember) ProtoReflect() protoreflect.Message
func (*AddMember) UnmarshalVT ¶
type AddMemberResult ¶
type AddMemberResult struct {
// contains filtered or unexported fields
}
func (*AddMemberResult) Descriptor
deprecated
func (*AddMemberResult) Descriptor() ([]byte, []int)
Deprecated: Use AddMemberResult.ProtoReflect.Descriptor instead.
func (*AddMemberResult) MarshalToSizedBufferVT ¶
func (m *AddMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*AddMemberResult) MarshalToVT ¶
func (m *AddMemberResult) MarshalToVT(dAtA []byte) (int, error)
func (*AddMemberResult) MarshalVT ¶
func (m *AddMemberResult) MarshalVT() (dAtA []byte, err error)
func (*AddMemberResult) ProtoMessage ¶
func (*AddMemberResult) ProtoMessage()
func (*AddMemberResult) ProtoReflect ¶
func (x *AddMemberResult) ProtoReflect() protoreflect.Message
func (*AddMemberResult) Reset ¶
func (x *AddMemberResult) Reset()
func (*AddMemberResult) SizeVT ¶
func (m *AddMemberResult) SizeVT() (n int)
func (*AddMemberResult) String ¶
func (x *AddMemberResult) String() string
func (*AddMemberResult) UnmarshalVT ¶
func (m *AddMemberResult) UnmarshalVT(dAtA []byte) error
type ConsumeRequest ¶
type ConsumeRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"` Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ConsumeRequest) Descriptor
deprecated
func (*ConsumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.
func (*ConsumeRequest) GetGroupId ¶
func (x *ConsumeRequest) GetGroupId() string
func (*ConsumeRequest) GetOffsets ¶
func (x *ConsumeRequest) GetOffsets() map[uint64]uint64
func (*ConsumeRequest) GetTopic ¶
func (x *ConsumeRequest) GetTopic() string
func (*ConsumeRequest) MarshalToSizedBufferVT ¶
func (m *ConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ConsumeRequest) MarshalToVT ¶
func (m *ConsumeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ConsumeRequest) MarshalVT ¶
func (m *ConsumeRequest) MarshalVT() (dAtA []byte, err error)
func (*ConsumeRequest) ProtoMessage ¶
func (*ConsumeRequest) ProtoMessage()
func (*ConsumeRequest) ProtoReflect ¶
func (x *ConsumeRequest) ProtoReflect() protoreflect.Message
func (*ConsumeRequest) Reset ¶
func (x *ConsumeRequest) Reset()
func (*ConsumeRequest) SizeVT ¶
func (m *ConsumeRequest) SizeVT() (n int)
func (*ConsumeRequest) String ¶
func (x *ConsumeRequest) String() string
func (*ConsumeRequest) UnmarshalVT ¶
func (m *ConsumeRequest) UnmarshalVT(dAtA []byte) error
type ConsumeResponse ¶
type ConsumeResponse struct { Messages map[uint64]*Messages `` /* 158-byte string literal not displayed */ LastIndex uint64 `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"` // contains filtered or unexported fields }
func (*ConsumeResponse) Descriptor
deprecated
func (*ConsumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.
func (*ConsumeResponse) GetLastIndex ¶
func (x *ConsumeResponse) GetLastIndex() uint64
func (*ConsumeResponse) GetMessages ¶
func (x *ConsumeResponse) GetMessages() map[uint64]*Messages
func (*ConsumeResponse) MarshalToSizedBufferVT ¶
func (m *ConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ConsumeResponse) MarshalToVT ¶
func (m *ConsumeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ConsumeResponse) MarshalVT ¶
func (m *ConsumeResponse) MarshalVT() (dAtA []byte, err error)
func (*ConsumeResponse) ProtoMessage ¶
func (*ConsumeResponse) ProtoMessage()
func (*ConsumeResponse) ProtoReflect ¶
func (x *ConsumeResponse) ProtoReflect() protoreflect.Message
func (*ConsumeResponse) Reset ¶
func (x *ConsumeResponse) Reset()
func (*ConsumeResponse) SizeVT ¶
func (m *ConsumeResponse) SizeVT() (n int)
func (*ConsumeResponse) String ¶
func (x *ConsumeResponse) String() string
func (*ConsumeResponse) UnmarshalVT ¶
func (m *ConsumeResponse) UnmarshalVT(dAtA []byte) error
type Consumer ¶
type Consumer struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Partition uint64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*Consumer) Descriptor
deprecated
func (*Consumer) GetPartition ¶
func (*Consumer) MarshalToSizedBufferVT ¶
func (*Consumer) ProtoMessage ¶
func (*Consumer) ProtoMessage()
func (*Consumer) ProtoReflect ¶
func (x *Consumer) ProtoReflect() protoreflect.Message
func (*Consumer) UnmarshalVT ¶
type ConsumerGroup ¶
type ConsumerGroup struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Consumers map[string]*Consumer `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ConsumerGroup) Descriptor
deprecated
func (*ConsumerGroup) Descriptor() ([]byte, []int)
Deprecated: Use ConsumerGroup.ProtoReflect.Descriptor instead.
func (*ConsumerGroup) GetConsumers ¶
func (x *ConsumerGroup) GetConsumers() map[string]*Consumer
func (*ConsumerGroup) GetId ¶
func (x *ConsumerGroup) GetId() string
func (*ConsumerGroup) MarshalToSizedBufferVT ¶
func (m *ConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ConsumerGroup) MarshalToVT ¶
func (m *ConsumerGroup) MarshalToVT(dAtA []byte) (int, error)
func (*ConsumerGroup) MarshalVT ¶
func (m *ConsumerGroup) MarshalVT() (dAtA []byte, err error)
func (*ConsumerGroup) ProtoMessage ¶
func (*ConsumerGroup) ProtoMessage()
func (*ConsumerGroup) ProtoReflect ¶
func (x *ConsumerGroup) ProtoReflect() protoreflect.Message
func (*ConsumerGroup) Reset ¶
func (x *ConsumerGroup) Reset()
func (*ConsumerGroup) SizeVT ¶
func (m *ConsumerGroup) SizeVT() (n int)
func (*ConsumerGroup) String ¶
func (x *ConsumerGroup) String() string
func (*ConsumerGroup) UnmarshalVT ¶
func (m *ConsumerGroup) UnmarshalVT(dAtA []byte) error
type CreateConsumer ¶
type CreateConsumer struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumer) Descriptor
deprecated
func (*CreateConsumer) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumer.ProtoReflect.Descriptor instead.
func (*CreateConsumer) GetGroupId ¶
func (x *CreateConsumer) GetGroupId() string
func (*CreateConsumer) GetTopic ¶
func (x *CreateConsumer) GetTopic() string
func (*CreateConsumer) MarshalToSizedBufferVT ¶
func (m *CreateConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumer) MarshalToVT ¶
func (m *CreateConsumer) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumer) MarshalVT ¶
func (m *CreateConsumer) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumer) ProtoMessage ¶
func (*CreateConsumer) ProtoMessage()
func (*CreateConsumer) ProtoReflect ¶
func (x *CreateConsumer) ProtoReflect() protoreflect.Message
func (*CreateConsumer) Reset ¶
func (x *CreateConsumer) Reset()
func (*CreateConsumer) SizeVT ¶
func (m *CreateConsumer) SizeVT() (n int)
func (*CreateConsumer) String ¶
func (x *CreateConsumer) String() string
func (*CreateConsumer) UnmarshalVT ¶
func (m *CreateConsumer) UnmarshalVT(dAtA []byte) error
type CreateConsumerGroup ¶
type CreateConsumerGroup struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerGroup) Descriptor
deprecated
func (*CreateConsumerGroup) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerGroup.ProtoReflect.Descriptor instead.
func (*CreateConsumerGroup) GetId ¶
func (x *CreateConsumerGroup) GetId() string
func (*CreateConsumerGroup) GetTopic ¶
func (x *CreateConsumerGroup) GetTopic() string
func (*CreateConsumerGroup) MarshalToSizedBufferVT ¶
func (m *CreateConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerGroup) MarshalToVT ¶
func (m *CreateConsumerGroup) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerGroup) MarshalVT ¶
func (m *CreateConsumerGroup) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerGroup) ProtoMessage ¶
func (*CreateConsumerGroup) ProtoMessage()
func (*CreateConsumerGroup) ProtoReflect ¶
func (x *CreateConsumerGroup) ProtoReflect() protoreflect.Message
func (*CreateConsumerGroup) Reset ¶
func (x *CreateConsumerGroup) Reset()
func (*CreateConsumerGroup) SizeVT ¶
func (m *CreateConsumerGroup) SizeVT() (n int)
func (*CreateConsumerGroup) String ¶
func (x *CreateConsumerGroup) String() string
func (*CreateConsumerGroup) UnmarshalVT ¶
func (m *CreateConsumerGroup) UnmarshalVT(dAtA []byte) error
type CreateConsumerGroupRequest ¶
type CreateConsumerGroupRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerGroupRequest) Descriptor
deprecated
func (*CreateConsumerGroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerGroupRequest.ProtoReflect.Descriptor instead.
func (*CreateConsumerGroupRequest) GetId ¶
func (x *CreateConsumerGroupRequest) GetId() string
func (*CreateConsumerGroupRequest) GetTopic ¶
func (x *CreateConsumerGroupRequest) GetTopic() string
func (*CreateConsumerGroupRequest) MarshalToSizedBufferVT ¶
func (m *CreateConsumerGroupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupRequest) MarshalToVT ¶
func (m *CreateConsumerGroupRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupRequest) MarshalVT ¶
func (m *CreateConsumerGroupRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerGroupRequest) ProtoMessage ¶
func (*CreateConsumerGroupRequest) ProtoMessage()
func (*CreateConsumerGroupRequest) ProtoReflect ¶
func (x *CreateConsumerGroupRequest) ProtoReflect() protoreflect.Message
func (*CreateConsumerGroupRequest) Reset ¶
func (x *CreateConsumerGroupRequest) Reset()
func (*CreateConsumerGroupRequest) SizeVT ¶
func (m *CreateConsumerGroupRequest) SizeVT() (n int)
func (*CreateConsumerGroupRequest) String ¶
func (x *CreateConsumerGroupRequest) String() string
func (*CreateConsumerGroupRequest) UnmarshalVT ¶
func (m *CreateConsumerGroupRequest) UnmarshalVT(dAtA []byte) error
type CreateConsumerGroupResponse ¶
type CreateConsumerGroupResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Group *ConsumerGroup `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` // contains filtered or unexported fields }
uuid for consumer group id
func (*CreateConsumerGroupResponse) Descriptor
deprecated
func (*CreateConsumerGroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerGroupResponse.ProtoReflect.Descriptor instead.
func (*CreateConsumerGroupResponse) GetGroup ¶
func (x *CreateConsumerGroupResponse) GetGroup() *ConsumerGroup
func (*CreateConsumerGroupResponse) GetId ¶
func (x *CreateConsumerGroupResponse) GetId() string
func (*CreateConsumerGroupResponse) MarshalToSizedBufferVT ¶
func (m *CreateConsumerGroupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupResponse) MarshalToVT ¶
func (m *CreateConsumerGroupResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupResponse) MarshalVT ¶
func (m *CreateConsumerGroupResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerGroupResponse) ProtoMessage ¶
func (*CreateConsumerGroupResponse) ProtoMessage()
func (*CreateConsumerGroupResponse) ProtoReflect ¶
func (x *CreateConsumerGroupResponse) ProtoReflect() protoreflect.Message
func (*CreateConsumerGroupResponse) Reset ¶
func (x *CreateConsumerGroupResponse) Reset()
func (*CreateConsumerGroupResponse) SizeVT ¶
func (m *CreateConsumerGroupResponse) SizeVT() (n int)
func (*CreateConsumerGroupResponse) String ¶
func (x *CreateConsumerGroupResponse) String() string
func (*CreateConsumerGroupResponse) UnmarshalVT ¶
func (m *CreateConsumerGroupResponse) UnmarshalVT(dAtA []byte) error
type CreateConsumerGroupResult ¶
type CreateConsumerGroupResult struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Consumers []*Consumer `protobuf:"bytes,2,rep,name=consumers,proto3" json:"consumers,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerGroupResult) Descriptor
deprecated
func (*CreateConsumerGroupResult) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerGroupResult.ProtoReflect.Descriptor instead.
func (*CreateConsumerGroupResult) GetConsumers ¶
func (x *CreateConsumerGroupResult) GetConsumers() []*Consumer
func (*CreateConsumerGroupResult) GetId ¶
func (x *CreateConsumerGroupResult) GetId() string
func (*CreateConsumerGroupResult) MarshalToSizedBufferVT ¶
func (m *CreateConsumerGroupResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupResult) MarshalToVT ¶
func (m *CreateConsumerGroupResult) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerGroupResult) MarshalVT ¶
func (m *CreateConsumerGroupResult) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerGroupResult) ProtoMessage ¶
func (*CreateConsumerGroupResult) ProtoMessage()
func (*CreateConsumerGroupResult) ProtoReflect ¶
func (x *CreateConsumerGroupResult) ProtoReflect() protoreflect.Message
func (*CreateConsumerGroupResult) Reset ¶
func (x *CreateConsumerGroupResult) Reset()
func (*CreateConsumerGroupResult) SizeVT ¶
func (m *CreateConsumerGroupResult) SizeVT() (n int)
func (*CreateConsumerGroupResult) String ¶
func (x *CreateConsumerGroupResult) String() string
func (*CreateConsumerGroupResult) UnmarshalVT ¶
func (m *CreateConsumerGroupResult) UnmarshalVT(dAtA []byte) error
type CreateConsumerRequest ¶
type CreateConsumerRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerRequest) Descriptor
deprecated
func (*CreateConsumerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerRequest.ProtoReflect.Descriptor instead.
func (*CreateConsumerRequest) GetGroupId ¶
func (x *CreateConsumerRequest) GetGroupId() string
func (*CreateConsumerRequest) GetTopic ¶
func (x *CreateConsumerRequest) GetTopic() string
func (*CreateConsumerRequest) MarshalToSizedBufferVT ¶
func (m *CreateConsumerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerRequest) MarshalToVT ¶
func (m *CreateConsumerRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerRequest) MarshalVT ¶
func (m *CreateConsumerRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerRequest) ProtoMessage ¶
func (*CreateConsumerRequest) ProtoMessage()
func (*CreateConsumerRequest) ProtoReflect ¶
func (x *CreateConsumerRequest) ProtoReflect() protoreflect.Message
func (*CreateConsumerRequest) Reset ¶
func (x *CreateConsumerRequest) Reset()
func (*CreateConsumerRequest) SizeVT ¶
func (m *CreateConsumerRequest) SizeVT() (n int)
func (*CreateConsumerRequest) String ¶
func (x *CreateConsumerRequest) String() string
func (*CreateConsumerRequest) UnmarshalVT ¶
func (m *CreateConsumerRequest) UnmarshalVT(dAtA []byte) error
type CreateConsumerResponse ¶
type CreateConsumerResponse struct { ConsumerId string `protobuf:"bytes,1,opt,name=consumerId,proto3" json:"consumerId,omitempty"` LastIndex uint64 `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerResponse) Descriptor
deprecated
func (*CreateConsumerResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerResponse.ProtoReflect.Descriptor instead.
func (*CreateConsumerResponse) GetConsumerId ¶
func (x *CreateConsumerResponse) GetConsumerId() string
func (*CreateConsumerResponse) GetLastIndex ¶
func (x *CreateConsumerResponse) GetLastIndex() uint64
func (*CreateConsumerResponse) MarshalToSizedBufferVT ¶
func (m *CreateConsumerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerResponse) MarshalToVT ¶
func (m *CreateConsumerResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerResponse) MarshalVT ¶
func (m *CreateConsumerResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerResponse) ProtoMessage ¶
func (*CreateConsumerResponse) ProtoMessage()
func (*CreateConsumerResponse) ProtoReflect ¶
func (x *CreateConsumerResponse) ProtoReflect() protoreflect.Message
func (*CreateConsumerResponse) Reset ¶
func (x *CreateConsumerResponse) Reset()
func (*CreateConsumerResponse) SizeVT ¶
func (m *CreateConsumerResponse) SizeVT() (n int)
func (*CreateConsumerResponse) String ¶
func (x *CreateConsumerResponse) String() string
func (*CreateConsumerResponse) UnmarshalVT ¶
func (m *CreateConsumerResponse) UnmarshalVT(dAtA []byte) error
type CreateConsumerResult ¶
type CreateConsumerResult struct { Consumer *Consumer `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"` // contains filtered or unexported fields }
func (*CreateConsumerResult) Descriptor
deprecated
func (*CreateConsumerResult) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerResult.ProtoReflect.Descriptor instead.
func (*CreateConsumerResult) GetConsumer ¶
func (x *CreateConsumerResult) GetConsumer() *Consumer
func (*CreateConsumerResult) MarshalToSizedBufferVT ¶
func (m *CreateConsumerResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateConsumerResult) MarshalToVT ¶
func (m *CreateConsumerResult) MarshalToVT(dAtA []byte) (int, error)
func (*CreateConsumerResult) MarshalVT ¶
func (m *CreateConsumerResult) MarshalVT() (dAtA []byte, err error)
func (*CreateConsumerResult) ProtoMessage ¶
func (*CreateConsumerResult) ProtoMessage()
func (*CreateConsumerResult) ProtoReflect ¶
func (x *CreateConsumerResult) ProtoReflect() protoreflect.Message
func (*CreateConsumerResult) Reset ¶
func (x *CreateConsumerResult) Reset()
func (*CreateConsumerResult) SizeVT ¶
func (m *CreateConsumerResult) SizeVT() (n int)
func (*CreateConsumerResult) String ¶
func (x *CreateConsumerResult) String() string
func (*CreateConsumerResult) UnmarshalVT ¶
func (m *CreateConsumerResult) UnmarshalVT(dAtA []byte) error
type CreateTopic ¶
type CreateTopic struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` // contains filtered or unexported fields }
func (*CreateTopic) Descriptor
deprecated
func (*CreateTopic) Descriptor() ([]byte, []int)
Deprecated: Use CreateTopic.ProtoReflect.Descriptor instead.
func (*CreateTopic) GetPartitions ¶
func (x *CreateTopic) GetPartitions() []uint64
func (*CreateTopic) GetTopic ¶
func (x *CreateTopic) GetTopic() string
func (*CreateTopic) MarshalToSizedBufferVT ¶
func (m *CreateTopic) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateTopic) MarshalToVT ¶
func (m *CreateTopic) MarshalToVT(dAtA []byte) (int, error)
func (*CreateTopic) MarshalVT ¶
func (m *CreateTopic) MarshalVT() (dAtA []byte, err error)
func (*CreateTopic) ProtoMessage ¶
func (*CreateTopic) ProtoMessage()
func (*CreateTopic) ProtoReflect ¶
func (x *CreateTopic) ProtoReflect() protoreflect.Message
func (*CreateTopic) Reset ¶
func (x *CreateTopic) Reset()
func (*CreateTopic) SizeVT ¶
func (m *CreateTopic) SizeVT() (n int)
func (*CreateTopic) String ¶
func (x *CreateTopic) String() string
func (*CreateTopic) UnmarshalVT ¶
func (m *CreateTopic) UnmarshalVT(dAtA []byte) error
type CreateTopicRequest ¶
type CreateTopicRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"` // contains filtered or unexported fields }
func (*CreateTopicRequest) Descriptor
deprecated
func (*CreateTopicRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.
func (*CreateTopicRequest) GetPartitions ¶
func (x *CreateTopicRequest) GetPartitions() []uint64
func (*CreateTopicRequest) GetTopic ¶
func (x *CreateTopicRequest) GetTopic() string
func (*CreateTopicRequest) MarshalToSizedBufferVT ¶
func (m *CreateTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateTopicRequest) MarshalToVT ¶
func (m *CreateTopicRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateTopicRequest) MarshalVT ¶
func (m *CreateTopicRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateTopicRequest) ProtoMessage ¶
func (*CreateTopicRequest) ProtoMessage()
func (*CreateTopicRequest) ProtoReflect ¶
func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message
func (*CreateTopicRequest) Reset ¶
func (x *CreateTopicRequest) Reset()
func (*CreateTopicRequest) SizeVT ¶
func (m *CreateTopicRequest) SizeVT() (n int)
func (*CreateTopicRequest) String ¶
func (x *CreateTopicRequest) String() string
func (*CreateTopicRequest) UnmarshalVT ¶
func (m *CreateTopicRequest) UnmarshalVT(dAtA []byte) error
type CreateTopicResponse ¶
type CreateTopicResponse struct {
// contains filtered or unexported fields
}
func (*CreateTopicResponse) Descriptor
deprecated
func (*CreateTopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTopicResponse.ProtoReflect.Descriptor instead.
func (*CreateTopicResponse) MarshalToSizedBufferVT ¶
func (m *CreateTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateTopicResponse) MarshalToVT ¶
func (m *CreateTopicResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateTopicResponse) MarshalVT ¶
func (m *CreateTopicResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateTopicResponse) ProtoMessage ¶
func (*CreateTopicResponse) ProtoMessage()
func (*CreateTopicResponse) ProtoReflect ¶
func (x *CreateTopicResponse) ProtoReflect() protoreflect.Message
func (*CreateTopicResponse) Reset ¶
func (x *CreateTopicResponse) Reset()
func (*CreateTopicResponse) SizeVT ¶
func (m *CreateTopicResponse) SizeVT() (n int)
func (*CreateTopicResponse) String ¶
func (x *CreateTopicResponse) String() string
func (*CreateTopicResponse) UnmarshalVT ¶
func (m *CreateTopicResponse) UnmarshalVT(dAtA []byte) error
type CreateTopicResult ¶
type CreateTopicResult struct {
// contains filtered or unexported fields
}
func (*CreateTopicResult) Descriptor
deprecated
func (*CreateTopicResult) Descriptor() ([]byte, []int)
Deprecated: Use CreateTopicResult.ProtoReflect.Descriptor instead.
func (*CreateTopicResult) MarshalToSizedBufferVT ¶
func (m *CreateTopicResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateTopicResult) MarshalToVT ¶
func (m *CreateTopicResult) MarshalToVT(dAtA []byte) (int, error)
func (*CreateTopicResult) MarshalVT ¶
func (m *CreateTopicResult) MarshalVT() (dAtA []byte, err error)
func (*CreateTopicResult) ProtoMessage ¶
func (*CreateTopicResult) ProtoMessage()
func (*CreateTopicResult) ProtoReflect ¶
func (x *CreateTopicResult) ProtoReflect() protoreflect.Message
func (*CreateTopicResult) Reset ¶
func (x *CreateTopicResult) Reset()
func (*CreateTopicResult) SizeVT ¶
func (m *CreateTopicResult) SizeVT() (n int)
func (*CreateTopicResult) String ¶
func (x *CreateTopicResult) String() string
func (*CreateTopicResult) UnmarshalVT ¶
func (m *CreateTopicResult) UnmarshalVT(dAtA []byte) error
type GetConsumerGroupsRequest ¶
type GetConsumerGroupsRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*GetConsumerGroupsRequest) Descriptor
deprecated
func (*GetConsumerGroupsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConsumerGroupsRequest.ProtoReflect.Descriptor instead.
func (*GetConsumerGroupsRequest) GetTopic ¶
func (x *GetConsumerGroupsRequest) GetTopic() string
func (*GetConsumerGroupsRequest) MarshalToSizedBufferVT ¶
func (m *GetConsumerGroupsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetConsumerGroupsRequest) MarshalToVT ¶
func (m *GetConsumerGroupsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*GetConsumerGroupsRequest) MarshalVT ¶
func (m *GetConsumerGroupsRequest) MarshalVT() (dAtA []byte, err error)
func (*GetConsumerGroupsRequest) ProtoMessage ¶
func (*GetConsumerGroupsRequest) ProtoMessage()
func (*GetConsumerGroupsRequest) ProtoReflect ¶
func (x *GetConsumerGroupsRequest) ProtoReflect() protoreflect.Message
func (*GetConsumerGroupsRequest) Reset ¶
func (x *GetConsumerGroupsRequest) Reset()
func (*GetConsumerGroupsRequest) SizeVT ¶
func (m *GetConsumerGroupsRequest) SizeVT() (n int)
func (*GetConsumerGroupsRequest) String ¶
func (x *GetConsumerGroupsRequest) String() string
func (*GetConsumerGroupsRequest) UnmarshalVT ¶
func (m *GetConsumerGroupsRequest) UnmarshalVT(dAtA []byte) error
type GetConsumerGroupsResponse ¶
type GetConsumerGroupsResponse struct { Groups map[string]*ConsumerGroup `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetConsumerGroupsResponse) Descriptor
deprecated
func (*GetConsumerGroupsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConsumerGroupsResponse.ProtoReflect.Descriptor instead.
func (*GetConsumerGroupsResponse) GetGroups ¶
func (x *GetConsumerGroupsResponse) GetGroups() map[string]*ConsumerGroup
func (*GetConsumerGroupsResponse) MarshalToSizedBufferVT ¶
func (m *GetConsumerGroupsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetConsumerGroupsResponse) MarshalToVT ¶
func (m *GetConsumerGroupsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*GetConsumerGroupsResponse) MarshalVT ¶
func (m *GetConsumerGroupsResponse) MarshalVT() (dAtA []byte, err error)
func (*GetConsumerGroupsResponse) ProtoMessage ¶
func (*GetConsumerGroupsResponse) ProtoMessage()
func (*GetConsumerGroupsResponse) ProtoReflect ¶
func (x *GetConsumerGroupsResponse) ProtoReflect() protoreflect.Message
func (*GetConsumerGroupsResponse) Reset ¶
func (x *GetConsumerGroupsResponse) Reset()
func (*GetConsumerGroupsResponse) SizeVT ¶
func (m *GetConsumerGroupsResponse) SizeVT() (n int)
func (*GetConsumerGroupsResponse) String ¶
func (x *GetConsumerGroupsResponse) String() string
func (*GetConsumerGroupsResponse) UnmarshalVT ¶
func (m *GetConsumerGroupsResponse) UnmarshalVT(dAtA []byte) error
type GetMetaRequest ¶
type GetMetaRequest struct {
// contains filtered or unexported fields
}
func (*GetMetaRequest) Descriptor
deprecated
func (*GetMetaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetaRequest.ProtoReflect.Descriptor instead.
func (*GetMetaRequest) MarshalToSizedBufferVT ¶
func (m *GetMetaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetMetaRequest) MarshalToVT ¶
func (m *GetMetaRequest) MarshalToVT(dAtA []byte) (int, error)
func (*GetMetaRequest) MarshalVT ¶
func (m *GetMetaRequest) MarshalVT() (dAtA []byte, err error)
func (*GetMetaRequest) ProtoMessage ¶
func (*GetMetaRequest) ProtoMessage()
func (*GetMetaRequest) ProtoReflect ¶
func (x *GetMetaRequest) ProtoReflect() protoreflect.Message
func (*GetMetaRequest) Reset ¶
func (x *GetMetaRequest) Reset()
func (*GetMetaRequest) SizeVT ¶
func (m *GetMetaRequest) SizeVT() (n int)
func (*GetMetaRequest) String ¶
func (x *GetMetaRequest) String() string
func (*GetMetaRequest) UnmarshalVT ¶
func (m *GetMetaRequest) UnmarshalVT(dAtA []byte) error
type GetMetaResponse ¶
type GetMetaResponse struct { Topics map[string]*Topic `` /* 153-byte string literal not displayed */ ConsumerGroups map[string]*ConsumerGroup `` /* 169-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetMetaResponse) Descriptor
deprecated
func (*GetMetaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetaResponse.ProtoReflect.Descriptor instead.
func (*GetMetaResponse) GetConsumerGroups ¶
func (x *GetMetaResponse) GetConsumerGroups() map[string]*ConsumerGroup
func (*GetMetaResponse) GetTopics ¶
func (x *GetMetaResponse) GetTopics() map[string]*Topic
func (*GetMetaResponse) MarshalToSizedBufferVT ¶
func (m *GetMetaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetMetaResponse) MarshalToVT ¶
func (m *GetMetaResponse) MarshalToVT(dAtA []byte) (int, error)
func (*GetMetaResponse) MarshalVT ¶
func (m *GetMetaResponse) MarshalVT() (dAtA []byte, err error)
func (*GetMetaResponse) ProtoMessage ¶
func (*GetMetaResponse) ProtoMessage()
func (*GetMetaResponse) ProtoReflect ¶
func (x *GetMetaResponse) ProtoReflect() protoreflect.Message
func (*GetMetaResponse) Reset ¶
func (x *GetMetaResponse) Reset()
func (*GetMetaResponse) SizeVT ¶
func (m *GetMetaResponse) SizeVT() (n int)
func (*GetMetaResponse) String ¶
func (x *GetMetaResponse) String() string
func (*GetMetaResponse) UnmarshalVT ¶
func (m *GetMetaResponse) UnmarshalVT(dAtA []byte) error
type KeyVal ¶
type KeyVal struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"` // contains filtered or unexported fields }
func (*KeyVal) Descriptor
deprecated
func (*KeyVal) MarshalToSizedBufferVT ¶
func (*KeyVal) ProtoMessage ¶
func (*KeyVal) ProtoMessage()
func (*KeyVal) ProtoReflect ¶
func (x *KeyVal) ProtoReflect() protoreflect.Message
func (*KeyVal) UnmarshalVT ¶
type Message ¶
type Message struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` Partition uint64 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` RaftIndex uint64 `protobuf:"varint,6,opt,name=raftIndex,proto3" json:"raftIndex,omitempty"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetPartition ¶
func (*Message) GetPayload ¶
func (*Message) GetRaftIndex ¶
func (*Message) MarshalToSizedBufferVT ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
func (*Message) UnmarshalVT ¶
type MessageServiceClient ¶
type MessageServiceClient interface { PublishMessages(ctx context.Context, in *PublishMessageRequest, opts ...grpc.CallOption) (*PublishMessageResponse, error) CreateConsumer(ctx context.Context, in *CreateConsumerRequest, opts ...grpc.CallOption) (*CreateConsumerResponse, error) CreateConsumerGroup(ctx context.Context, in *CreateConsumerGroupRequest, opts ...grpc.CallOption) (*CreateConsumerGroupResponse, error) GetConsumerGroups(ctx context.Context, in *GetConsumerGroupsRequest, opts ...grpc.CallOption) (*GetConsumerGroupsResponse, error) Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error) CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*CreateTopicResponse, error) AckConsume(ctx context.Context, in *AckConsumeRequest, opts ...grpc.CallOption) (*AckConsumeResponse, error) GetMeta(ctx context.Context, in *GetMetaRequest, opts ...grpc.CallOption) (*GetMetaResponse, error) }
MessageServiceClient is the client API for MessageService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMessageServiceClient ¶
func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient
type MessageServiceServer ¶
type MessageServiceServer interface { PublishMessages(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error) CreateConsumer(context.Context, *CreateConsumerRequest) (*CreateConsumerResponse, error) CreateConsumerGroup(context.Context, *CreateConsumerGroupRequest) (*CreateConsumerGroupResponse, error) GetConsumerGroups(context.Context, *GetConsumerGroupsRequest) (*GetConsumerGroupsResponse, error) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error) AckConsume(context.Context, *AckConsumeRequest) (*AckConsumeResponse, error) GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error) // contains filtered or unexported methods }
MessageServiceServer is the server API for MessageService service. All implementations must embed UnimplementedMessageServiceServer for forward compatibility
type Messages ¶
type Messages struct { Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*Messages) Descriptor
deprecated
func (*Messages) GetMessages ¶
func (*Messages) MarshalToSizedBufferVT ¶
func (*Messages) ProtoMessage ¶
func (*Messages) ProtoMessage()
func (*Messages) ProtoReflect ¶
func (x *Messages) ProtoReflect() protoreflect.Message
func (*Messages) UnmarshalVT ¶
type Operation ¶
type Operation int32
func (Operation) Descriptor ¶
func (Operation) Descriptor() protoreflect.EnumDescriptor
func (Operation) EnumDescriptor
deprecated
func (Operation) Number ¶
func (x Operation) Number() protoreflect.EnumNumber
func (Operation) Type ¶
func (Operation) Type() protoreflect.EnumType
type Partition ¶
type Partition struct { Num uint64 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*Partition) Descriptor
deprecated
func (*Partition) MarshalToSizedBufferVT ¶
func (*Partition) ProtoMessage ¶
func (*Partition) ProtoMessage()
func (*Partition) ProtoReflect ¶
func (x *Partition) ProtoReflect() protoreflect.Message
func (*Partition) UnmarshalVT ¶
type Publish ¶
type Publish struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Partition uint64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` Messages []*KeyVal `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*Publish) Descriptor
deprecated
func (*Publish) GetMessages ¶
func (*Publish) GetPartition ¶
func (*Publish) MarshalToSizedBufferVT ¶
func (*Publish) ProtoMessage ¶
func (*Publish) ProtoMessage()
func (*Publish) ProtoReflect ¶
func (x *Publish) ProtoReflect() protoreflect.Message
func (*Publish) UnmarshalVT ¶
type PublishMessageRequest ¶
type PublishMessageRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Partition uint64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` Messages []*KeyVal `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*PublishMessageRequest) Descriptor
deprecated
func (*PublishMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishMessageRequest.ProtoReflect.Descriptor instead.
func (*PublishMessageRequest) GetMessages ¶
func (x *PublishMessageRequest) GetMessages() []*KeyVal
func (*PublishMessageRequest) GetPartition ¶
func (x *PublishMessageRequest) GetPartition() uint64
func (*PublishMessageRequest) GetTopic ¶
func (x *PublishMessageRequest) GetTopic() string
func (*PublishMessageRequest) MarshalToSizedBufferVT ¶
func (m *PublishMessageRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PublishMessageRequest) MarshalToVT ¶
func (m *PublishMessageRequest) MarshalToVT(dAtA []byte) (int, error)
func (*PublishMessageRequest) MarshalVT ¶
func (m *PublishMessageRequest) MarshalVT() (dAtA []byte, err error)
func (*PublishMessageRequest) ProtoMessage ¶
func (*PublishMessageRequest) ProtoMessage()
func (*PublishMessageRequest) ProtoReflect ¶
func (x *PublishMessageRequest) ProtoReflect() protoreflect.Message
func (*PublishMessageRequest) Reset ¶
func (x *PublishMessageRequest) Reset()
func (*PublishMessageRequest) SizeVT ¶
func (m *PublishMessageRequest) SizeVT() (n int)
func (*PublishMessageRequest) String ¶
func (x *PublishMessageRequest) String() string
func (*PublishMessageRequest) UnmarshalVT ¶
func (m *PublishMessageRequest) UnmarshalVT(dAtA []byte) error
type PublishMessageResponse ¶
type PublishMessageResponse struct { Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` LastIndex uint64 `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"` // contains filtered or unexported fields }
func (*PublishMessageResponse) Descriptor
deprecated
func (*PublishMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishMessageResponse.ProtoReflect.Descriptor instead.
func (*PublishMessageResponse) GetLastIndex ¶
func (x *PublishMessageResponse) GetLastIndex() uint64
func (*PublishMessageResponse) GetMessages ¶
func (x *PublishMessageResponse) GetMessages() []*Message
func (*PublishMessageResponse) MarshalToSizedBufferVT ¶
func (m *PublishMessageResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PublishMessageResponse) MarshalToVT ¶
func (m *PublishMessageResponse) MarshalToVT(dAtA []byte) (int, error)
func (*PublishMessageResponse) MarshalVT ¶
func (m *PublishMessageResponse) MarshalVT() (dAtA []byte, err error)
func (*PublishMessageResponse) ProtoMessage ¶
func (*PublishMessageResponse) ProtoMessage()
func (*PublishMessageResponse) ProtoReflect ¶
func (x *PublishMessageResponse) ProtoReflect() protoreflect.Message
func (*PublishMessageResponse) Reset ¶
func (x *PublishMessageResponse) Reset()
func (*PublishMessageResponse) SizeVT ¶
func (m *PublishMessageResponse) SizeVT() (n int)
func (*PublishMessageResponse) String ¶
func (x *PublishMessageResponse) String() string
func (*PublishMessageResponse) UnmarshalVT ¶
func (m *PublishMessageResponse) UnmarshalVT(dAtA []byte) error
type PublishResult ¶
type PublishResult struct { Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*PublishResult) Descriptor
deprecated
func (*PublishResult) Descriptor() ([]byte, []int)
Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.
func (*PublishResult) GetMessages ¶
func (x *PublishResult) GetMessages() []*Message
func (*PublishResult) MarshalToSizedBufferVT ¶
func (m *PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PublishResult) MarshalToVT ¶
func (m *PublishResult) MarshalToVT(dAtA []byte) (int, error)
func (*PublishResult) MarshalVT ¶
func (m *PublishResult) MarshalVT() (dAtA []byte, err error)
func (*PublishResult) ProtoMessage ¶
func (*PublishResult) ProtoMessage()
func (*PublishResult) ProtoReflect ¶
func (x *PublishResult) ProtoReflect() protoreflect.Message
func (*PublishResult) Reset ¶
func (x *PublishResult) Reset()
func (*PublishResult) SizeVT ¶
func (m *PublishResult) SizeVT() (n int)
func (*PublishResult) String ¶
func (x *PublishResult) String() string
func (*PublishResult) UnmarshalVT ¶
func (m *PublishResult) UnmarshalVT(dAtA []byte) error
type RemoveMember ¶
type RemoveMember struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // contains filtered or unexported fields }
func (*RemoveMember) Descriptor
deprecated
func (*RemoveMember) Descriptor() ([]byte, []int)
Deprecated: Use RemoveMember.ProtoReflect.Descriptor instead.
func (*RemoveMember) GetNodeId ¶
func (x *RemoveMember) GetNodeId() string
func (*RemoveMember) MarshalToSizedBufferVT ¶
func (m *RemoveMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RemoveMember) MarshalToVT ¶
func (m *RemoveMember) MarshalToVT(dAtA []byte) (int, error)
func (*RemoveMember) MarshalVT ¶
func (m *RemoveMember) MarshalVT() (dAtA []byte, err error)
func (*RemoveMember) ProtoMessage ¶
func (*RemoveMember) ProtoMessage()
func (*RemoveMember) ProtoReflect ¶
func (x *RemoveMember) ProtoReflect() protoreflect.Message
func (*RemoveMember) Reset ¶
func (x *RemoveMember) Reset()
func (*RemoveMember) SizeVT ¶
func (m *RemoveMember) SizeVT() (n int)
func (*RemoveMember) String ¶
func (x *RemoveMember) String() string
func (*RemoveMember) UnmarshalVT ¶
func (m *RemoveMember) UnmarshalVT(dAtA []byte) error
type RemoveMemberResult ¶
type RemoveMemberResult struct {
// contains filtered or unexported fields
}
func (*RemoveMemberResult) Descriptor
deprecated
func (*RemoveMemberResult) Descriptor() ([]byte, []int)
Deprecated: Use RemoveMemberResult.ProtoReflect.Descriptor instead.
func (*RemoveMemberResult) MarshalToSizedBufferVT ¶
func (m *RemoveMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RemoveMemberResult) MarshalToVT ¶
func (m *RemoveMemberResult) MarshalToVT(dAtA []byte) (int, error)
func (*RemoveMemberResult) MarshalVT ¶
func (m *RemoveMemberResult) MarshalVT() (dAtA []byte, err error)
func (*RemoveMemberResult) ProtoMessage ¶
func (*RemoveMemberResult) ProtoMessage()
func (*RemoveMemberResult) ProtoReflect ¶
func (x *RemoveMemberResult) ProtoReflect() protoreflect.Message
func (*RemoveMemberResult) Reset ¶
func (x *RemoveMemberResult) Reset()
func (*RemoveMemberResult) SizeVT ¶
func (m *RemoveMemberResult) SizeVT() (n int)
func (*RemoveMemberResult) String ¶
func (x *RemoveMemberResult) String() string
func (*RemoveMemberResult) UnmarshalVT ¶
func (m *RemoveMemberResult) UnmarshalVT(dAtA []byte) error
type ScaleTopicRequest ¶
type ScaleTopicRequest struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Partitions uint64 `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"` // contains filtered or unexported fields }
func (*ScaleTopicRequest) Descriptor
deprecated
func (*ScaleTopicRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScaleTopicRequest.ProtoReflect.Descriptor instead.
func (*ScaleTopicRequest) GetPartitions ¶
func (x *ScaleTopicRequest) GetPartitions() uint64
func (*ScaleTopicRequest) GetTopic ¶
func (x *ScaleTopicRequest) GetTopic() string
func (*ScaleTopicRequest) MarshalToSizedBufferVT ¶
func (m *ScaleTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ScaleTopicRequest) MarshalToVT ¶
func (m *ScaleTopicRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ScaleTopicRequest) MarshalVT ¶
func (m *ScaleTopicRequest) MarshalVT() (dAtA []byte, err error)
func (*ScaleTopicRequest) ProtoMessage ¶
func (*ScaleTopicRequest) ProtoMessage()
func (*ScaleTopicRequest) ProtoReflect ¶
func (x *ScaleTopicRequest) ProtoReflect() protoreflect.Message
func (*ScaleTopicRequest) Reset ¶
func (x *ScaleTopicRequest) Reset()
func (*ScaleTopicRequest) SizeVT ¶
func (m *ScaleTopicRequest) SizeVT() (n int)
func (*ScaleTopicRequest) String ¶
func (x *ScaleTopicRequest) String() string
func (*ScaleTopicRequest) UnmarshalVT ¶
func (m *ScaleTopicRequest) UnmarshalVT(dAtA []byte) error
type ScaleTopicResponse ¶
type ScaleTopicResponse struct { LastIndex uint64 `protobuf:"varint,1,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"` // contains filtered or unexported fields }
func (*ScaleTopicResponse) Descriptor
deprecated
func (*ScaleTopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScaleTopicResponse.ProtoReflect.Descriptor instead.
func (*ScaleTopicResponse) GetLastIndex ¶
func (x *ScaleTopicResponse) GetLastIndex() uint64
func (*ScaleTopicResponse) MarshalToSizedBufferVT ¶
func (m *ScaleTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ScaleTopicResponse) MarshalToVT ¶
func (m *ScaleTopicResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ScaleTopicResponse) MarshalVT ¶
func (m *ScaleTopicResponse) MarshalVT() (dAtA []byte, err error)
func (*ScaleTopicResponse) ProtoMessage ¶
func (*ScaleTopicResponse) ProtoMessage()
func (*ScaleTopicResponse) ProtoReflect ¶
func (x *ScaleTopicResponse) ProtoReflect() protoreflect.Message
func (*ScaleTopicResponse) Reset ¶
func (x *ScaleTopicResponse) Reset()
func (*ScaleTopicResponse) SizeVT ¶
func (m *ScaleTopicResponse) SizeVT() (n int)
func (*ScaleTopicResponse) String ¶
func (x *ScaleTopicResponse) String() string
func (*ScaleTopicResponse) UnmarshalVT ¶
func (m *ScaleTopicResponse) UnmarshalVT(dAtA []byte) error
type Snapshot ¶
type Snapshot struct {
// contains filtered or unexported fields
}
func (*Snapshot) Descriptor
deprecated
func (*Snapshot) MarshalToSizedBufferVT ¶
func (*Snapshot) ProtoMessage ¶
func (*Snapshot) ProtoMessage()
func (*Snapshot) ProtoReflect ¶
func (x *Snapshot) ProtoReflect() protoreflect.Message
func (*Snapshot) UnmarshalVT ¶
type Topic ¶
type Topic struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Partitions map[uint64]*Partition `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Topic) Descriptor
deprecated
func (*Topic) GetPartitions ¶
func (*Topic) MarshalToSizedBufferVT ¶
func (*Topic) ProtoMessage ¶
func (*Topic) ProtoMessage()
func (*Topic) ProtoReflect ¶
func (x *Topic) ProtoReflect() protoreflect.Message
func (*Topic) UnmarshalVT ¶
type UnimplementedMessageServiceServer ¶
type UnimplementedMessageServiceServer struct { }
UnimplementedMessageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMessageServiceServer) AckConsume ¶
func (UnimplementedMessageServiceServer) AckConsume(context.Context, *AckConsumeRequest) (*AckConsumeResponse, error)
func (UnimplementedMessageServiceServer) Consume ¶
func (UnimplementedMessageServiceServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
func (UnimplementedMessageServiceServer) CreateConsumer ¶
func (UnimplementedMessageServiceServer) CreateConsumer(context.Context, *CreateConsumerRequest) (*CreateConsumerResponse, error)
func (UnimplementedMessageServiceServer) CreateConsumerGroup ¶
func (UnimplementedMessageServiceServer) CreateConsumerGroup(context.Context, *CreateConsumerGroupRequest) (*CreateConsumerGroupResponse, error)
func (UnimplementedMessageServiceServer) CreateTopic ¶
func (UnimplementedMessageServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)
func (UnimplementedMessageServiceServer) GetConsumerGroups ¶
func (UnimplementedMessageServiceServer) GetConsumerGroups(context.Context, *GetConsumerGroupsRequest) (*GetConsumerGroupsResponse, error)
func (UnimplementedMessageServiceServer) GetMeta ¶
func (UnimplementedMessageServiceServer) GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)
func (UnimplementedMessageServiceServer) PublishMessages ¶
func (UnimplementedMessageServiceServer) PublishMessages(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)
type UnsafeMessageServiceServer ¶
type UnsafeMessageServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMessageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MessageServiceServer will result in compilation errors.
type WriteOperation ¶
type WriteOperation struct { // Types that are assignable to Operation: // // *WriteOperation_Publish // *WriteOperation_Ack // *WriteOperation_CreateConsumer // *WriteOperation_CreateTopic // *WriteOperation_AddMember // *WriteOperation_RemoveMember // *WriteOperation_CreateConsumerGroup Operation isWriteOperation_Operation `protobuf_oneof:"operation"` Code Operation `protobuf:"varint,8,opt,name=code,proto3,enum=message.Operation" json:"code,omitempty"` // contains filtered or unexported fields }
func (*WriteOperation) Descriptor
deprecated
func (*WriteOperation) Descriptor() ([]byte, []int)
Deprecated: Use WriteOperation.ProtoReflect.Descriptor instead.
func (*WriteOperation) GetAck ¶
func (x *WriteOperation) GetAck() *Ack
func (*WriteOperation) GetAddMember ¶
func (x *WriteOperation) GetAddMember() *AddMember
func (*WriteOperation) GetCode ¶
func (x *WriteOperation) GetCode() Operation
func (*WriteOperation) GetCreateConsumer ¶
func (x *WriteOperation) GetCreateConsumer() *CreateConsumer
func (*WriteOperation) GetCreateConsumerGroup ¶
func (x *WriteOperation) GetCreateConsumerGroup() *CreateConsumerGroup
func (*WriteOperation) GetCreateTopic ¶
func (x *WriteOperation) GetCreateTopic() *CreateTopic
func (*WriteOperation) GetOperation ¶
func (m *WriteOperation) GetOperation() isWriteOperation_Operation
func (*WriteOperation) GetPublish ¶
func (x *WriteOperation) GetPublish() *Publish
func (*WriteOperation) GetRemoveMember ¶
func (x *WriteOperation) GetRemoveMember() *RemoveMember
func (*WriteOperation) MarshalToSizedBufferVT ¶
func (m *WriteOperation) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation) MarshalToVT ¶
func (m *WriteOperation) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation) MarshalVT ¶
func (m *WriteOperation) MarshalVT() (dAtA []byte, err error)
func (*WriteOperation) ProtoMessage ¶
func (*WriteOperation) ProtoMessage()
func (*WriteOperation) ProtoReflect ¶
func (x *WriteOperation) ProtoReflect() protoreflect.Message
func (*WriteOperation) Reset ¶
func (x *WriteOperation) Reset()
func (*WriteOperation) SizeVT ¶
func (m *WriteOperation) SizeVT() (n int)
func (*WriteOperation) String ¶
func (x *WriteOperation) String() string
func (*WriteOperation) UnmarshalVT ¶
func (m *WriteOperation) UnmarshalVT(dAtA []byte) error
type WriteOperation_Ack ¶
type WriteOperation_Ack struct {
Ack *Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}
func (*WriteOperation_Ack) MarshalToSizedBufferVT ¶
func (m *WriteOperation_Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_Ack) MarshalToVT ¶
func (m *WriteOperation_Ack) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_Ack) SizeVT ¶
func (m *WriteOperation_Ack) SizeVT() (n int)
type WriteOperation_AddMember ¶
type WriteOperation_AddMember struct {
AddMember *AddMember `protobuf:"bytes,5,opt,name=addMember,proto3,oneof"`
}
func (*WriteOperation_AddMember) MarshalToSizedBufferVT ¶
func (m *WriteOperation_AddMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_AddMember) MarshalToVT ¶
func (m *WriteOperation_AddMember) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_AddMember) SizeVT ¶
func (m *WriteOperation_AddMember) SizeVT() (n int)
type WriteOperation_CreateConsumer ¶
type WriteOperation_CreateConsumer struct {
CreateConsumer *CreateConsumer `protobuf:"bytes,3,opt,name=createConsumer,proto3,oneof"`
}
func (*WriteOperation_CreateConsumer) MarshalToSizedBufferVT ¶
func (m *WriteOperation_CreateConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateConsumer) MarshalToVT ¶
func (m *WriteOperation_CreateConsumer) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateConsumer) SizeVT ¶
func (m *WriteOperation_CreateConsumer) SizeVT() (n int)
type WriteOperation_CreateConsumerGroup ¶
type WriteOperation_CreateConsumerGroup struct {
CreateConsumerGroup *CreateConsumerGroup `protobuf:"bytes,7,opt,name=createConsumerGroup,proto3,oneof"`
}
func (*WriteOperation_CreateConsumerGroup) MarshalToSizedBufferVT ¶
func (m *WriteOperation_CreateConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateConsumerGroup) MarshalToVT ¶
func (m *WriteOperation_CreateConsumerGroup) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateConsumerGroup) SizeVT ¶
func (m *WriteOperation_CreateConsumerGroup) SizeVT() (n int)
type WriteOperation_CreateTopic ¶
type WriteOperation_CreateTopic struct {
CreateTopic *CreateTopic `protobuf:"bytes,4,opt,name=createTopic,proto3,oneof"`
}
func (*WriteOperation_CreateTopic) MarshalToSizedBufferVT ¶
func (m *WriteOperation_CreateTopic) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateTopic) MarshalToVT ¶
func (m *WriteOperation_CreateTopic) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_CreateTopic) SizeVT ¶
func (m *WriteOperation_CreateTopic) SizeVT() (n int)
type WriteOperation_Publish ¶
type WriteOperation_Publish struct {
Publish *Publish `protobuf:"bytes,1,opt,name=publish,proto3,oneof"`
}
func (*WriteOperation_Publish) MarshalToSizedBufferVT ¶
func (m *WriteOperation_Publish) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_Publish) MarshalToVT ¶
func (m *WriteOperation_Publish) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_Publish) SizeVT ¶
func (m *WriteOperation_Publish) SizeVT() (n int)
type WriteOperation_RemoveMember ¶
type WriteOperation_RemoveMember struct {
RemoveMember *RemoveMember `protobuf:"bytes,6,opt,name=removeMember,proto3,oneof"`
}
func (*WriteOperation_RemoveMember) MarshalToSizedBufferVT ¶
func (m *WriteOperation_RemoveMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteOperation_RemoveMember) MarshalToVT ¶
func (m *WriteOperation_RemoveMember) MarshalToVT(dAtA []byte) (int, error)
func (*WriteOperation_RemoveMember) SizeVT ¶
func (m *WriteOperation_RemoveMember) SizeVT() (n int)
type WriteResult ¶
type WriteResult struct { // Types that are assignable to Result: // // *WriteResult_PublishResult // *WriteResult_AckResult // *WriteResult_CreateConsumerResult // *WriteResult_CreateTopicResult // *WriteResult_AddMemberResult // *WriteResult_RemoveMemberResult // *WriteResult_CreateConsumerGroupResult Result isWriteResult_Result `protobuf_oneof:"result"` // contains filtered or unexported fields }
func (*WriteResult) Descriptor
deprecated
func (*WriteResult) Descriptor() ([]byte, []int)
Deprecated: Use WriteResult.ProtoReflect.Descriptor instead.
func (*WriteResult) GetAckResult ¶
func (x *WriteResult) GetAckResult() *AckResult
func (*WriteResult) GetAddMemberResult ¶
func (x *WriteResult) GetAddMemberResult() *AddMemberResult
func (*WriteResult) GetCreateConsumerGroupResult ¶
func (x *WriteResult) GetCreateConsumerGroupResult() *CreateConsumerGroupResult
func (*WriteResult) GetCreateConsumerResult ¶
func (x *WriteResult) GetCreateConsumerResult() *CreateConsumerResult
func (*WriteResult) GetCreateTopicResult ¶
func (x *WriteResult) GetCreateTopicResult() *CreateTopicResult
func (*WriteResult) GetPublishResult ¶
func (x *WriteResult) GetPublishResult() *PublishResult
func (*WriteResult) GetRemoveMemberResult ¶
func (x *WriteResult) GetRemoveMemberResult() *RemoveMemberResult
func (*WriteResult) GetResult ¶
func (m *WriteResult) GetResult() isWriteResult_Result
func (*WriteResult) MarshalToSizedBufferVT ¶
func (m *WriteResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult) MarshalToVT ¶
func (m *WriteResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult) MarshalVT ¶
func (m *WriteResult) MarshalVT() (dAtA []byte, err error)
func (*WriteResult) ProtoMessage ¶
func (*WriteResult) ProtoMessage()
func (*WriteResult) ProtoReflect ¶
func (x *WriteResult) ProtoReflect() protoreflect.Message
func (*WriteResult) Reset ¶
func (x *WriteResult) Reset()
func (*WriteResult) SizeVT ¶
func (m *WriteResult) SizeVT() (n int)
func (*WriteResult) String ¶
func (x *WriteResult) String() string
func (*WriteResult) UnmarshalVT ¶
func (m *WriteResult) UnmarshalVT(dAtA []byte) error
type WriteResult_AckResult ¶
type WriteResult_AckResult struct {
AckResult *AckResult `protobuf:"bytes,2,opt,name=ackResult,proto3,oneof"`
}
func (*WriteResult_AckResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_AckResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_AckResult) MarshalToVT ¶
func (m *WriteResult_AckResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_AckResult) SizeVT ¶
func (m *WriteResult_AckResult) SizeVT() (n int)
type WriteResult_AddMemberResult ¶
type WriteResult_AddMemberResult struct {
AddMemberResult *AddMemberResult `protobuf:"bytes,5,opt,name=addMemberResult,proto3,oneof"`
}
func (*WriteResult_AddMemberResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_AddMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_AddMemberResult) MarshalToVT ¶
func (m *WriteResult_AddMemberResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_AddMemberResult) SizeVT ¶
func (m *WriteResult_AddMemberResult) SizeVT() (n int)
type WriteResult_CreateConsumerGroupResult ¶
type WriteResult_CreateConsumerGroupResult struct {
CreateConsumerGroupResult *CreateConsumerGroupResult `protobuf:"bytes,7,opt,name=createConsumerGroupResult,proto3,oneof"`
}
func (*WriteResult_CreateConsumerGroupResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_CreateConsumerGroupResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_CreateConsumerGroupResult) MarshalToVT ¶
func (m *WriteResult_CreateConsumerGroupResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_CreateConsumerGroupResult) SizeVT ¶
func (m *WriteResult_CreateConsumerGroupResult) SizeVT() (n int)
type WriteResult_CreateConsumerResult ¶
type WriteResult_CreateConsumerResult struct {
CreateConsumerResult *CreateConsumerResult `protobuf:"bytes,3,opt,name=createConsumerResult,proto3,oneof"`
}
func (*WriteResult_CreateConsumerResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_CreateConsumerResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_CreateConsumerResult) MarshalToVT ¶
func (m *WriteResult_CreateConsumerResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_CreateConsumerResult) SizeVT ¶
func (m *WriteResult_CreateConsumerResult) SizeVT() (n int)
type WriteResult_CreateTopicResult ¶
type WriteResult_CreateTopicResult struct {
CreateTopicResult *CreateTopicResult `protobuf:"bytes,4,opt,name=createTopicResult,proto3,oneof"`
}
func (*WriteResult_CreateTopicResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_CreateTopicResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_CreateTopicResult) MarshalToVT ¶
func (m *WriteResult_CreateTopicResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_CreateTopicResult) SizeVT ¶
func (m *WriteResult_CreateTopicResult) SizeVT() (n int)
type WriteResult_PublishResult ¶
type WriteResult_PublishResult struct {
PublishResult *PublishResult `protobuf:"bytes,1,opt,name=publishResult,proto3,oneof"`
}
func (*WriteResult_PublishResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_PublishResult) MarshalToVT ¶
func (m *WriteResult_PublishResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_PublishResult) SizeVT ¶
func (m *WriteResult_PublishResult) SizeVT() (n int)
type WriteResult_RemoveMemberResult ¶
type WriteResult_RemoveMemberResult struct {
RemoveMemberResult *RemoveMemberResult `protobuf:"bytes,6,opt,name=removeMemberResult,proto3,oneof"`
}
func (*WriteResult_RemoveMemberResult) MarshalToSizedBufferVT ¶
func (m *WriteResult_RemoveMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteResult_RemoveMemberResult) MarshalToVT ¶
func (m *WriteResult_RemoveMemberResult) MarshalToVT(dAtA []byte) (int, error)
func (*WriteResult_RemoveMemberResult) SizeVT ¶
func (m *WriteResult_RemoveMemberResult) SizeVT() (n int)