pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

pb/notify.proto

It has these top-level messages:

NotifyReq
NotifyResp

Index

• func RegisterProxyServer(s *grpc.Server, srv ProxyServer)
• type NotifyReq
  • func (*NotifyReq) Descriptor() ([]byte, []int)
  • func (m *NotifyReq) GetMsg() []byte
  • func (m *NotifyReq) GetMsgId() uint32
  • func (*NotifyReq) ProtoMessage()
  • func (m *NotifyReq) Reset()
  • func (m *NotifyReq) String() string
• type NotifyResp
  • func (*NotifyResp) Descriptor() ([]byte, []int)
  • func (m *NotifyResp) GetCode() uint32
  • func (m *NotifyResp) GetMsg() []byte
  • func (m *NotifyResp) GetMsgId() uint32
  • func (*NotifyResp) ProtoMessage()
  • func (m *NotifyResp) Reset()
  • func (m *NotifyResp) String() string
• type ProxyClient
  • func NewProxyClient(cc *grpc.ClientConn) ProxyClient
• type ProxyServer
• type Proxy_NotifyClient
• type Proxy_NotifyServer

Functions

func RegisterProxyServer

func RegisterProxyServer(s *grpc.Server, srv ProxyServer)

Types

type NotifyReq

type NotifyReq struct {
	MsgId uint32 `protobuf:"varint,1,opt,name=msgId" json:"msgId,omitempty"`
	Msg   []byte `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

新增连接信息通知

func (*NotifyReq) Descriptor

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

func (*NotifyReq) GetMsg

func (m *NotifyReq) GetMsg() []byte

func (*NotifyReq) GetMsgId

func (m *NotifyReq) GetMsgId() uint32

func (*NotifyReq) ProtoMessage

func (*NotifyReq) ProtoMessage()

func (*NotifyReq) Reset

func (m *NotifyReq) Reset()

func (*NotifyReq) String

func (m *NotifyReq) String() string

type NotifyResp

type NotifyResp struct {
	Code  uint32 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
	MsgId uint32 `protobuf:"varint,2,opt,name=msgId" json:"msgId,omitempty"`
	Msg   []byte `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*NotifyResp) Descriptor

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

func (*NotifyResp) GetCode

func (m *NotifyResp) GetCode() uint32

func (*NotifyResp) GetMsg

func (m *NotifyResp) GetMsg() []byte

func (*NotifyResp) GetMsgId

func (m *NotifyResp) GetMsgId() uint32

func (*NotifyResp) ProtoMessage

func (*NotifyResp) ProtoMessage()

func (*NotifyResp) Reset

func (m *NotifyResp) Reset()

func (*NotifyResp) String

func (m *NotifyResp) String() string

type ProxyClient

type ProxyClient interface {
	Notify(ctx context.Context, opts ...grpc.CallOption) (Proxy_NotifyClient, error)
}

func NewProxyClient

func NewProxyClient(cc *grpc.ClientConn) ProxyClient

type ProxyServer

type ProxyServer interface {
	Notify(Proxy_NotifyServer) error
}

type Proxy_NotifyClient

type Proxy_NotifyClient interface {
	Send(*NotifyReq) error
	Recv() (*NotifyResp, error)
	grpc.ClientStream
}

type Proxy_NotifyServer

type Proxy_NotifyServer interface {
	Send(*NotifyResp) error
	Recv() (*NotifyReq, error)
	grpc.ServerStream
}