push

package
v0.0.0-...-2aa8555 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPushServiceServer 

func RegisterPushServiceServer(s *grpc.Server, srv PushServiceServer)

Types

type AddRouteReq 

type AddRouteReq struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,2,opt,name=Service,proto3" json:"Service,omitempty"`
	Topic                string   `protobuf:"bytes,3,opt,name=Topic,proto3" json:"Topic,omitempty"`
	GrpcAddress          string   `protobuf:"bytes,4,opt,name=GrpcAddress,proto3" json:"GrpcAddress,omitempty"`
	Version              uint64   `protobuf:"varint,5,opt,name=Version,proto3" json:"Version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRouteReq) Descriptor 

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

func (*AddRouteReq) GetGrpcAddress 

func (m *AddRouteReq) GetGrpcAddress() string

func (*AddRouteReq) GetService 

func (m *AddRouteReq) GetService() string

func (*AddRouteReq) GetTopic 

func (m *AddRouteReq) GetTopic() string

func (*AddRouteReq) GetTraceID 

func (m *AddRouteReq) GetTraceID() string

func (*AddRouteReq) GetVersion 

func (m *AddRouteReq) GetVersion() uint64

func (*AddRouteReq) ProtoMessage 

func (*AddRouteReq) ProtoMessage()

func (*AddRouteReq) Reset 

func (m *AddRouteReq) Reset()

func (*AddRouteReq) String 

func (m *AddRouteReq) String() string

func (*AddRouteReq) XXX_DiscardUnknown 

func (m *AddRouteReq) XXX_DiscardUnknown()

func (*AddRouteReq) XXX_Marshal 

func (m *AddRouteReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddRouteReq) XXX_Merge 

func (m *AddRouteReq) XXX_Merge(src proto.Message)

func (*AddRouteReq) XXX_Size 

func (m *AddRouteReq) XXX_Size() int

func (*AddRouteReq) XXX_Unmarshal 

func (m *AddRouteReq) XXX_Unmarshal(b []byte) error

type AddRouteResp 

type AddRouteResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRouteResp) Descriptor 

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

func (*AddRouteResp) ProtoMessage 

func (*AddRouteResp) ProtoMessage()

func (*AddRouteResp) Reset 

func (m *AddRouteResp) Reset()

func (*AddRouteResp) String 

func (m *AddRouteResp) String() string

func (*AddRouteResp) XXX_DiscardUnknown 

func (m *AddRouteResp) XXX_DiscardUnknown()

func (*AddRouteResp) XXX_Marshal 

func (m *AddRouteResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddRouteResp) XXX_Merge 

func (m *AddRouteResp) XXX_Merge(src proto.Message)

func (*AddRouteResp) XXX_Size 

func (m *AddRouteResp) XXX_Size() int

func (*AddRouteResp) XXX_Unmarshal 

func (m *AddRouteResp) XXX_Unmarshal(b []byte) error

type ConnectReq 

type ConnectReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Username             string   `protobuf:"bytes,2,opt,name=Username,proto3" json:"Username,omitempty"`
	Password             []byte   `protobuf:"bytes,3,opt,name=Password,proto3" json:"Password,omitempty"`
	CleanSession         bool     `protobuf:"varint,4,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	GrpcAddress          string   `protobuf:"bytes,5,opt,name=GrpcAddress,proto3" json:"GrpcAddress,omitempty"`
	TraceID              string   `protobuf:"bytes,6,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	ClientAddress        string   `protobuf:"bytes,7,opt,name=ClientAddress,proto3" json:"ClientAddress,omitempty"`
	ConnectionID         int64    `protobuf:"varint,8,opt,name=ConnectionID,proto3" json:"ConnectionID,omitempty"`
	Service              string   `protobuf:"bytes,9,opt,name=Service,proto3" json:"Service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectReq) Descriptor 

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

func (*ConnectReq) GetCleanSession 

func (m *ConnectReq) GetCleanSession() bool

func (*ConnectReq) GetClientAddress 

func (m *ConnectReq) GetClientAddress() string

func (*ConnectReq) GetClientID 

func (m *ConnectReq) GetClientID() string

func (*ConnectReq) GetConnectionID 

func (m *ConnectReq) GetConnectionID() int64

func (*ConnectReq) GetGrpcAddress 

func (m *ConnectReq) GetGrpcAddress() string

func (*ConnectReq) GetPassword 

func (m *ConnectReq) GetPassword() []byte

func (*ConnectReq) GetService 

func (m *ConnectReq) GetService() string

func (*ConnectReq) GetTraceID 

func (m *ConnectReq) GetTraceID() string

func (*ConnectReq) GetUsername 

func (m *ConnectReq) GetUsername() string

func (*ConnectReq) ProtoMessage 

func (*ConnectReq) ProtoMessage()

func (*ConnectReq) Reset 

func (m *ConnectReq) Reset()

func (*ConnectReq) String 

func (m *ConnectReq) String() string

func (*ConnectReq) XXX_DiscardUnknown 

func (m *ConnectReq) XXX_DiscardUnknown()

func (*ConnectReq) XXX_Marshal 

func (m *ConnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectReq) XXX_Merge 

func (m *ConnectReq) XXX_Merge(src proto.Message)

func (*ConnectReq) XXX_Size 

func (m *ConnectReq) XXX_Size() int

func (*ConnectReq) XXX_Unmarshal 

func (m *ConnectReq) XXX_Unmarshal(b []byte) error

type ConnectResp 

