Documentation ¶
Overview ¶
Package coordgrpc is a generated protocol buffer package.
It is generated from these files:
coord_grpc.proto
It has these top-level messages:
CoordErr RpcTopicData ChannelConsumerOffset CommitLogData NsqdMessage RpcChannelOffsetArg RpcPutMessage RpcPutMessages
Index ¶
- func RegisterNsqdCoordRpcV2Server(s *grpc.Server, srv NsqdCoordRpcV2Server)
- type ChannelConsumerOffset
- type CommitLogData
- type CoordErr
- type NsqdCoordRpcV2Client
- type NsqdCoordRpcV2Server
- type NsqdMessage
- type RpcChannelOffsetArg
- func (*RpcChannelOffsetArg) Descriptor() ([]byte, []int)
- func (m *RpcChannelOffsetArg) GetChannelOffset() *ChannelConsumerOffset
- func (m *RpcChannelOffsetArg) GetTopicData() *RpcTopicData
- func (*RpcChannelOffsetArg) ProtoMessage()
- func (m *RpcChannelOffsetArg) Reset()
- func (m *RpcChannelOffsetArg) String() string
- type RpcPutMessage
- func (*RpcPutMessage) Descriptor() ([]byte, []int)
- func (m *RpcPutMessage) GetLogData() *CommitLogData
- func (m *RpcPutMessage) GetTopicData() *RpcTopicData
- func (m *RpcPutMessage) GetTopicMessage() *NsqdMessage
- func (*RpcPutMessage) ProtoMessage()
- func (m *RpcPutMessage) Reset()
- func (m *RpcPutMessage) String() string
- type RpcPutMessages
- func (*RpcPutMessages) Descriptor() ([]byte, []int)
- func (m *RpcPutMessages) GetLogData() *CommitLogData
- func (m *RpcPutMessages) GetTopicData() *RpcTopicData
- func (m *RpcPutMessages) GetTopicMessage() []*NsqdMessage
- func (*RpcPutMessages) ProtoMessage()
- func (m *RpcPutMessages) Reset()
- func (m *RpcPutMessages) String() string
- type RpcTopicData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterNsqdCoordRpcV2Server ¶
func RegisterNsqdCoordRpcV2Server(s *grpc.Server, srv NsqdCoordRpcV2Server)
Types ¶
type ChannelConsumerOffset ¶
type ChannelConsumerOffset struct { Voffset int64 `protobuf:"varint,1,opt,name=voffset" json:"voffset,omitempty"` Flush bool `protobuf:"varint,2,opt,name=flush" json:"flush,omitempty"` AllowBackward bool `protobuf:"varint,3,opt,name=allow_backward,json=allowBackward" json:"allow_backward,omitempty"` }
func (*ChannelConsumerOffset) Descriptor ¶
func (*ChannelConsumerOffset) Descriptor() ([]byte, []int)
func (*ChannelConsumerOffset) ProtoMessage ¶
func (*ChannelConsumerOffset) ProtoMessage()
func (*ChannelConsumerOffset) Reset ¶
func (m *ChannelConsumerOffset) Reset()
func (*ChannelConsumerOffset) String ¶
func (m *ChannelConsumerOffset) String() string
type CommitLogData ¶
type CommitLogData struct { LogID int64 `protobuf:"varint,1,opt,name=logID" json:"logID,omitempty"` Epoch int64 `protobuf:"varint,2,opt,name=epoch" json:"epoch,omitempty"` LastMsgLogID int64 `protobuf:"varint,3,opt,name=last_msg_logID,json=lastMsgLogID" json:"last_msg_logID,omitempty"` MsgOffset int64 `protobuf:"varint,4,opt,name=msg_offset,json=msgOffset" json:"msg_offset,omitempty"` MsgSize int32 `protobuf:"varint,5,opt,name=msg_size,json=msgSize" json:"msg_size,omitempty"` MsgCnt int64 `protobuf:"varint,6,opt,name=msg_cnt,json=msgCnt" json:"msg_cnt,omitempty"` MsgNum int32 `protobuf:"varint,7,opt,name=msg_num,json=msgNum" json:"msg_num,omitempty"` }
func (*CommitLogData) Descriptor ¶
func (*CommitLogData) Descriptor() ([]byte, []int)
func (*CommitLogData) ProtoMessage ¶
func (*CommitLogData) ProtoMessage()
func (*CommitLogData) Reset ¶
func (m *CommitLogData) Reset()
func (*CommitLogData) String ¶
func (m *CommitLogData) String() string
type CoordErr ¶
type NsqdCoordRpcV2Client ¶
type NsqdCoordRpcV2Client interface { UpdateChannelOffset(ctx context.Context, in *RpcChannelOffsetArg, opts ...grpc.CallOption) (*CoordErr, error) PutMessage(ctx context.Context, in *RpcPutMessage, opts ...grpc.CallOption) (*CoordErr, error) PutMessages(ctx context.Context, in *RpcPutMessages, opts ...grpc.CallOption) (*CoordErr, error) }
func NewNsqdCoordRpcV2Client ¶
func NewNsqdCoordRpcV2Client(cc *grpc.ClientConn) NsqdCoordRpcV2Client
type NsqdCoordRpcV2Server ¶
type NsqdCoordRpcV2Server interface { UpdateChannelOffset(context.Context, *RpcChannelOffsetArg) (*CoordErr, error) PutMessage(context.Context, *RpcPutMessage) (*CoordErr, error) PutMessages(context.Context, *RpcPutMessages) (*CoordErr, error) }
type NsqdMessage ¶
type NsqdMessage struct { ID uint64 `protobuf:"varint,1,opt,name=ID,json=iD" json:"ID,omitempty"` Trace_ID uint64 `protobuf:"varint,2,opt,name=trace_ID,json=traceID" json:"trace_ID,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` Timestamp int64 `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"` Attemps uint32 `protobuf:"varint,5,opt,name=attemps" json:"attemps,omitempty"` }
func (*NsqdMessage) Descriptor ¶
func (*NsqdMessage) Descriptor() ([]byte, []int)
func (*NsqdMessage) ProtoMessage ¶
func (*NsqdMessage) ProtoMessage()
func (*NsqdMessage) Reset ¶
func (m *NsqdMessage) Reset()
func (*NsqdMessage) String ¶
func (m *NsqdMessage) String() string
type RpcChannelOffsetArg ¶
type RpcChannelOffsetArg struct { TopicData *RpcTopicData `protobuf:"bytes,1,opt,name=topic_data,json=topicData" json:"topic_data,omitempty"` Channel string `protobuf:"bytes,2,opt,name=channel" json:"channel,omitempty"` ChannelOffset *ChannelConsumerOffset `protobuf:"bytes,3,opt,name=channel_offset,json=channelOffset" json:"channel_offset,omitempty"` }
func (*RpcChannelOffsetArg) Descriptor ¶
func (*RpcChannelOffsetArg) Descriptor() ([]byte, []int)
func (*RpcChannelOffsetArg) GetChannelOffset ¶
func (m *RpcChannelOffsetArg) GetChannelOffset() *ChannelConsumerOffset
func (*RpcChannelOffsetArg) GetTopicData ¶
func (m *RpcChannelOffsetArg) GetTopicData() *RpcTopicData
func (*RpcChannelOffsetArg) ProtoMessage ¶
func (*RpcChannelOffsetArg) ProtoMessage()
func (*RpcChannelOffsetArg) Reset ¶
func (m *RpcChannelOffsetArg) Reset()
func (*RpcChannelOffsetArg) String ¶
func (m *RpcChannelOffsetArg) String() string
type RpcPutMessage ¶
type RpcPutMessage struct { TopicData *RpcTopicData `protobuf:"bytes,1,opt,name=topic_data,json=topicData" json:"topic_data,omitempty"` LogData *CommitLogData `protobuf:"bytes,2,opt,name=log_data,json=logData" json:"log_data,omitempty"` TopicMessage *NsqdMessage `protobuf:"bytes,3,opt,name=topic_message,json=topicMessage" json:"topic_message,omitempty"` }
func (*RpcPutMessage) Descriptor ¶
func (*RpcPutMessage) Descriptor() ([]byte, []int)
func (*RpcPutMessage) GetLogData ¶
func (m *RpcPutMessage) GetLogData() *CommitLogData
func (*RpcPutMessage) GetTopicData ¶
func (m *RpcPutMessage) GetTopicData() *RpcTopicData
func (*RpcPutMessage) GetTopicMessage ¶
func (m *RpcPutMessage) GetTopicMessage() *NsqdMessage
func (*RpcPutMessage) ProtoMessage ¶
func (*RpcPutMessage) ProtoMessage()
func (*RpcPutMessage) Reset ¶
func (m *RpcPutMessage) Reset()
func (*RpcPutMessage) String ¶
func (m *RpcPutMessage) String() string
type RpcPutMessages ¶
type RpcPutMessages struct { TopicData *RpcTopicData `protobuf:"bytes,1,opt,name=topic_data,json=topicData" json:"topic_data,omitempty"` LogData *CommitLogData `protobuf:"bytes,2,opt,name=log_data,json=logData" json:"log_data,omitempty"` TopicMessage []*NsqdMessage `protobuf:"bytes,3,rep,name=topic_message,json=topicMessage" json:"topic_message,omitempty"` }
func (*RpcPutMessages) Descriptor ¶
func (*RpcPutMessages) Descriptor() ([]byte, []int)
func (*RpcPutMessages) GetLogData ¶
func (m *RpcPutMessages) GetLogData() *CommitLogData
func (*RpcPutMessages) GetTopicData ¶
func (m *RpcPutMessages) GetTopicData() *RpcTopicData
func (*RpcPutMessages) GetTopicMessage ¶
func (m *RpcPutMessages) GetTopicMessage() []*NsqdMessage
func (*RpcPutMessages) ProtoMessage ¶
func (*RpcPutMessages) ProtoMessage()
func (*RpcPutMessages) Reset ¶
func (m *RpcPutMessages) Reset()
func (*RpcPutMessages) String ¶
func (m *RpcPutMessages) String() string
type RpcTopicData ¶
type RpcTopicData struct { TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName" json:"topic_name,omitempty"` TopicPartition int32 `protobuf:"varint,2,opt,name=topic_partition,json=topicPartition" json:"topic_partition,omitempty"` Epoch int64 `protobuf:"varint,3,opt,name=epoch" json:"epoch,omitempty"` TopicWriteEpoch int64 `protobuf:"varint,4,opt,name=topic_write_epoch,json=topicWriteEpoch" json:"topic_write_epoch,omitempty"` TopicLeaderSessionEpoch int64 `` /* 128-byte string literal not displayed */ TopicLeaderSession string `protobuf:"bytes,6,opt,name=topic_leader_session,json=topicLeaderSession" json:"topic_leader_session,omitempty"` }
func (*RpcTopicData) Descriptor ¶
func (*RpcTopicData) Descriptor() ([]byte, []int)
func (*RpcTopicData) ProtoMessage ¶
func (*RpcTopicData) ProtoMessage()
func (*RpcTopicData) Reset ¶
func (m *RpcTopicData) Reset()
func (*RpcTopicData) String ¶
func (m *RpcTopicData) String() string
Click to show internal directories.
Click to hide internal directories.