coordgrpc

package
v0.3.7-HA.1.9.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2019 License: MIT Imports: 7 Imported by: 0

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
MsgQueueInterval
ChannelConsumerOffset
CommitLogData
NsqdMessage
RpcChannelOffsetArg
RpcPutMessage
RpcPutMessages
PullCommitLogsReq
PullCommitLogsRsp

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCoordGrpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCoordGrpc   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterNsqdCoordRpcV2Server 

func RegisterNsqdCoordRpcV2Server(s *grpc.Server, srv NsqdCoordRpcV2Server)

Types

type ChannelConsumerOffset 

type ChannelConsumerOffset struct {
	Voffset             int64              `protobuf:"varint,1,opt,name=voffset,proto3" json:"voffset,omitempty"`
	Flush               bool               `protobuf:"varint,2,opt,name=flush,proto3" json:"flush,omitempty"`
	AllowBackward       bool               `protobuf:"varint,3,opt,name=allow_backward,json=allowBackward,proto3" json:"allow_backward,omitempty"`
	Vcnt                int64              `protobuf:"varint,4,opt,name=vcnt,proto3" json:"vcnt,omitempty"`
	NeedUpdateConfirmed bool               `protobuf:"varint,5,opt,name=need_update_confirmed,json=needUpdateConfirmed,proto3" json:"need_update_confirmed,omitempty"`
	ConfirmedIntervals  []MsgQueueInterval `protobuf:"bytes,6,rep,name=confirmed_intervals,json=confirmedIntervals" json:"confirmed_intervals"`
}

func (*ChannelConsumerOffset) Descriptor 

func (*ChannelConsumerOffset) Descriptor() ([]byte, []int)

func (*ChannelConsumerOffset) Marshal 

func (m *ChannelConsumerOffset) Marshal() (dAtA []byte, err error)

func (*ChannelConsumerOffset) MarshalTo 

func (m *ChannelConsumerOffset) MarshalTo(dAtA []byte) (int, error)

func (*ChannelConsumerOffset) ProtoMessage 

func (*ChannelConsumerOffset) ProtoMessage()

func (*ChannelConsumerOffset) Reset 

func (m *ChannelConsumerOffset) Reset()

func (*ChannelConsumerOffset) Size 

func (m *ChannelConsumerOffset) Size() (n int)

func (*ChannelConsumerOffset) String 

func (m *ChannelConsumerOffset) String() string

func (*ChannelConsumerOffset) Unmarshal 

func (m *ChannelConsumerOffset) Unmarshal(dAtA []byte) error

type CommitLogData 

type CommitLogData struct {
	LogID        int64 `protobuf:"varint,1,opt,name=logID,proto3" json:"logID,omitempty"`
	Epoch        int64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	LastMsgLogID int64 `protobuf:"varint,3,opt,name=last_msg_logID,json=lastMsgLogID,proto3" json:"last_msg_logID,omitempty"`
	MsgOffset    int64 `protobuf:"varint,4,opt,name=msg_offset,json=msgOffset,proto3" json:"msg_offset,omitempty"`
	MsgSize      int32 `protobuf:"varint,5,opt,name=msg_size,json=msgSize,proto3" json:"msg_size,omitempty"`
	MsgCnt       int64 `protobuf:"varint,6,opt,name=msg_cnt,json=msgCnt,proto3" json:"msg_cnt,omitempty"`
	MsgNum       int32 `protobuf:"varint,7,opt,name=msg_num,json=msgNum,proto3" json:"msg_num,omitempty"`
}

func (*CommitLogData) Descriptor 

func (*CommitLogData) Descriptor() ([]byte, []int)

func (*CommitLogData) Marshal 

func (m *CommitLogData) Marshal() (dAtA []byte, err error)

func (*CommitLogData) MarshalTo 

func (m *CommitLogData) MarshalTo(dAtA []byte) (int, error)

func (*CommitLogData) ProtoMessage 

func (*CommitLogData) ProtoMessage()

func (*CommitLogData) Reset 

func (m *CommitLogData) Reset()

func (*CommitLogData) Size 

func (m *CommitLogData) Size() (n int)