type ConnectResp struct {
	Cookie               []byte    `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	SessionPresent       bool      `protobuf:"varint,2,opt,name=SessionPresent,proto3" json:"SessionPresent,omitempty"`
	Records              []*Record `protobuf:"bytes,3,rep,name=Records,proto3" json:"Records,omitempty"`
	StatLabel            string    `protobuf:"bytes,4,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	MqttCode             int32     `protobuf:"varint,5,opt,name=MqttCode,proto3" json:"MqttCode,omitempty"`
	MessageID            int64     `protobuf:"varint,6,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	Service              string    `protobuf:"bytes,7,opt,name=Service,proto3" json:"Service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ConnectResp) Descriptor 

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

func (*ConnectResp) GetCookie 

func (m *ConnectResp) GetCookie() []byte

func (*ConnectResp) GetMessageID 

func (m *ConnectResp) GetMessageID() int64

func (*ConnectResp) GetMqttCode 

func (m *ConnectResp) GetMqttCode() int32

func (*ConnectResp) GetRecords 

func (m *ConnectResp) GetRecords() []*Record

func (*ConnectResp) GetService 

func (m *ConnectResp) GetService() string

func (*ConnectResp) GetSessionPresent 

func (m *ConnectResp) GetSessionPresent() bool

func (*ConnectResp) GetStatLabel 

func (m *ConnectResp) GetStatLabel() string

func (*ConnectResp) ProtoMessage 

func (*ConnectResp) ProtoMessage()

func (*ConnectResp) Reset 

func (m *ConnectResp) Reset()

func (*ConnectResp) String 

func (m *ConnectResp) String() string

func (*ConnectResp) XXX_DiscardUnknown 

func (m *ConnectResp) XXX_DiscardUnknown()

func (*ConnectResp) XXX_Marshal 

func (m *ConnectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectResp) XXX_Merge 

func (m *ConnectResp) XXX_Merge(src proto.Message)

func (*ConnectResp) XXX_Size 

func (m *ConnectResp) XXX_Size() int

func (*ConnectResp) XXX_Unmarshal 

func (m *ConnectResp) XXX_Unmarshal(b []byte) error

type DelUnackReq 

type DelUnackReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	MessageID            int64    `protobuf:"varint,3,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	TraceID              string   `protobuf:"bytes,4,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,5,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool     `protobuf:"varint,6,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	StatLabel            string   `protobuf:"bytes,7,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	BizID                []byte   `protobuf:"bytes,8,opt,name=BizID,proto3" json:"BizID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelUnackReq) Descriptor 

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

func (*DelUnackReq) GetBizID 

func (m *DelUnackReq) GetBizID() []byte

func (*DelUnackReq) GetCleanSession 

func (m *DelUnackReq) GetCleanSession() bool

func (*DelUnackReq) GetClientID 

func (m *DelUnackReq) GetClientID() string

func (*DelUnackReq) GetCookie 

func (m *DelUnackReq) GetCookie() []byte

func (*DelUnackReq) GetMessageID 

func (m *DelUnackReq) GetMessageID() int64

func (*DelUnackReq) GetService 

func (m *DelUnackReq) GetService() string

func (*DelUnackReq) GetStatLabel 

func (m *DelUnackReq) GetStatLabel() string

func (*DelUnackReq) GetTraceID 

func (m *DelUnackReq) GetTraceID() string

func (*DelUnackReq) ProtoMessage 

func (*DelUnackReq) ProtoMessage()

func (*DelUnackReq) Reset 

func (m *DelUnackReq) Reset()

func (*DelUnackReq) String 

func (m *DelUnackReq) String() string

func (*DelUnackReq) XXX_DiscardUnknown 

func (m *DelUnackReq) XXX_DiscardUnknown()

func (*DelUnackReq) XXX_Marshal 

func (m *DelUnackReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelUnackReq) XXX_Merge 

func (m *DelUnackReq) XXX_Merge(src proto.Message)

func (*DelUnackReq) XXX_Size 

func (m *DelUnackReq) XXX_Size() int

func (*DelUnackReq) XXX_Unmarshal 

func (m *DelUnackReq) XXX_Unmarshal(b []byte) error

type DelUnackResp 

type DelUnackResp struct {
	Cookie               []byte   `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	BizID                []byte   `protobuf:"bytes,2,opt,name=BizID,proto3" json:"BizID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelUnackResp) Descriptor 

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

func (*DelUnackResp) GetBizID 

func (m *DelUnackResp) GetBizID() []byte

func (*DelUnackResp) GetCookie 

func (m *DelUnackResp) GetCookie() []byte

func (*DelUnackResp) ProtoMessage 

func (*DelUnackResp) ProtoMessage()

func (*DelUnackResp) Reset 

func (m *DelUnackResp) Reset()

func (*DelUnackResp) String 

func (m *DelUnackResp) String() string

func (*DelUnackResp) XXX_DiscardUnknown 

func (m *DelUnackResp) XXX_DiscardUnknown()

func (*DelUnackResp) XXX_Marshal 

func (m *DelUnackResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelUnackResp) XXX_Merge 

func (m *DelUnackResp) XXX_Merge(src proto.Message)

func (*DelUnackResp) XXX_Size 

func (m *DelUnackResp) XXX_Size() int

func (*DelUnackResp) XXX_Unmarshal 

func (m *DelUnackResp) XXX_Unmarshal(b []byte) error

type DisconnectReq 

type DisconnectReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	GrpcAddress          string   `protobuf:"bytes,3,opt,name=GrpcAddress,proto3" json:"GrpcAddress,omitempty"`
	CleanSession         bool     `protobuf:"varint,4,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	TraceID              string   `protobuf:"bytes,5,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Lost                 bool     `protobuf:"varint,6,opt,name=Lost,proto3" json:"Lost,omitempty"`
	Service              string   `protobuf:"bytes,7,opt,name=Service,proto3" json:"Service,omitempty"`
	StatLabel            string   `protobuf:"bytes,8,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	ConnectionID         int64    `protobuf:"varint,9,opt,name=ConnectionID,proto3" json:"ConnectionID,omitempty"`
	Kick                 bool     `protobuf:"varint,10,opt,name=kick,proto3" json:"kick,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisconnectReq) Descriptor 

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

func (*DisconnectReq) GetCleanSession 

func (m *DisconnectReq) GetCleanSession() bool

func (*DisconnectReq) GetClientID 

func (m *DisconnectReq) GetClientID() string

func (*DisconnectReq) GetConnectionID 

func (m *DisconnectReq) GetConnectionID() int64

func (*DisconnectReq) GetCookie 

func (m *DisconnectReq) GetCookie() []byte

func (*DisconnectReq) GetGrpcAddress 

func (m *DisconnectReq) GetGrpcAddress() string

func (*DisconnectReq) GetKick 

func (m *DisconnectReq) GetKick() bool

func (*DisconnectReq) GetLost 

func (m *DisconnectReq) GetLost() bool

func (*DisconnectReq) GetService 

func (m *DisconnectReq) GetService() string

func (*DisconnectReq) GetStatLabel 

func (m *DisconnectReq) GetStatLabel() string

func (*DisconnectReq) GetTraceID 

func (m *DisconnectReq) GetTraceID() string

func (*DisconnectReq) ProtoMessage 

func (*DisconnectReq) ProtoMessage()

func (*DisconnectReq) Reset 

func (m *DisconnectReq) Reset()

func (*DisconnectReq) String 

func (m *DisconnectReq) String() string

func (*DisconnectReq) XXX_DiscardUnknown 

func (m *DisconnectReq) XXX_DiscardUnknown()

func (*DisconnectReq) XXX_Marshal 

func (m *DisconnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DisconnectReq) XXX_Merge 

func (m *DisconnectReq) XXX_Merge(src proto.Message)

func (*DisconnectReq) XXX_Size 

func (m *DisconnectReq) XXX_Size() int

func (*DisconnectReq) XXX_Unmarshal 

func (m *DisconnectReq) XXX_Unmarshal(b []byte) error

type DisconnectResp 

type DisconnectResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisconnectResp) Descriptor 

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

func (*DisconnectResp) ProtoMessage 

func (*DisconnectResp) ProtoMessage()

func (*DisconnectResp) Reset 

func (m *DisconnectResp) Reset()

func (*DisconnectResp) String 

func (m *DisconnectResp) String() string

func (*DisconnectResp) XXX_DiscardUnknown 

func (m *DisconnectResp) XXX_DiscardUnknown()

func (*DisconnectResp) XXX_Marshal 

func (m *DisconnectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DisconnectResp) XXX_Merge 

func (m *DisconnectResp) XXX_Merge(src proto.Message)

func (*DisconnectResp) XXX_Size 

func (m *DisconnectResp) XXX_Size() int

func (*DisconnectResp) XXX_Unmarshal 

func (m *DisconnectResp) XXX_Unmarshal(b []byte) error

type Message 

type Message struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Qos                  int32    `protobuf:"varint,2,opt,name=Qos,proto3" json:"Qos,omitempty"`
	MessageID            int64    `protobuf:"varint,3,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	Payload              []byte   `protobuf:"bytes,4,opt,name=Payload,proto3" json:"Payload,omitempty"`
	TraceID              string   `protobuf:"bytes,5,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Retain               bool     `protobuf:"varint,6,opt,name=Retain,proto3" json:"Retain,omitempty"`
	BizID                []byte   `protobuf:"bytes,7,opt,name=BizID,proto3" json:"BizID,omitempty"`
	Index                []byte   `protobuf:"bytes,8,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetBizID 

func (m *Message) GetBizID() []byte

func (*Message) GetIndex 

func (m *Message) GetIndex() []byte

func (*Message) GetMessageID 

func (m *Message) GetMessageID() int64

func (*Message) GetPayload 

func (m *Message) GetPayload() []byte

func (*Message) GetQos 

func (m *Message) GetQos() int32

func (*Message) GetRetain 

func (m *Message) GetRetain() bool

func (*Message) GetTopic 

func (m *Message) GetTopic() string

func (*Message) GetTraceID 

func (m *Message) GetTraceID() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type PostSubscribeReq 

type PostSubscribeReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	TraceID              string   `protobuf:"bytes,3,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,4,opt,name=Service,proto3" json:"Service,omitempty"`
	Topics               []string `protobuf:"bytes,5,rep,name=Topics,proto3" json:"Topics,omitempty"`
	Qoss                 []int32  `protobuf:"varint,6,rep,packed,name=Qoss,proto3" json:"Qoss,omitempty"`
	StatLabel            string   `protobuf:"bytes,7,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostSubscribeReq) Descriptor 

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

func (*PostSubscribeReq) GetClientID 

func (m *PostSubscribeReq) GetClientID() string

func (*PostSubscribeReq) GetCookie 

func (m *PostSubscribeReq) GetCookie() []byte

func (*PostSubscribeReq) GetQoss 

func (m *PostSubscribeReq) GetQoss() []int32

func (*PostSubscribeReq) GetService 

func (m *PostSubscribeReq) GetService() string

func (*PostSubscribeReq) GetStatLabel 

func (m *PostSubscribeReq) GetStatLabel() string

func (*PostSubscribeReq) GetTopics 

func (m *PostSubscribeReq) GetTopics() []string

func (*PostSubscribeReq) GetTraceID 

func (m *PostSubscribeReq) GetTraceID() string

func (*PostSubscribeReq) ProtoMessage 

func (*PostSubscribeReq) ProtoMessage()

func (*PostSubscribeReq) Reset 

func (m *PostSubscribeReq) Reset()

func (*PostSubscribeReq) String 

func (m *PostSubscribeReq) String() string

func (*PostSubscribeReq) XXX_DiscardUnknown 

func (m *PostSubscribeReq) XXX_DiscardUnknown()

func (*PostSubscribeReq) XXX_Marshal 

func (m *PostSubscribeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostSubscribeReq) XXX_Merge 

func (m *PostSubscribeReq) XXX_Merge(src proto.Message)

func (*PostSubscribeReq) XXX_Size 

func (m *PostSubscribeReq) XXX_Size() int

func (*PostSubscribeReq) XXX_Unmarshal 

func (m *PostSubscribeReq) XXX_Unmarshal(b []byte) error

type PostSubscribeResp 

type PostSubscribeResp struct {
	Cookie               []byte   `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostSubscribeResp) Descriptor 

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

func (*PostSubscribeResp) GetCookie 

func (m *PostSubscribeResp) GetCookie() []byte

func (*PostSubscribeResp) ProtoMessage 

func (*PostSubscribeResp) ProtoMessage()

func (*PostSubscribeResp) Reset 

func (m *PostSubscribeResp) Reset()

func (*PostSubscribeResp) String 

func (m *PostSubscribeResp) String() string

func (*PostSubscribeResp) XXX_DiscardUnknown 

func (m *PostSubscribeResp) XXX_DiscardUnknown()

func (*PostSubscribeResp) XXX_Marshal 

func (m *PostSubscribeResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostSubscribeResp) XXX_Merge 

func (m *PostSubscribeResp) XXX_Merge(src proto.Message)

func (*PostSubscribeResp) XXX_Size 

func (m *PostSubscribeResp) XXX_Size() int

func (*PostSubscribeResp) XXX_Unmarshal 

func (m *PostSubscribeResp) XXX_Unmarshal(b []byte) error

type PubcompReq 

type PubcompReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	MessageID            int64    `protobuf:"varint,2,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	TraceID              string   `protobuf:"bytes,3,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,4,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool     `protobuf:"varint,5,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubcompReq) Descriptor 

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

func (*PubcompReq) GetCleanSession 

func (m *PubcompReq) GetCleanSession() bool

func (*PubcompReq) GetClientID 

func (m *PubcompReq) GetClientID() string

func (*PubcompReq) GetMessageID 

func (m *PubcompReq) GetMessageID() int64

func (*PubcompReq) GetService 

func (m *PubcompReq) GetService() string

func (*PubcompReq) GetTraceID 

func (m *PubcompReq) GetTraceID() string

func (*PubcompReq) ProtoMessage 

func (*PubcompReq) ProtoMessage()

func (*PubcompReq) Reset 

func (m *PubcompReq) Reset()

func (*PubcompReq) String 

func (m *PubcompReq) String() string

func (*PubcompReq) XXX_DiscardUnknown 

func (m *PubcompReq) XXX_DiscardUnknown()

func (*PubcompReq) XXX_Marshal 

func (m *PubcompReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubcompReq) XXX_Merge 

func (m *PubcompReq) XXX_Merge(src proto.Message)

func (*PubcompReq) XXX_Size 

func (m *PubcompReq) XXX_Size() int

func (*PubcompReq) XXX_Unmarshal 

func (m *PubcompReq) XXX_Unmarshal(b []byte) error

type PubcompResp 

type PubcompResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubcompResp) Descriptor 

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

func (*PubcompResp) ProtoMessage 

func (*PubcompResp) ProtoMessage()

func (*PubcompResp) Reset 

func (m *PubcompResp) Reset()

func (*PubcompResp) String 

func (m *PubcompResp) String() string

func (*PubcompResp) XXX_DiscardUnknown 

func (m *PubcompResp) XXX_DiscardUnknown()

func (*PubcompResp) XXX_Marshal 

func (m *PubcompResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubcompResp) XXX_Merge 

func (m *PubcompResp) XXX_Merge(src proto.Message)

func (*PubcompResp) XXX_Size 

func (m *PubcompResp) XXX_Size() int

func (*PubcompResp) XXX_Unmarshal 

func (m *PubcompResp) XXX_Unmarshal(b []byte) error

type PublishReq 

type PublishReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	Message              *Message `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	Service              string   `protobuf:"bytes,4,opt,name=Service,proto3" json:"Service,omitempty"`
	StatLabel            string   `protobuf:"bytes,5,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishReq) Descriptor 

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

func (*PublishReq) GetClientID 

func (m *PublishReq) GetClientID() string

func (*PublishReq) GetCookie 

func (m *PublishReq) GetCookie() []byte

func (*PublishReq) GetMessage 

func (m *PublishReq) GetMessage() *Message

func (*PublishReq) GetService 

func (m *PublishReq) GetService() string

func (*PublishReq) GetStatLabel 

func (m *PublishReq) GetStatLabel() string

func (*PublishReq) ProtoMessage 

func (*PublishReq) ProtoMessage()

func (*PublishReq) Reset 

func (m *PublishReq) Reset()

func (*PublishReq) String 

func (m *PublishReq) String() string

func (*PublishReq) XXX_DiscardUnknown 

func (m *PublishReq) XXX_DiscardUnknown()

func (*PublishReq) XXX_Marshal 

func (m *PublishReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishReq) XXX_Merge 

func (m *PublishReq) XXX_Merge(src proto.Message)

func (*PublishReq) XXX_Size 

func (m *PublishReq) XXX_Size() int

func (*PublishReq) XXX_Unmarshal 

func (m *PublishReq) XXX_Unmarshal(b []byte) error

type PublishResp 

type PublishResp struct {
	Cookie               []byte   `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishResp) Descriptor 

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

func (*PublishResp) GetCookie 

func (m *PublishResp) GetCookie() []byte

func (*PublishResp) ProtoMessage 

func (*PublishResp) ProtoMessage()

func (*PublishResp) Reset 

func (m *PublishResp) Reset()

func (*PublishResp) String 

func (m *PublishResp) String() string

func (*PublishResp) XXX_DiscardUnknown 

func (m *PublishResp) XXX_DiscardUnknown()

func (*PublishResp) XXX_Marshal 

func (m *PublishResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResp) XXX_Merge 

func (m *PublishResp) XXX_Merge(src proto.Message)

func (*PublishResp) XXX_Size 

func (m *PublishResp) XXX_Size() int

func (*PublishResp) XXX_Unmarshal 

func (m *PublishResp) XXX_Unmarshal(b []byte) error

type PubrecReq 

type PubrecReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	MessageID            int64    `protobuf:"varint,3,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	TraceID              string   `protobuf:"bytes,4,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	GrpcAddress          string   `protobuf:"bytes,5,opt,name=GrpcAddress,proto3" json:"GrpcAddress,omitempty"`
	Service              string   `protobuf:"bytes,6,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool     `protobuf:"varint,7,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	StatLabel            string   `protobuf:"bytes,8,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubrecReq) Descriptor 

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

