coordgrpc

package
v0.3.7-HA.1.6.5.win Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2017 License: MIT Imports: 5 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
ChannelConsumerOffset
CommitLogData
NsqdMessage
RpcChannelOffsetArg
RpcPutMessage
RpcPutMessages

Index

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 CoordErr struct {
	ErrMsg  string `protobuf:"bytes,1,opt,name=err_msg,json=errMsg" json:"err_msg,omitempty"`
	ErrCode int32  `protobuf:"varint,2,opt,name=err_code,json=errCode" json:"err_code,omitempty"`
	ErrType int32  `protobuf:"varint,3,opt,name=err_type,json=errType" json:"err_type,omitempty"`
}

func (*CoordErr) Descriptor 

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

func (*CoordErr) ProtoMessage 

func (*CoordErr) ProtoMessage()

func (*CoordErr) Reset 

func (m *CoordErr) Reset()

func (*CoordErr) String 

func (m *CoordErr) String() string

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

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.