v1

Documentation

Overview

Package v1 is a generated protocol buffer package.

It is generated from these files:

app/service/main/reply-feed/api/api.proto

It has these top-level messages:

HotReplyReq
HotReplyRes
ReplyReq
ReplyRes

Index

• Constants
• Variables
• func RegisterReplyFeedServer(s *grpc.Server, srv ReplyFeedServer)
• type HotReplyReq
  • func (*HotReplyReq) Descriptor() ([]byte, []int)
  • func (m *HotReplyReq) GetMid() int64
  • func (m *HotReplyReq) GetOid() int64
  • func (m *HotReplyReq) GetPn() int32
  • func (m *HotReplyReq) GetPs() int32
  • func (m *HotReplyReq) GetTp() int32
  • func (m *HotReplyReq) Marshal() (dAtA []byte, err error)
  • func (m *HotReplyReq) MarshalTo(dAtA []byte) (int, error)
  • func (*HotReplyReq) ProtoMessage()
  • func (m *HotReplyReq) Reset()
  • func (m *HotReplyReq) Size() (n int)
  • func (m *HotReplyReq) String() string
  • func (m *HotReplyReq) Unmarshal(dAtA []byte) error
• type HotReplyRes
  • func (*HotReplyRes) Descriptor() ([]byte, []int)
  • func (m *HotReplyRes) GetCount() int32
  • func (m *HotReplyRes) GetName() string
  • func (m *HotReplyRes) GetRpIDs() []int64
  • func (m *HotReplyRes) Marshal() (dAtA []byte, err error)
  • func (m *HotReplyRes) MarshalTo(dAtA []byte) (int, error)
  • func (*HotReplyRes) ProtoMessage()
  • func (m *HotReplyRes) Reset()
  • func (m *HotReplyRes) Size() (n int)
  • func (m *HotReplyRes) String() string
  • func (m *HotReplyRes) Unmarshal(dAtA []byte) error
• type ReplyFeedClient
  • func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (ReplyFeedClient, error)
  • func NewReplyFeedClient(cc *grpc.ClientConn) ReplyFeedClient
• type ReplyFeedServer
• type ReplyReq
  • func (*ReplyReq) Descriptor() ([]byte, []int)
  • func (m *ReplyReq) GetMid() int64
  • func (m *ReplyReq) GetPn() int32
  • func (m *ReplyReq) GetPs() int32
  • func (m *ReplyReq) Marshal() (dAtA []byte, err error)
  • func (m *ReplyReq) MarshalTo(dAtA []byte) (int, error)
  • func (*ReplyReq) ProtoMessage()
  • func (m *ReplyReq) Reset()
  • func (m *ReplyReq) Size() (n int)
  • func (m *ReplyReq) String() string
  • func (m *ReplyReq) Unmarshal(dAtA []byte) error
• type ReplyRes
  • func (*ReplyRes) Descriptor() ([]byte, []int)
  • func (m *ReplyRes) GetName() string
  • func (m *ReplyRes) Marshal() (dAtA []byte, err error)
  • func (m *ReplyRes) MarshalTo(dAtA []byte) (int, error)
  • func (*ReplyRes) ProtoMessage()
  • func (m *ReplyRes) Reset()
  • func (m *ReplyRes) Size() (n int)
  • func (m *ReplyRes) String() string
  • func (m *ReplyRes) Unmarshal(dAtA []byte) error

Constants

const AppID = "community.reply.feed"

AppID unique app id for service discovery

Variables

var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterReplyFeedServer

func RegisterReplyFeedServer(s *grpc.Server, srv ReplyFeedServer)

Types

type HotReplyReq

type HotReplyReq struct {
	Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	Oid int64 `protobuf:"varint,2,opt,name=oid,proto3" json:"oid,omitempty"`
	Tp  int32 `protobuf:"varint,3,opt,name=tp,proto3" json:"tp,omitempty"`
	Pn  int32 `protobuf:"varint,4,opt,name=pn,proto3" json:"pn,omitempty"`
	Ps  int32 `protobuf:"varint,5,opt,name=ps,proto3" json:"ps,omitempty"`
}

func (*HotReplyReq) Descriptor

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