func (*PubrecReq) GetCleanSession 

func (m *PubrecReq) GetCleanSession() bool

func (*PubrecReq) GetClientID 

func (m *PubrecReq) GetClientID() string

func (*PubrecReq) GetCookie 

func (m *PubrecReq) GetCookie() []byte

func (*PubrecReq) GetGrpcAddress 

func (m *PubrecReq) GetGrpcAddress() string

func (*PubrecReq) GetMessageID 

func (m *PubrecReq) GetMessageID() int64

func (*PubrecReq) GetService 

func (m *PubrecReq) GetService() string

func (*PubrecReq) GetStatLabel 

func (m *PubrecReq) GetStatLabel() string

func (*PubrecReq) GetTraceID 

func (m *PubrecReq) GetTraceID() string

func (*PubrecReq) ProtoMessage 

func (*PubrecReq) ProtoMessage()

func (*PubrecReq) Reset 

func (m *PubrecReq) Reset()

func (*PubrecReq) String 

func (m *PubrecReq) String() string

func (*PubrecReq) XXX_DiscardUnknown 

func (m *PubrecReq) XXX_DiscardUnknown()

func (*PubrecReq) XXX_Marshal 

func (m *PubrecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubrecReq) XXX_Merge 

func (m *PubrecReq) XXX_Merge(src proto.Message)