func (*CommitLogData) String 

func (m *CommitLogData) String() string

func (*CommitLogData) Unmarshal 

func (m *CommitLogData) Unmarshal(dAtA []byte) error

type CoordErr 

type CoordErr struct {
	ErrMsg  string `protobuf:"bytes,1,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	ErrCode int32  `protobuf:"varint,2,opt,name=err_code,json=errCode,proto3" json:"err_code,omitempty"`
	ErrType int32  `protobuf:"varint,3,opt,name=err_type,json=errType,proto3" json:"err_type,omitempty"`
}

func (*CoordErr) Descriptor 

func (*CoordErr) Descriptor() ([]byte, []int)

func (*CoordErr) Marshal 

func (m *CoordErr) Marshal() (dAtA []byte, err error)

func (*CoordErr) MarshalTo 

func (m *CoordErr) MarshalTo(dAtA []byte) (int, error)

func (*CoordErr) ProtoMessage 

func (*CoordErr) ProtoMessage()

func (*CoordErr) Reset 

func (m *CoordErr) Reset()

func (*CoordErr) Size 

func (m *CoordErr) Size() (n int)

func (*CoordErr) String 

func (m *CoordErr) String() string

func (*CoordErr) Unmarshal 

func (m *CoordErr) Unmarshal(dAtA []byte) error

type MsgQueueInterval 

type MsgQueueInterval struct {
	Start  int64  `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End    int64  `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	EndCnt uint64 `protobuf:"varint,3,opt,name=end_cnt,json=endCnt,proto3" json:"end_cnt,omitempty"`
}

func (*MsgQueueInterval) Descriptor 

func (*MsgQueueInterval) Descriptor() ([]byte, []int)

func (*MsgQueueInterval) Marshal 

func (m *MsgQueueInterval) Marshal() (dAtA []byte, err error)

func (*MsgQueueInterval) MarshalTo 

func (m *MsgQueueInterval) MarshalTo(dAtA []byte) (int, error)

func (*MsgQueueInterval) ProtoMessage 

func (*MsgQueueInterval) ProtoMessage()

func (*MsgQueueInterval) Reset 

func (m *MsgQueueInterval) Reset()

func (*MsgQueueInterval) Size 

func (m *MsgQueueInterval) Size() (n int)

func (*MsgQueueInterval) String 

func (m *MsgQueueInterval) String() string

func (*MsgQueueInterval) Unmarshal 

func (m *MsgQueueInterval) Unmarshal(dAtA []byte) error

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)
	PullCommitLogsAndData(ctx context.Context, in *PullCommitLogsReq, opts ...grpc.CallOption) (*PullCommitLogsRsp, error)
	PullDelayedQueueCommitLogsAndData(ctx context.Context, in *PullCommitLogsReq, opts ...grpc.CallOption) (*PullCommitLogsRsp, 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)
	PullCommitLogsAndData(context.Context, *PullCommitLogsReq) (*PullCommitLogsRsp, error)
	PullDelayedQueueCommitLogsAndData(context.Context, *PullCommitLogsReq) (*PullCommitLogsRsp, error)
}

type NsqdMessage 

type NsqdMessage struct {
	ID        uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Trace_ID  uint64 `protobuf:"varint,2,opt,name=trace_ID,json=traceID,proto3" json:"trace_ID,omitempty"`
	Body      []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Attemps   uint32 `protobuf:"varint,5,opt,name=attemps,proto3" json:"attemps,omitempty"`
}

func (*NsqdMessage) Descriptor 

func (*NsqdMessage) Descriptor() ([]byte, []int)

func (*NsqdMessage) Marshal 

func (m *NsqdMessage) Marshal() (dAtA []byte, err error)

func (*NsqdMessage) MarshalTo 

func (m *NsqdMessage) MarshalTo(dAtA []byte) (int, error)

func (*NsqdMessage) ProtoMessage 

func (*NsqdMessage) ProtoMessage()

func (*NsqdMessage) Reset 

func (m *NsqdMessage) Reset()

func (*NsqdMessage) Size 

func (m *NsqdMessage) Size() (n int)

func (*NsqdMessage) String 

func (m *NsqdMessage) String() string

func (*NsqdMessage) Unmarshal 

func (m *NsqdMessage) Unmarshal(dAtA []byte) error

type PullCommitLogsReq 

type PullCommitLogsReq struct {
	TopicData        *RpcTopicData `protobuf:"bytes,1,opt,name=topic_data,json=topicData" json:"topic_data,omitempty"`
	StartLogOffset   int64         `protobuf:"varint,2,opt,name=start_log_offset,json=startLogOffset,proto3" json:"start_log_offset,omitempty"`
	LogMaxNum        int32         `protobuf:"varint,3,opt,name=log_max_num,json=logMaxNum,proto3" json:"log_max_num,omitempty"`
	StartIndexCnt    int64         `protobuf:"varint,4,opt,name=start_index_cnt,json=startIndexCnt,proto3" json:"start_index_cnt,omitempty"`
	LogCountNumIndex int64         `protobuf:"varint,5,opt,name=log_count_num_index,json=logCountNumIndex,proto3" json:"log_count_num_index,omitempty"`
	UseCountIndex    bool          `protobuf:"varint,6,opt,name=use_count_index,json=useCountIndex,proto3" json:"use_count_index,omitempty"`
}

func (*PullCommitLogsReq) Descriptor 

func (*PullCommitLogsReq) Descriptor() ([]byte, []int)

func (*PullCommitLogsReq) Marshal 

func (m *PullCommitLogsReq) Marshal() (dAtA []byte, err error)

func (*PullCommitLogsReq) MarshalTo 

func (m *PullCommitLogsReq) MarshalTo(dAtA []byte) (int, error)

func (*PullCommitLogsReq) ProtoMessage 

func (*PullCommitLogsReq) ProtoMessage()

func (*PullCommitLogsReq) Reset 

func (m *PullCommitLogsReq) Reset()

func (*PullCommitLogsReq) Size 

func (m *PullCommitLogsReq) Size() (n int)

func (*PullCommitLogsReq) String 

func (m *PullCommitLogsReq) String() string

func (*PullCommitLogsReq) Unmarshal 

func (m *PullCommitLogsReq) Unmarshal(dAtA []byte) error

type PullCommitLogsRsp 

type PullCommitLogsRsp struct {
	Logs     []CommitLogData `protobuf:"bytes,1,rep,name=logs" json:"logs"`
	DataList [][]byte        `protobuf:"bytes,2,rep,name=data_list,json=dataList" json:"data_list,omitempty"`
}

func (*PullCommitLogsRsp) Descriptor 

func (*PullCommitLogsRsp) Descriptor() ([]byte, []int)

func (*PullCommitLogsRsp) Marshal 

func (m *PullCommitLogsRsp) Marshal() (dAtA []byte, err error)

func (*PullCommitLogsRsp) MarshalTo 

func (m *PullCommitLogsRsp) MarshalTo(dAtA []byte) (int, error)

func (*PullCommitLogsRsp) ProtoMessage 

func (*PullCommitLogsRsp) ProtoMessage()

func (*PullCommitLogsRsp) Reset 

func (m *PullCommitLogsRsp) Reset()

func (*PullCommitLogsRsp) Size 

func (m *PullCommitLogsRsp) Size() (n int)

func (*PullCommitLogsRsp) String 

func (m *PullCommitLogsRsp) String() string

func (*PullCommitLogsRsp) Unmarshal 

func (m *PullCommitLogsRsp) Unmarshal(dAtA []byte) error

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,proto3" 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) Marshal 

func (m *RpcChannelOffsetArg) Marshal() (dAtA []byte, err error)

func (*RpcChannelOffsetArg) MarshalTo 

func (m *RpcChannelOffsetArg) MarshalTo(dAtA []byte) (int, error)

func (*RpcChannelOffsetArg) ProtoMessage 

func (*RpcChannelOffsetArg) ProtoMessage()

func (*RpcChannelOffsetArg) Reset 

func (m *RpcChannelOffsetArg) Reset()

func (*RpcChannelOffsetArg) Size 

func (m *RpcChannelOffsetArg) Size() (n int)

func (*RpcChannelOffsetArg) String 

func (m *RpcChannelOffsetArg) String() string

func (*RpcChannelOffsetArg) Unmarshal 

func (m *RpcChannelOffsetArg) Unmarshal(dAtA []byte) error

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"`
	TopicRawMessage []byte         `protobuf:"bytes,4,opt,name=topic_raw_message,json=topicRawMessage,proto3" json:"topic_raw_message,omitempty"`
}