func (*HotReplyReq) GetMid

func (m *HotReplyReq) GetMid() int64

func (*HotReplyReq) GetOid

func (m *HotReplyReq) GetOid() int64

func (*HotReplyReq) GetPn

func (m *HotReplyReq) GetPn() int32

func (*HotReplyReq) GetPs

func (m *HotReplyReq) GetPs() int32

func (*HotReplyReq) GetTp

func (m *HotReplyReq) GetTp() int32

func (*HotReplyReq) Marshal

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

func (*HotReplyReq) MarshalTo

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

func (*HotReplyReq) ProtoMessage

func (*HotReplyReq) ProtoMessage()

func (*HotReplyReq) Reset

func (m *HotReplyReq) Reset()

func (*HotReplyReq) Size

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

func (*HotReplyReq) String

func (m *HotReplyReq) String() string

func (*HotReplyReq) Unmarshal

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

type HotReplyRes

type HotReplyRes struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RpIDs []int64 `protobuf:"varint,2,rep,packed,name=rpIDs" json:"rpIDs,omitempty"`
	Count int32   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
}

func (*HotReplyRes) Descriptor

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

func (*HotReplyRes) GetCount

func (m *HotReplyRes) GetCount() int32

func (*HotReplyRes) GetName

func (m *HotReplyRes) GetName() string

func (*HotReplyRes) GetRpIDs

func (m *HotReplyRes) GetRpIDs() []int64

func (*HotReplyRes) Marshal

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

func (*HotReplyRes) MarshalTo

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

func (*HotReplyRes) ProtoMessage

func (*HotReplyRes) ProtoMessage()

func (*HotReplyRes) Reset

func (m *HotReplyRes) Reset()

func (*HotReplyRes) Size

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

func (*HotReplyRes) String

func (m *HotReplyRes) String() string

func (*HotReplyRes) Unmarshal

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

type ReplyFeedClient

type ReplyFeedClient interface {
	HotReply(ctx context.Context, in *HotReplyReq, opts ...grpc.CallOption) (*HotReplyRes, error)
	Reply(ctx context.Context, in *ReplyReq, opts ...grpc.CallOption) (*ReplyRes, error)
}

func NewClient

func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (ReplyFeedClient, error)

NewClient new identify grpc client

func NewReplyFeedClient

func NewReplyFeedClient(cc *grpc.ClientConn) ReplyFeedClient

type ReplyFeedServer

type ReplyFeedServer interface {
	HotReply(context.Context, *HotReplyReq) (*HotReplyRes, error)
	Reply(context.Context, *ReplyReq) (*ReplyRes, error)
}

type ReplyReq

type ReplyReq struct {
	Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	Pn  int32 `protobuf:"varint,2,opt,name=pn,proto3" json:"pn,omitempty"`
	Ps  int32 `protobuf:"varint,3,opt,name=ps,proto3" json:"ps,omitempty"`
}

func (*ReplyReq) Descriptor

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

func (*ReplyReq) GetMid

func (m *ReplyReq) GetMid() int64

func (*ReplyReq) GetPn

func (m *ReplyReq) GetPn() int32

func (*ReplyReq) GetPs

func (m *ReplyReq) GetPs() int32

func (*ReplyReq) Marshal

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

func (*ReplyReq) MarshalTo

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

func (*ReplyReq) ProtoMessage

func (*ReplyReq) ProtoMessage()

func (*ReplyReq) Reset

func (m *ReplyReq) Reset()

func (*ReplyReq) Size

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

func (*ReplyReq) String

func (m *ReplyReq) String() string

func (*ReplyReq) Unmarshal

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

type ReplyRes

type ReplyRes struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ReplyRes) Descriptor

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

func (*ReplyRes) GetName

func (m *ReplyRes) GetName() string

func (*ReplyRes) Marshal

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

func (*ReplyRes) MarshalTo

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

func (*ReplyRes) ProtoMessage

func (*ReplyRes) ProtoMessage()

func (*ReplyRes) Reset

func (m *ReplyRes) Reset()

func (*ReplyRes) Size

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

func (*ReplyRes) String

func (m *ReplyRes) String() string

func (*ReplyRes) Unmarshal

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