func (*PubrecReq) XXX_Size 

func (m *PubrecReq) XXX_Size() int

func (*PubrecReq) XXX_Unmarshal 

func (m *PubrecReq) XXX_Unmarshal(b []byte) error

type PubrecResp 

type PubrecResp struct {
	Cookie               []byte   `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubrecResp) Descriptor 

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

func (*PubrecResp) GetCookie 

func (m *PubrecResp) GetCookie() []byte

func (*PubrecResp) ProtoMessage 

func (*PubrecResp) ProtoMessage()

func (*PubrecResp) Reset 

func (m *PubrecResp) Reset()

func (*PubrecResp) String 

func (m *PubrecResp) String() string

func (*PubrecResp) XXX_DiscardUnknown 

func (m *PubrecResp) XXX_DiscardUnknown()

func (*PubrecResp) XXX_Marshal 

func (m *PubrecResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubrecResp) XXX_Merge 

func (m *PubrecResp) XXX_Merge(src proto.Message)

func (*PubrecResp) XXX_Size 

func (m *PubrecResp) XXX_Size() int

func (*PubrecResp) XXX_Unmarshal 

func (m *PubrecResp) XXX_Unmarshal(b []byte) error

type PubrelReq 

type PubrelReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	MessageID            int64    `protobuf:"varint,2,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	TraceID              string   `protobuf:"bytes,3,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,4,opt,name=Service,proto3" json:"Service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubrelReq) Descriptor 

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

func (*PubrelReq) GetClientID 

func (m *PubrelReq) GetClientID() string

func (*PubrelReq) GetMessageID 

func (m *PubrelReq) GetMessageID() int64

func (*PubrelReq) GetService 

func (m *PubrelReq) GetService() string

func (*PubrelReq) GetTraceID 

func (m *PubrelReq) GetTraceID() string

func (*PubrelReq) ProtoMessage 

func (*PubrelReq) ProtoMessage()

func (*PubrelReq) Reset 

func (m *PubrelReq) Reset()

func (*PubrelReq) String 

func (m *PubrelReq) String() string

func (*PubrelReq) XXX_DiscardUnknown 

func (m *PubrelReq) XXX_DiscardUnknown()

func (*PubrelReq) XXX_Marshal 

func (m *PubrelReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubrelReq) XXX_Merge 

func (m *PubrelReq) XXX_Merge(src proto.Message)

func (*PubrelReq) XXX_Size 

func (m *PubrelReq) XXX_Size() int

func (*PubrelReq) XXX_Unmarshal 

func (m *PubrelReq) XXX_Unmarshal(b []byte) error

type PubrelResp 

type PubrelResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubrelResp) Descriptor 

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

func (*PubrelResp) ProtoMessage 

func (*PubrelResp) ProtoMessage()

func (*PubrelResp) Reset 

func (m *PubrelResp) Reset()

func (*PubrelResp) String 

func (m *PubrelResp) String() string

func (*PubrelResp) XXX_DiscardUnknown 

func (m *PubrelResp) XXX_DiscardUnknown()

func (*PubrelResp) XXX_Marshal 

func (m *PubrelResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubrelResp) XXX_Merge 

func (m *PubrelResp) XXX_Merge(src proto.Message)