func (*RpcPutMessage) Descriptor 

func (*RpcPutMessage) Descriptor() ([]byte, []int)

func (*RpcPutMessage) Marshal 

func (m *RpcPutMessage) Marshal() (dAtA []byte, err error)

func (*RpcPutMessage) MarshalTo 

func (m *RpcPutMessage) MarshalTo(dAtA []byte) (int, error)

func (*RpcPutMessage) ProtoMessage 

func (*RpcPutMessage) ProtoMessage()

func (*RpcPutMessage) Reset 

func (m *RpcPutMessage) Reset()

func (*RpcPutMessage) Size 

func (m *RpcPutMessage) Size() (n int)

func (*RpcPutMessage) String 

func (m *RpcPutMessage) String() string

func (*RpcPutMessage) Unmarshal 

func (m *RpcPutMessage) Unmarshal(dAtA []byte) error

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"`
	TopicRawMessage []byte         `protobuf:"bytes,4,opt,name=topic_raw_message,json=topicRawMessage,proto3" json:"topic_raw_message,omitempty"`
}

func (*RpcPutMessages) Descriptor 

func (*RpcPutMessages) Descriptor() ([]byte, []int)

func (*RpcPutMessages) Marshal 

func (m *RpcPutMessages) Marshal() (dAtA []byte, err error)