func (*PubrelResp) XXX_Size 

func (m *PubrelResp) XXX_Size() int

func (*PubrelResp) XXX_Unmarshal 

func (m *PubrelResp) XXX_Unmarshal(b []byte) error

type PullReq 

type PullReq struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Topic                string   `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Offset               []byte   `protobuf:"bytes,3,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Limit                int64    `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Service              string   `protobuf:"bytes,5,opt,name=Service,proto3" json:"Service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Pushd从指定Topic的指定位置Index返回至多Count条消息。

func (*PullReq) Descriptor 

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

func (*PullReq) GetLimit 

func (m *PullReq) GetLimit() int64

func (*PullReq) GetOffset 

func (m *PullReq) GetOffset() []byte

func (*PullReq) GetService 

func (m *PullReq) GetService() string

func (*PullReq) GetTopic 

func (m *PullReq) GetTopic() string

func (*PullReq) GetTraceID 

func (m *PullReq) GetTraceID() string

func (*PullReq) ProtoMessage 

func (*PullReq) ProtoMessage()

func (*PullReq) Reset 

func (m *PullReq) Reset()

func (*PullReq) String 

func (m *PullReq) String() string

func (*PullReq) XXX_DiscardUnknown 

func (m *PullReq) XXX_DiscardUnknown()

func (*PullReq) XXX_Marshal 

func (m *PullReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullReq) XXX_Merge 

func (m *PullReq) XXX_Merge(src proto.Message)

func (*PullReq) XXX_Size 

func (m *PullReq) XXX_Size() int

func (*PullReq) XXX_Unmarshal 

func (m *PullReq) XXX_Unmarshal(b []byte) error

type PullResp 

type PullResp struct {
	Messages             []*Message `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"`
	Offset               []byte     `protobuf:"bytes,2,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Complete             bool       `protobuf:"varint,3,opt,name=Complete,proto3" json:"Complete,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Index是下次拉取时的需要指定的Index。 例如： 

PullReq中设置Index为5， Count为10，但是
pushd仅返回了8条消息，则PullResp中Index
的值为13，即第8条消息的下一条。

PacketID也是同样的逻辑。 即，PullResp中返回的Index和PacketID就是下次 PullReq中的Index和PacketID。

func (*PullResp) Descriptor 

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

func (*PullResp) GetComplete 

func (m *PullResp) GetComplete() bool

func (*PullResp) GetMessages 

func (m *PullResp) GetMessages() []*Message

func (*PullResp) GetOffset 

func (m *PullResp) GetOffset() []byte

func (*PullResp) ProtoMessage 

func (*PullResp) ProtoMessage()

func (*PullResp) Reset 

func (m *PullResp) Reset()

func (*PullResp) String 

func (m *PullResp) String() string

func (*PullResp) XXX_DiscardUnknown 

func (m *PullResp) XXX_DiscardUnknown()

func (*PullResp) XXX_Marshal 

func (m *PullResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullResp) XXX_Merge 

func (m *PullResp) XXX_Merge(src proto.Message)

func (*PullResp) XXX_Size 

func (m *PullResp) XXX_Size() int

func (*PullResp) XXX_Unmarshal 

func (m *PullResp) XXX_Unmarshal(b []byte) error

type PushServiceClient 

type PushServiceClient interface {
	Connect(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectResp, error)
	Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*DisconnectResp, error)
	Subscribe(ctx context.Context, in *SubscribeReq, opts ...grpc.CallOption) (*SubscribeResp, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeReq, opts ...grpc.CallOption) (*UnsubscribeResp, error)
	MQTTPublish(ctx context.Context, in *PublishReq, opts ...grpc.CallOption) (*PublishResp, error)
	Pubrec(ctx context.Context, in *PubrecReq, opts ...grpc.CallOption) (*PubrecResp, error)
	Pubrel(ctx context.Context, in *PubrelReq, opts ...grpc.CallOption) (*PubrelResp, error)
	Pubcomp(ctx context.Context, in *PubcompReq, opts ...grpc.CallOption) (*PubcompResp, error)
	RangeUnack(ctx context.Context, in *RangeUnackReq, opts ...grpc.CallOption) (*RangeUnackResp, error)
	PutUnack(ctx context.Context, in *PutUnackReq, opts ...grpc.CallOption) (*PutUnackResp, error)
	DelUnack(ctx context.Context, in *DelUnackReq, opts ...grpc.CallOption) (*DelUnackResp, error)
	Pull(ctx context.Context, in *PullReq, opts ...grpc.CallOption) (*PullResp, error)
	PostSubscribe(ctx context.Context, in *PostSubscribeReq, opts ...grpc.CallOption) (*PostSubscribeResp, error)
	AddRoute(ctx context.Context, in *AddRouteReq, opts ...grpc.CallOption) (*AddRouteResp, error)
	RemoveRoute(ctx context.Context, in *RemoveRouteReq, opts ...grpc.CallOption) (*RemoveRouteResp, error)
}

PushServiceClient is the client API for PushService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPushServiceClient 

func NewPushServiceClient(cc *grpc.ClientConn) PushServiceClient

type PushServiceServer 

type PushServiceServer interface {
	Connect(context.Context, *ConnectReq) (*ConnectResp, error)
	Disconnect(context.Context, *DisconnectReq) (*DisconnectResp, error)
	Subscribe(context.Context, *SubscribeReq) (*SubscribeResp, error)
	Unsubscribe(context.Context, *UnsubscribeReq) (*UnsubscribeResp, error)
	MQTTPublish(context.Context, *PublishReq) (*PublishResp, error)
	Pubrec(context.Context, *PubrecReq) (*PubrecResp, error)
	Pubrel(context.Context, *PubrelReq) (*PubrelResp, error)
	Pubcomp(context.Context, *PubcompReq) (*PubcompResp, error)
	RangeUnack(context.Context, *RangeUnackReq) (*RangeUnackResp, error)
	PutUnack(context.Context, *PutUnackReq) (*PutUnackResp, error)
	DelUnack(context.Context, *DelUnackReq) (*DelUnackResp, error)
	Pull(context.Context, *PullReq) (*PullResp, error)
	PostSubscribe(context.Context, *PostSubscribeReq) (*PostSubscribeResp, error)
	AddRoute(context.Context, *AddRouteReq) (*AddRouteResp, error)
	RemoveRoute(context.Context, *RemoveRouteReq) (*RemoveRouteResp, error)
}

PushServiceServer is the server API for PushService service.

type PutUnackReq 

type PutUnackReq struct {
	TraceID              string       `protobuf:"bytes,1,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	ClientID             string       `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Messages             []*UnackDesc `protobuf:"bytes,3,rep,name=Messages,proto3" json:"Messages,omitempty"`
	Service              string       `protobuf:"bytes,4,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool         `protobuf:"varint,5,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PutUnackReq) Descriptor 

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

func (*PutUnackReq) GetCleanSession 

func (m *PutUnackReq) GetCleanSession() bool

func (*PutUnackReq) GetClientID 

func (m *PutUnackReq) GetClientID() string

func (*PutUnackReq) GetMessages 

func (m *PutUnackReq) GetMessages() []*UnackDesc

func (*PutUnackReq) GetService 

func (m *PutUnackReq) GetService() string

func (*PutUnackReq) GetTraceID 

func (m *PutUnackReq) GetTraceID() string

func (*PutUnackReq) ProtoMessage 

func (*PutUnackReq) ProtoMessage()

func (*PutUnackReq) Reset 

func (m *PutUnackReq) Reset()

func (*PutUnackReq) String 

func (m *PutUnackReq) String() string

func (*PutUnackReq) XXX_DiscardUnknown 

func (m *PutUnackReq) XXX_DiscardUnknown()

func (*PutUnackReq) XXX_Marshal 

func (m *PutUnackReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutUnackReq) XXX_Merge 

func (m *PutUnackReq) XXX_Merge(src proto.Message)

func (*PutUnackReq) XXX_Size 

func (m *PutUnackReq) XXX_Size() int

func (*PutUnackReq) XXX_Unmarshal 

func (m *PutUnackReq) XXX_Unmarshal(b []byte) error

type PutUnackResp 

type PutUnackResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutUnackResp) Descriptor 

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

func (*PutUnackResp) ProtoMessage 

func (*PutUnackResp) ProtoMessage()

func (*PutUnackResp) Reset 

func (m *PutUnackResp) Reset()

func (*PutUnackResp) String 

func (m *PutUnackResp) String() string

func (*PutUnackResp) XXX_DiscardUnknown 

func (m *PutUnackResp) XXX_DiscardUnknown()

func (*PutUnackResp) XXX_Marshal 

func (m *PutUnackResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutUnackResp) XXX_Merge 

func (m *PutUnackResp) XXX_Merge(src proto.Message)

func (*PutUnackResp) XXX_Size 

func (m *PutUnackResp) XXX_Size() int

func (*PutUnackResp) XXX_Unmarshal 

func (m *PutUnackResp) XXX_Unmarshal(b []byte) error

type RangeUnackReq 

type RangeUnackReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	TraceID              string   `protobuf:"bytes,2,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Limit                int64    `protobuf:"varint,3,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Offset               []byte   `protobuf:"bytes,4,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Service              string   `protobuf:"bytes,5,opt,name=Service,proto3" json:"Service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RangeUnackReq) Descriptor 

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

func (*RangeUnackReq) GetClientID 

func (m *RangeUnackReq) GetClientID() string

func (*RangeUnackReq) GetLimit 

func (m *RangeUnackReq) GetLimit() int64

func (*RangeUnackReq) GetOffset 

func (m *RangeUnackReq) GetOffset() []byte

func (*RangeUnackReq) GetService 

func (m *RangeUnackReq) GetService() string

func (*RangeUnackReq) GetTraceID 

func (m *RangeUnackReq) GetTraceID() string

func (*RangeUnackReq) ProtoMessage 

func (*RangeUnackReq) ProtoMessage()

func (*RangeUnackReq) Reset 

func (m *RangeUnackReq) Reset()

func (*RangeUnackReq) String 

func (m *RangeUnackReq) String() string

func (*RangeUnackReq) XXX_DiscardUnknown 

func (m *RangeUnackReq) XXX_DiscardUnknown()

func (*RangeUnackReq) XXX_Marshal 

func (m *RangeUnackReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeUnackReq) XXX_Merge 

func (m *RangeUnackReq) XXX_Merge(src proto.Message)

func (*RangeUnackReq) XXX_Size 

func (m *RangeUnackReq) XXX_Size() int

func (*RangeUnackReq) XXX_Unmarshal 

func (m *RangeUnackReq) XXX_Unmarshal(b []byte) error

type RangeUnackResp 

type RangeUnackResp struct {
	Offset               []byte       `protobuf:"bytes,1,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Complete             bool         `protobuf:"varint,2,opt,name=Complete,proto3" json:"Complete,omitempty"`
	Messages             []*UnackDesc `protobuf:"bytes,3,rep,name=Messages,proto3" json:"Messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RangeUnackResp) Descriptor 

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

func (*RangeUnackResp) GetComplete 

func (m *RangeUnackResp) GetComplete() bool

func (*RangeUnackResp) GetMessages 

func (m *RangeUnackResp) GetMessages() []*UnackDesc

func (*RangeUnackResp) GetOffset 

func (m *RangeUnackResp) GetOffset() []byte

func (*RangeUnackResp) ProtoMessage 

func (*RangeUnackResp) ProtoMessage()

func (*RangeUnackResp) Reset 

func (m *RangeUnackResp) Reset()

func (*RangeUnackResp) String 

func (m *RangeUnackResp) String() string

func (*RangeUnackResp) XXX_DiscardUnknown 

func (m *RangeUnackResp) XXX_DiscardUnknown()

func (*RangeUnackResp) XXX_Marshal 

func (m *RangeUnackResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeUnackResp) XXX_Merge 

func (m *RangeUnackResp) XXX_Merge(src proto.Message)

func (*RangeUnackResp) XXX_Size 

func (m *RangeUnackResp) XXX_Size() int

func (*RangeUnackResp) XXX_Unmarshal 

func (m *RangeUnackResp) XXX_Unmarshal(b []byte) error

type Record 

type Record struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Qos                  int32    `protobuf:"varint,2,opt,name=Qos,proto3" json:"Qos,omitempty"`
	CurrentIndex         []byte   `protobuf:"bytes,3,opt,name=CurrentIndex,proto3" json:"CurrentIndex,omitempty"`
	LastestIndex         []byte   `protobuf:"bytes,4,opt,name=LastestIndex,proto3" json:"LastestIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

该Topic当前读取位置Index和最新消息Index。 connd需要拉取区间[CurrentIndex, LastestIndex] 内的全部消息。

func (*Record) Descriptor 

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

func (*Record) GetCurrentIndex 

func (m *Record) GetCurrentIndex() []byte

func (*Record) GetLastestIndex 

func (m *Record) GetLastestIndex() []byte

func (*Record) GetQos 

func (m *Record) GetQos() int32

func (*Record) GetTopic 

func (m *Record) GetTopic() string

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) String 

func (m *Record) String() string

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Record) XXX_Merge 

func (m *Record) XXX_Merge(src proto.Message)

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

func (m *Record) XXX_Unmarshal(b []byte) error

type RemoveRouteReq 