func (*RpcPutMessages) MarshalTo 

func (m *RpcPutMessages) MarshalTo(dAtA []byte) (int, error)

func (*RpcPutMessages) ProtoMessage 

func (*RpcPutMessages) ProtoMessage()

func (*RpcPutMessages) Reset 

func (m *RpcPutMessages) Reset()

func (*RpcPutMessages) Size 

func (m *RpcPutMessages) Size() (n int)

func (*RpcPutMessages) String 

func (m *RpcPutMessages) String() string

func (*RpcPutMessages) Unmarshal 

func (m *RpcPutMessages) Unmarshal(dAtA []byte) error

type RpcTopicData 

type RpcTopicData struct {
	TopicName               string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	TopicPartition          int32  `protobuf:"varint,2,opt,name=topic_partition,json=topicPartition,proto3" json:"topic_partition,omitempty"`
	Epoch                   int64  `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	TopicWriteEpoch         int64  `protobuf:"varint,4,opt,name=topic_write_epoch,json=topicWriteEpoch,proto3" json:"topic_write_epoch,omitempty"`
	TopicLeaderSessionEpoch int64  `` /* 135-byte string literal not displayed */
	TopicLeaderSession      string `protobuf:"bytes,6,opt,name=topic_leader_session,json=topicLeaderSession,proto3" json:"topic_leader_session,omitempty"`
	TopicLeader             string `protobuf:"bytes,7,opt,name=topic_leader,json=topicLeader,proto3" json:"topic_leader,omitempty"`
}

func (*RpcTopicData) Descriptor 

func (*RpcTopicData) Descriptor() ([]byte, []int)

func (*RpcTopicData) Marshal 

func (m *RpcTopicData) Marshal() (dAtA []byte, err error)

func (*RpcTopicData) MarshalTo 

func (m *RpcTopicData) MarshalTo(dAtA []byte) (int, error)

func (*RpcTopicData) ProtoMessage 

func (*RpcTopicData) ProtoMessage()

func (*RpcTopicData) Reset 

func (m *RpcTopicData) Reset()

func (*RpcTopicData) Size 

func (m *RpcTopicData) Size() (n int)

func (*RpcTopicData) String 

func (m *RpcTopicData) String() string

func (*RpcTopicData) Unmarshal 

func (m *RpcTopicData) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.