type RemoveRouteReq struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,2,opt,name=Service,proto3" json:"Service,omitempty"`
	Topic                string   `protobuf:"bytes,3,opt,name=Topic,proto3" json:"Topic,omitempty"`
	GrpcAddress          string   `protobuf:"bytes,4,opt,name=GrpcAddress,proto3" json:"GrpcAddress,omitempty"`
	Version              uint64   `protobuf:"varint,5,opt,name=Version,proto3" json:"Version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRouteReq) Descriptor 

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

func (*RemoveRouteReq) GetGrpcAddress 

func (m *RemoveRouteReq) GetGrpcAddress() string

func (*RemoveRouteReq) GetService 

func (m *RemoveRouteReq) GetService() string

func (*RemoveRouteReq) GetTopic 

func (m *RemoveRouteReq) GetTopic() string

func (*RemoveRouteReq) GetTraceID 

func (m *RemoveRouteReq) GetTraceID() string

func (*RemoveRouteReq) GetVersion 

func (m *RemoveRouteReq) GetVersion() uint64

func (*RemoveRouteReq) ProtoMessage 

func (*RemoveRouteReq) ProtoMessage()

func (*RemoveRouteReq) Reset 

func (m *RemoveRouteReq) Reset()

func (*RemoveRouteReq) String 

func (m *RemoveRouteReq) String() string

func (*RemoveRouteReq) XXX_DiscardUnknown 

func (m *RemoveRouteReq) XXX_DiscardUnknown()

func (*RemoveRouteReq) XXX_Marshal 

func (m *RemoveRouteReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveRouteReq) XXX_Merge 

func (m *RemoveRouteReq) XXX_Merge(src proto.Message)

func (*RemoveRouteReq) XXX_Size 

func (m *RemoveRouteReq) XXX_Size() int

func (*RemoveRouteReq) XXX_Unmarshal 

func (m *RemoveRouteReq) XXX_Unmarshal(b []byte) error

type RemoveRouteResp 

type RemoveRouteResp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRouteResp) Descriptor 

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

func (*RemoveRouteResp) ProtoMessage 

func (*RemoveRouteResp) ProtoMessage()

func (*RemoveRouteResp) Reset 

func (m *RemoveRouteResp) Reset()

func (*RemoveRouteResp) String 

func (m *RemoveRouteResp) String() string

func (*RemoveRouteResp) XXX_DiscardUnknown 

func (m *RemoveRouteResp) XXX_DiscardUnknown()

func (*RemoveRouteResp) XXX_Marshal 

func (m *RemoveRouteResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveRouteResp) XXX_Merge 

func (m *RemoveRouteResp) XXX_Merge(src proto.Message)

func (*RemoveRouteResp) XXX_Size 

func (m *RemoveRouteResp) XXX_Size() int

func (*RemoveRouteResp) XXX_Unmarshal 

func (m *RemoveRouteResp) XXX_Unmarshal(b []byte) error

type SubscribeReq 

type SubscribeReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	Topics               []string `protobuf:"bytes,3,rep,name=Topics,proto3" json:"Topics,omitempty"`
	Qoss                 []int32  `protobuf:"varint,4,rep,packed,name=Qoss,proto3" json:"Qoss,omitempty"`
	TraceID              string   `protobuf:"bytes,5,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Service              string   `protobuf:"bytes,6,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool     `protobuf:"varint,7,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	StatLabel            string   `protobuf:"bytes,8,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeReq) Descriptor 

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

func (*SubscribeReq) GetCleanSession 

func (m *SubscribeReq) GetCleanSession() bool

func (*SubscribeReq) GetClientID 

func (m *SubscribeReq) GetClientID() string

func (*SubscribeReq) GetCookie 

func (m *SubscribeReq) GetCookie() []byte

func (*SubscribeReq) GetQoss 

func (m *SubscribeReq) GetQoss() []int32

func (*SubscribeReq) GetService 

func (m *SubscribeReq) GetService() string

func (*SubscribeReq) GetStatLabel 

func (m *SubscribeReq) GetStatLabel() string

func (*SubscribeReq) GetTopics 

func (m *SubscribeReq) GetTopics() []string

func (*SubscribeReq) GetTraceID 

func (m *SubscribeReq) GetTraceID() string

func (*SubscribeReq) ProtoMessage 

func (*SubscribeReq) ProtoMessage()

func (*SubscribeReq) Reset 

func (m *SubscribeReq) Reset()

func (*SubscribeReq) String 

func (m *SubscribeReq) String() string

func (*SubscribeReq) XXX_DiscardUnknown 

func (m *SubscribeReq) XXX_DiscardUnknown()

func (*SubscribeReq) XXX_Marshal 

func (m *SubscribeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeReq) XXX_Merge 

func (m *SubscribeReq) XXX_Merge(src proto.Message)

func (*SubscribeReq) XXX_Size 

func (m *SubscribeReq) XXX_Size() int

func (*SubscribeReq) XXX_Unmarshal 

func (m *SubscribeReq) XXX_Unmarshal(b []byte) error

type SubscribeResp 

type SubscribeResp struct {
	Cookie               []byte     `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	Qoss                 []int32    `protobuf:"varint,2,rep,packed,name=Qoss,proto3" json:"Qoss,omitempty"`
	Index                [][]byte   `protobuf:"bytes,3,rep,name=Index,proto3" json:"Index,omitempty"`
	RetainMessage        []*Message `protobuf:"bytes,4,rep,name=RetainMessage,proto3" json:"RetainMessage,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SubscribeResp) Descriptor 

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

func (*SubscribeResp) GetCookie 

func (m *SubscribeResp) GetCookie() []byte

func (*SubscribeResp) GetIndex 

func (m *SubscribeResp) GetIndex() [][]byte

func (*SubscribeResp) GetQoss 

func (m *SubscribeResp) GetQoss() []int32

func (*SubscribeResp) GetRetainMessage 

func (m *SubscribeResp) GetRetainMessage() []*Message

func (*SubscribeResp) ProtoMessage 

func (*SubscribeResp) ProtoMessage()

func (*SubscribeResp) Reset 

func (m *SubscribeResp) Reset()

func (*SubscribeResp) String 

func (m *SubscribeResp) String() string

func (*SubscribeResp) XXX_DiscardUnknown 

func (m *SubscribeResp) XXX_DiscardUnknown()

func (*SubscribeResp) XXX_Marshal 

func (m *SubscribeResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeResp) XXX_Merge 

func (m *SubscribeResp) XXX_Merge(src proto.Message)

func (*SubscribeResp) XXX_Size 

func (m *SubscribeResp) XXX_Size() int

func (*SubscribeResp) XXX_Unmarshal 

func (m *SubscribeResp) XXX_Unmarshal(b []byte) error

type UnackDesc 

type UnackDesc struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Index                []byte   `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"`
	MessageID            int64    `protobuf:"varint,3,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	BizID                []byte   `protobuf:"bytes,4,opt,name=BizID,proto3" json:"BizID,omitempty"`
	TraceID              string   `protobuf:"bytes,5,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Payload              []byte   `protobuf:"bytes,6,opt,name=Payload,proto3" json:"Payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnackDesc) Descriptor 

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

func (*UnackDesc) GetBizID 

func (m *UnackDesc) GetBizID() []byte

func (*UnackDesc) GetIndex 

func (m *UnackDesc) GetIndex() []byte

func (*UnackDesc) GetMessageID 

func (m *UnackDesc) GetMessageID() int64

func (*UnackDesc) GetPayload 

func (m *UnackDesc) GetPayload() []byte

func (*UnackDesc) GetTopic 

func (m *UnackDesc) GetTopic() string

func (*UnackDesc) GetTraceID 

func (m *UnackDesc) GetTraceID() string

func (*UnackDesc) ProtoMessage 

func (*UnackDesc) ProtoMessage()

func (*UnackDesc) Reset 

func (m *UnackDesc) Reset()

func (*UnackDesc) String 

func (m *UnackDesc) String() string

func (*UnackDesc) XXX_DiscardUnknown 

func (m *UnackDesc) XXX_DiscardUnknown()

func (*UnackDesc) XXX_Marshal 

func (m *UnackDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnackDesc) XXX_Merge 

func (m *UnackDesc) XXX_Merge(src proto.Message)

func (*UnackDesc) XXX_Size 

func (m *UnackDesc) XXX_Size() int

func (*UnackDesc) XXX_Unmarshal 

func (m *UnackDesc) XXX_Unmarshal(b []byte) error

type UnimplementedPushServiceServer 

type UnimplementedPushServiceServer struct {
}

UnimplementedPushServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPushServiceServer) AddRoute 

func (*UnimplementedPushServiceServer) AddRoute(ctx context.Context, req *AddRouteReq) (*AddRouteResp, error)

func (*UnimplementedPushServiceServer) Connect 

func (*UnimplementedPushServiceServer) Connect(ctx context.Context, req *ConnectReq) (*ConnectResp, error)

func (*UnimplementedPushServiceServer) DelUnack 

func (*UnimplementedPushServiceServer) DelUnack(ctx context.Context, req *DelUnackReq) (*DelUnackResp, error)

func (*UnimplementedPushServiceServer) Disconnect 

func (*UnimplementedPushServiceServer) Disconnect(ctx context.Context, req *DisconnectReq) (*DisconnectResp, error)

func (*UnimplementedPushServiceServer) MQTTPublish 

func (*UnimplementedPushServiceServer) MQTTPublish(ctx context.Context, req *PublishReq) (*PublishResp, error)

func (*UnimplementedPushServiceServer) PostSubscribe 

func (*UnimplementedPushServiceServer) PostSubscribe(ctx context.Context, req *PostSubscribeReq) (*PostSubscribeResp, error)

func (*UnimplementedPushServiceServer) Pubcomp 

func (*UnimplementedPushServiceServer) Pubcomp(ctx context.Context, req *PubcompReq) (*PubcompResp, error)

func (*UnimplementedPushServiceServer) Pubrec 

func (*UnimplementedPushServiceServer) Pubrec(ctx context.Context, req *PubrecReq) (*PubrecResp, error)

func (*UnimplementedPushServiceServer) Pubrel 

func (*UnimplementedPushServiceServer) Pubrel(ctx context.Context, req *PubrelReq) (*PubrelResp, error)

func (*UnimplementedPushServiceServer) Pull 

func (*UnimplementedPushServiceServer) Pull(ctx context.Context, req *PullReq) (*PullResp, error)

func (*UnimplementedPushServiceServer) PutUnack 

func (*UnimplementedPushServiceServer) PutUnack(ctx context.Context, req *PutUnackReq) (*PutUnackResp, error)

func (*UnimplementedPushServiceServer) RangeUnack 

func (*UnimplementedPushServiceServer) RangeUnack(ctx context.Context, req *RangeUnackReq) (*RangeUnackResp, error)

func (*UnimplementedPushServiceServer) RemoveRoute 

func (*UnimplementedPushServiceServer) RemoveRoute(ctx context.Context, req *RemoveRouteReq) (*RemoveRouteResp, error)

func (*UnimplementedPushServiceServer) Subscribe 

func (*UnimplementedPushServiceServer) Subscribe(ctx context.Context, req *SubscribeReq) (*SubscribeResp, error)

func (*UnimplementedPushServiceServer) Unsubscribe 

func (*UnimplementedPushServiceServer) Unsubscribe(ctx context.Context, req *UnsubscribeReq) (*UnsubscribeResp, error)

type UnsubscribeReq 

type UnsubscribeReq struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Cookie               []byte   `protobuf:"bytes,2,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	Topics               []string `protobuf:"bytes,3,rep,name=Topics,proto3" json:"Topics,omitempty"`
	TraceID              string   `protobuf:"bytes,4,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	Lost                 bool     `protobuf:"varint,5,opt,name=Lost,proto3" json:"Lost,omitempty"`
	Service              string   `protobuf:"bytes,6,opt,name=Service,proto3" json:"Service,omitempty"`
	CleanSession         bool     `protobuf:"varint,7,opt,name=CleanSession,proto3" json:"CleanSession,omitempty"`
	StatLabel            string   `protobuf:"bytes,8,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnsubscribeReq) Descriptor 

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

func (*UnsubscribeReq) GetCleanSession 

func (m *UnsubscribeReq) GetCleanSession() bool

func (*UnsubscribeReq) GetClientID 

func (m *UnsubscribeReq) GetClientID() string

func (*UnsubscribeReq) GetCookie 

func (m *UnsubscribeReq) GetCookie() []byte

func (*UnsubscribeReq) GetLost 

func (m *UnsubscribeReq) GetLost() bool

func (*UnsubscribeReq) GetService 

func (m *UnsubscribeReq) GetService() string

func (*UnsubscribeReq) GetStatLabel 

func (m *UnsubscribeReq) GetStatLabel() string

func (*UnsubscribeReq) GetTopics 

func (m *UnsubscribeReq) GetTopics() []string

func (*UnsubscribeReq) GetTraceID 

func (m *UnsubscribeReq) GetTraceID() string

func (*UnsubscribeReq) ProtoMessage 

func (*UnsubscribeReq) ProtoMessage()

func (*UnsubscribeReq) Reset 

func (m *UnsubscribeReq) Reset()

func (*UnsubscribeReq) String 

func (m *UnsubscribeReq) String() string

func (*UnsubscribeReq) XXX_DiscardUnknown 

func (m *UnsubscribeReq) XXX_DiscardUnknown()

func (*UnsubscribeReq) XXX_Marshal 

func (m *UnsubscribeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsubscribeReq) XXX_Merge 

func (m *UnsubscribeReq) XXX_Merge(src proto.Message)

func (*UnsubscribeReq) XXX_Size 

func (m *UnsubscribeReq) XXX_Size() int

func (*UnsubscribeReq) XXX_Unmarshal 

func (m *UnsubscribeReq) XXX_Unmarshal(b []byte) error

type UnsubscribeResp 

type UnsubscribeResp struct {
	Cookie               []byte   `protobuf:"bytes,1,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnsubscribeResp) Descriptor 

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

func (*UnsubscribeResp) GetCookie 

func (m *UnsubscribeResp) GetCookie() []byte

func (*UnsubscribeResp) ProtoMessage 

func (*UnsubscribeResp) ProtoMessage()

func (*UnsubscribeResp) Reset 

func (m *UnsubscribeResp) Reset()

func (*UnsubscribeResp) String 

func (m *UnsubscribeResp) String() string

func (*UnsubscribeResp) XXX_DiscardUnknown 

func (m *UnsubscribeResp) XXX_DiscardUnknown()

func (*UnsubscribeResp) XXX_Marshal 

func (m *UnsubscribeResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsubscribeResp) XXX_Merge 

func (m *UnsubscribeResp) XXX_Merge(src proto.Message)

func (*UnsubscribeResp) XXX_Size 

func (m *UnsubscribeResp) XXX_Size() int

func (*UnsubscribeResp) XXX_Unmarshal 

func (m *UnsubscribeResp) XXX_Unmarshal(b []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.