1223 lines
37 KiB
Go
1223 lines
37 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.36.11
|
|
// protoc v7.34.0
|
|
// source: unistream.proto
|
|
|
|
package unistream
|
|
|
|
import (
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
type ConnectRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Numeration is in sync with Centrifuge client protocol.
|
|
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
|
|
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
|
|
Subs map[string]*SubscribeRequest `protobuf:"bytes,3,rep,name=subs,proto3" json:"subs,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
|
|
Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
|
|
Headers map[string]string `protobuf:"bytes,6,rep,name=headers,proto3" json:"headers,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ConnectRequest) Reset() {
|
|
*x = ConnectRequest{}
|
|
mi := &file_unistream_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ConnectRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ConnectRequest) ProtoMessage() {}
|
|
|
|
func (x *ConnectRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.
|
|
func (*ConnectRequest) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *ConnectRequest) GetToken() string {
|
|
if x != nil {
|
|
return x.Token
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ConnectRequest) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ConnectRequest) GetSubs() map[string]*SubscribeRequest {
|
|
if x != nil {
|
|
return x.Subs
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ConnectRequest) GetName() string {
|
|
if x != nil {
|
|
return x.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ConnectRequest) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ConnectRequest) GetHeaders() map[string]string {
|
|
if x != nil {
|
|
return x.Headers
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SubscribeRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Numeration is in sync with Centrifuge client protocol.
|
|
Recover bool `protobuf:"varint,3,opt,name=recover,proto3" json:"recover,omitempty"`
|
|
Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"`
|
|
Offset uint64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SubscribeRequest) Reset() {
|
|
*x = SubscribeRequest{}
|
|
mi := &file_unistream_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SubscribeRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SubscribeRequest) ProtoMessage() {}
|
|
|
|
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
|
|
func (*SubscribeRequest) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetRecover() bool {
|
|
if x != nil {
|
|
return x.Recover
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetEpoch() string {
|
|
if x != nil {
|
|
return x.Epoch
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeRequest) GetOffset() uint64 {
|
|
if x != nil {
|
|
return x.Offset
|
|
}
|
|
return 0
|
|
}
|
|
|
|
// Push can be sent to a client as part of Reply in case of bidirectional transport or
|
|
// without additional wrapping in case of unidirectional transports.
|
|
// ProtocolVersion2 uses channel and one of the possible concrete push messages.
|
|
type Push struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
|
|
// ProtocolVersion2 server can push one of the following fields to the client. We are
|
|
// not using oneof here due to JSON interoperability concerns.
|
|
Pub *Publication `protobuf:"bytes,4,opt,name=pub,proto3" json:"pub,omitempty"`
|
|
Join *Join `protobuf:"bytes,5,opt,name=join,proto3" json:"join,omitempty"`
|
|
Leave *Leave `protobuf:"bytes,6,opt,name=leave,proto3" json:"leave,omitempty"`
|
|
Unsubscribe *Unsubscribe `protobuf:"bytes,7,opt,name=unsubscribe,proto3" json:"unsubscribe,omitempty"`
|
|
Message *Message `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"`
|
|
Subscribe *Subscribe `protobuf:"bytes,9,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
|
|
Connect *Connect `protobuf:"bytes,10,opt,name=connect,proto3" json:"connect,omitempty"`
|
|
Disconnect *Disconnect `protobuf:"bytes,11,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
|
|
Refresh *Refresh `protobuf:"bytes,12,opt,name=refresh,proto3" json:"refresh,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Push) Reset() {
|
|
*x = Push{}
|
|
mi := &file_unistream_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Push) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Push) ProtoMessage() {}
|
|
|
|
func (x *Push) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Push.ProtoReflect.Descriptor instead.
|
|
func (*Push) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *Push) GetChannel() string {
|
|
if x != nil {
|
|
return x.Channel
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Push) GetPub() *Publication {
|
|
if x != nil {
|
|
return x.Pub
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetJoin() *Join {
|
|
if x != nil {
|
|
return x.Join
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetLeave() *Leave {
|
|
if x != nil {
|
|
return x.Leave
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetUnsubscribe() *Unsubscribe {
|
|
if x != nil {
|
|
return x.Unsubscribe
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetMessage() *Message {
|
|
if x != nil {
|
|
return x.Message
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetSubscribe() *Subscribe {
|
|
if x != nil {
|
|
return x.Subscribe
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetConnect() *Connect {
|
|
if x != nil {
|
|
return x.Connect
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetDisconnect() *Disconnect {
|
|
if x != nil {
|
|
return x.Disconnect
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Push) GetRefresh() *Refresh {
|
|
if x != nil {
|
|
return x.Refresh
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ClientInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
|
|
Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
|
|
ConnInfo []byte `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"`
|
|
ChanInfo []byte `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ClientInfo) Reset() {
|
|
*x = ClientInfo{}
|
|
mi := &file_unistream_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ClientInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ClientInfo) ProtoMessage() {}
|
|
|
|
func (x *ClientInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.
|
|
func (*ClientInfo) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *ClientInfo) GetUser() string {
|
|
if x != nil {
|
|
return x.User
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ClientInfo) GetClient() string {
|
|
if x != nil {
|
|
return x.Client
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ClientInfo) GetConnInfo() []byte {
|
|
if x != nil {
|
|
return x.ConnInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ClientInfo) GetChanInfo() []byte {
|
|
if x != nil {
|
|
return x.ChanInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Publication struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
|
|
Info *ClientInfo `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
|
|
Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
|
|
Tags map[string]string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Publication) Reset() {
|
|
*x = Publication{}
|
|
mi := &file_unistream_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Publication) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Publication) ProtoMessage() {}
|
|
|
|
func (x *Publication) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Publication.ProtoReflect.Descriptor instead.
|
|
func (*Publication) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *Publication) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Publication) GetInfo() *ClientInfo {
|
|
if x != nil {
|
|
return x.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Publication) GetOffset() uint64 {
|
|
if x != nil {
|
|
return x.Offset
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Publication) GetTags() map[string]string {
|
|
if x != nil {
|
|
return x.Tags
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Join struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Info *ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Join) Reset() {
|
|
*x = Join{}
|
|
mi := &file_unistream_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Join) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Join) ProtoMessage() {}
|
|
|
|
func (x *Join) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Join.ProtoReflect.Descriptor instead.
|
|
func (*Join) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *Join) GetInfo() *ClientInfo {
|
|
if x != nil {
|
|
return x.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Leave struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Info *ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Leave) Reset() {
|
|
*x = Leave{}
|
|
mi := &file_unistream_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Leave) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Leave) ProtoMessage() {}
|
|
|
|
func (x *Leave) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[6]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Leave.ProtoReflect.Descriptor instead.
|
|
func (*Leave) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *Leave) GetInfo() *ClientInfo {
|
|
if x != nil {
|
|
return x.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Unsubscribe struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
|
|
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Unsubscribe) Reset() {
|
|
*x = Unsubscribe{}
|
|
mi := &file_unistream_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Unsubscribe) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Unsubscribe) ProtoMessage() {}
|
|
|
|
func (x *Unsubscribe) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[7]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead.
|
|
func (*Unsubscribe) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *Unsubscribe) GetCode() uint32 {
|
|
if x != nil {
|
|
return x.Code
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Unsubscribe) GetReason() string {
|
|
if x != nil {
|
|
return x.Reason
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type Subscribe struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Recoverable bool `protobuf:"varint,1,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
|
|
Epoch string `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
|
|
Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
|
|
Positioned bool `protobuf:"varint,6,opt,name=positioned,proto3" json:"positioned,omitempty"`
|
|
Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Subscribe) Reset() {
|
|
*x = Subscribe{}
|
|
mi := &file_unistream_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Subscribe) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Subscribe) ProtoMessage() {}
|
|
|
|
func (x *Subscribe) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[8]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.
|
|
func (*Subscribe) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *Subscribe) GetRecoverable() bool {
|
|
if x != nil {
|
|
return x.Recoverable
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Subscribe) GetEpoch() string {
|
|
if x != nil {
|
|
return x.Epoch
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Subscribe) GetOffset() uint64 {
|
|
if x != nil {
|
|
return x.Offset
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Subscribe) GetPositioned() bool {
|
|
if x != nil {
|
|
return x.Positioned
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Subscribe) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Message struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Message) Reset() {
|
|
*x = Message{}
|
|
mi := &file_unistream_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Message) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Message) ProtoMessage() {}
|
|
|
|
func (x *Message) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[9]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Message.ProtoReflect.Descriptor instead.
|
|
func (*Message) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *Message) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Connect struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
|
|
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
|
|
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
|
|
Subs map[string]*SubscribeResult `protobuf:"bytes,4,rep,name=subs,proto3" json:"subs,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
Expires bool `protobuf:"varint,5,opt,name=expires,proto3" json:"expires,omitempty"`
|
|
Ttl uint32 `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
|
|
Ping uint32 `protobuf:"varint,7,opt,name=ping,proto3" json:"ping,omitempty"`
|
|
Pong bool `protobuf:"varint,8,opt,name=pong,proto3" json:"pong,omitempty"`
|
|
Session string `protobuf:"bytes,9,opt,name=session,proto3" json:"session,omitempty"`
|
|
Node string `protobuf:"bytes,10,opt,name=node,proto3" json:"node,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Connect) Reset() {
|
|
*x = Connect{}
|
|
mi := &file_unistream_proto_msgTypes[10]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Connect) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Connect) ProtoMessage() {}
|
|
|
|
func (x *Connect) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[10]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Connect.ProtoReflect.Descriptor instead.
|
|
func (*Connect) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{10}
|
|
}
|
|
|
|
func (x *Connect) GetClient() string {
|
|
if x != nil {
|
|
return x.Client
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Connect) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Connect) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Connect) GetSubs() map[string]*SubscribeResult {
|
|
if x != nil {
|
|
return x.Subs
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Connect) GetExpires() bool {
|
|
if x != nil {
|
|
return x.Expires
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Connect) GetTtl() uint32 {
|
|
if x != nil {
|
|
return x.Ttl
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Connect) GetPing() uint32 {
|
|
if x != nil {
|
|
return x.Ping
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Connect) GetPong() bool {
|
|
if x != nil {
|
|
return x.Pong
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Connect) GetSession() string {
|
|
if x != nil {
|
|
return x.Session
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Connect) GetNode() string {
|
|
if x != nil {
|
|
return x.Node
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type Disconnect struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
|
Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
|
|
Reconnect bool `protobuf:"varint,3,opt,name=reconnect,proto3" json:"reconnect,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Disconnect) Reset() {
|
|
*x = Disconnect{}
|
|
mi := &file_unistream_proto_msgTypes[11]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Disconnect) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Disconnect) ProtoMessage() {}
|
|
|
|
func (x *Disconnect) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[11]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.
|
|
func (*Disconnect) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{11}
|
|
}
|
|
|
|
func (x *Disconnect) GetCode() uint32 {
|
|
if x != nil {
|
|
return x.Code
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Disconnect) GetReason() string {
|
|
if x != nil {
|
|
return x.Reason
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Disconnect) GetReconnect() bool {
|
|
if x != nil {
|
|
return x.Reconnect
|
|
}
|
|
return false
|
|
}
|
|
|
|
type Refresh struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"`
|
|
Ttl uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Refresh) Reset() {
|
|
*x = Refresh{}
|
|
mi := &file_unistream_proto_msgTypes[12]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Refresh) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Refresh) ProtoMessage() {}
|
|
|
|
func (x *Refresh) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[12]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Refresh.ProtoReflect.Descriptor instead.
|
|
func (*Refresh) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{12}
|
|
}
|
|
|
|
func (x *Refresh) GetExpires() bool {
|
|
if x != nil {
|
|
return x.Expires
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *Refresh) GetTtl() uint32 {
|
|
if x != nil {
|
|
return x.Ttl
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type SubscribeResult struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"`
|
|
Ttl uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
|
|
Recoverable bool `protobuf:"varint,3,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
|
|
Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"`
|
|
Publications []*Publication `protobuf:"bytes,7,rep,name=publications,proto3" json:"publications,omitempty"`
|
|
Recovered bool `protobuf:"varint,8,opt,name=recovered,proto3" json:"recovered,omitempty"`
|
|
Offset uint64 `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
|
|
Positioned bool `protobuf:"varint,10,opt,name=positioned,proto3" json:"positioned,omitempty"`
|
|
Data []byte `protobuf:"bytes,11,opt,name=data,proto3" json:"data,omitempty"`
|
|
WasRecovering bool `protobuf:"varint,12,opt,name=was_recovering,json=wasRecovering,proto3" json:"was_recovering,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SubscribeResult) Reset() {
|
|
*x = SubscribeResult{}
|
|
mi := &file_unistream_proto_msgTypes[13]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SubscribeResult) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SubscribeResult) ProtoMessage() {}
|
|
|
|
func (x *SubscribeResult) ProtoReflect() protoreflect.Message {
|
|
mi := &file_unistream_proto_msgTypes[13]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.
|
|
func (*SubscribeResult) Descriptor() ([]byte, []int) {
|
|
return file_unistream_proto_rawDescGZIP(), []int{13}
|
|
}
|
|
|
|
func (x *SubscribeResult) GetExpires() bool {
|
|
if x != nil {
|
|
return x.Expires
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeResult) GetTtl() uint32 {
|
|
if x != nil {
|
|
return x.Ttl
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SubscribeResult) GetRecoverable() bool {
|
|
if x != nil {
|
|
return x.Recoverable
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeResult) GetEpoch() string {
|
|
if x != nil {
|
|
return x.Epoch
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SubscribeResult) GetPublications() []*Publication {
|
|
if x != nil {
|
|
return x.Publications
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SubscribeResult) GetRecovered() bool {
|
|
if x != nil {
|
|
return x.Recovered
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeResult) GetOffset() uint64 {
|
|
if x != nil {
|
|
return x.Offset
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SubscribeResult) GetPositioned() bool {
|
|
if x != nil {
|
|
return x.Positioned
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SubscribeResult) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SubscribeResult) GetWasRecovering() bool {
|
|
if x != nil {
|
|
return x.WasRecovering
|
|
}
|
|
return false
|
|
}
|
|
|
|
var File_unistream_proto protoreflect.FileDescriptor
|
|
|
|
const file_unistream_proto_rawDesc = "" +
|
|
"\n" +
|
|
"\x0funistream.proto\x12 centrifugal.centrifugo.unistream\"\xba\x03\n" +
|
|
"\x0eConnectRequest\x12\x14\n" +
|
|
"\x05token\x18\x01 \x01(\tR\x05token\x12\x12\n" +
|
|
"\x04data\x18\x02 \x01(\fR\x04data\x12N\n" +
|
|
"\x04subs\x18\x03 \x03(\v2:.centrifugal.centrifugo.unistream.ConnectRequest.SubsEntryR\x04subs\x12\x12\n" +
|
|
"\x04name\x18\x04 \x01(\tR\x04name\x12\x18\n" +
|
|
"\aversion\x18\x05 \x01(\tR\aversion\x12W\n" +
|
|
"\aheaders\x18\x06 \x03(\v2=.centrifugal.centrifugo.unistream.ConnectRequest.HeadersEntryR\aheaders\x1ak\n" +
|
|
"\tSubsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12H\n" +
|
|
"\x05value\x18\x02 \x01(\v22.centrifugal.centrifugo.unistream.SubscribeRequestR\x05value:\x028\x01\x1a:\n" +
|
|
"\fHeadersEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"f\n" +
|
|
"\x10SubscribeRequest\x12\x18\n" +
|
|
"\arecover\x18\x03 \x01(\bR\arecover\x12\x14\n" +
|
|
"\x05epoch\x18\x06 \x01(\tR\x05epoch\x12\x16\n" +
|
|
"\x06offset\x18\a \x01(\x04R\x06offsetJ\x04\b\x04\x10\x05J\x04\b\x05\x10\x06\"\xa1\x05\n" +
|
|
"\x04Push\x12\x18\n" +
|
|
"\achannel\x18\x02 \x01(\tR\achannel\x12?\n" +
|
|
"\x03pub\x18\x04 \x01(\v2-.centrifugal.centrifugo.unistream.PublicationR\x03pub\x12:\n" +
|
|
"\x04join\x18\x05 \x01(\v2&.centrifugal.centrifugo.unistream.JoinR\x04join\x12=\n" +
|
|
"\x05leave\x18\x06 \x01(\v2'.centrifugal.centrifugo.unistream.LeaveR\x05leave\x12O\n" +
|
|
"\vunsubscribe\x18\a \x01(\v2-.centrifugal.centrifugo.unistream.UnsubscribeR\vunsubscribe\x12C\n" +
|
|
"\amessage\x18\b \x01(\v2).centrifugal.centrifugo.unistream.MessageR\amessage\x12I\n" +
|
|
"\tsubscribe\x18\t \x01(\v2+.centrifugal.centrifugo.unistream.SubscribeR\tsubscribe\x12C\n" +
|
|
"\aconnect\x18\n" +
|
|
" \x01(\v2).centrifugal.centrifugo.unistream.ConnectR\aconnect\x12L\n" +
|
|
"\n" +
|
|
"disconnect\x18\v \x01(\v2,.centrifugal.centrifugo.unistream.DisconnectR\n" +
|
|
"disconnect\x12C\n" +
|
|
"\arefresh\x18\f \x01(\v2).centrifugal.centrifugo.unistream.RefreshR\arefreshJ\x04\b\x01\x10\x02J\x04\b\x03\x10\x04\"r\n" +
|
|
"\n" +
|
|
"ClientInfo\x12\x12\n" +
|
|
"\x04user\x18\x01 \x01(\tR\x04user\x12\x16\n" +
|
|
"\x06client\x18\x02 \x01(\tR\x06client\x12\x1b\n" +
|
|
"\tconn_info\x18\x03 \x01(\fR\bconnInfo\x12\x1b\n" +
|
|
"\tchan_info\x18\x04 \x01(\fR\bchanInfo\"\x93\x02\n" +
|
|
"\vPublication\x12\x12\n" +
|
|
"\x04data\x18\x04 \x01(\fR\x04data\x12@\n" +
|
|
"\x04info\x18\x05 \x01(\v2,.centrifugal.centrifugo.unistream.ClientInfoR\x04info\x12\x16\n" +
|
|
"\x06offset\x18\x06 \x01(\x04R\x06offset\x12K\n" +
|
|
"\x04tags\x18\a \x03(\v27.centrifugal.centrifugo.unistream.Publication.TagsEntryR\x04tags\x1a7\n" +
|
|
"\tTagsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01J\x04\b\x01\x10\x02J\x04\b\x02\x10\x03J\x04\b\x03\x10\x04\"H\n" +
|
|
"\x04Join\x12@\n" +
|
|
"\x04info\x18\x01 \x01(\v2,.centrifugal.centrifugo.unistream.ClientInfoR\x04info\"I\n" +
|
|
"\x05Leave\x12@\n" +
|
|
"\x04info\x18\x01 \x01(\v2,.centrifugal.centrifugo.unistream.ClientInfoR\x04info\"?\n" +
|
|
"\vUnsubscribe\x12\x12\n" +
|
|
"\x04code\x18\x02 \x01(\rR\x04code\x12\x16\n" +
|
|
"\x06reason\x18\x03 \x01(\tR\x06reasonJ\x04\b\x01\x10\x02\"\x9b\x01\n" +
|
|
"\tSubscribe\x12 \n" +
|
|
"\vrecoverable\x18\x01 \x01(\bR\vrecoverable\x12\x14\n" +
|
|
"\x05epoch\x18\x04 \x01(\tR\x05epoch\x12\x16\n" +
|
|
"\x06offset\x18\x05 \x01(\x04R\x06offset\x12\x1e\n" +
|
|
"\n" +
|
|
"positioned\x18\x06 \x01(\bR\n" +
|
|
"positioned\x12\x12\n" +
|
|
"\x04data\x18\a \x01(\fR\x04dataJ\x04\b\x02\x10\x03J\x04\b\x03\x10\x04\"\x1d\n" +
|
|
"\aMessage\x12\x12\n" +
|
|
"\x04data\x18\x01 \x01(\fR\x04data\"\x86\x03\n" +
|
|
"\aConnect\x12\x16\n" +
|
|
"\x06client\x18\x01 \x01(\tR\x06client\x12\x18\n" +
|
|
"\aversion\x18\x02 \x01(\tR\aversion\x12\x12\n" +
|
|
"\x04data\x18\x03 \x01(\fR\x04data\x12G\n" +
|
|
"\x04subs\x18\x04 \x03(\v23.centrifugal.centrifugo.unistream.Connect.SubsEntryR\x04subs\x12\x18\n" +
|
|
"\aexpires\x18\x05 \x01(\bR\aexpires\x12\x10\n" +
|
|
"\x03ttl\x18\x06 \x01(\rR\x03ttl\x12\x12\n" +
|
|
"\x04ping\x18\a \x01(\rR\x04ping\x12\x12\n" +
|
|
"\x04pong\x18\b \x01(\bR\x04pong\x12\x18\n" +
|
|
"\asession\x18\t \x01(\tR\asession\x12\x12\n" +
|
|
"\x04node\x18\n" +
|
|
" \x01(\tR\x04node\x1aj\n" +
|
|
"\tSubsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12G\n" +
|
|
"\x05value\x18\x02 \x01(\v21.centrifugal.centrifugo.unistream.SubscribeResultR\x05value:\x028\x01\"V\n" +
|
|
"\n" +
|
|
"Disconnect\x12\x12\n" +
|
|
"\x04code\x18\x01 \x01(\rR\x04code\x12\x16\n" +
|
|
"\x06reason\x18\x02 \x01(\tR\x06reason\x12\x1c\n" +
|
|
"\treconnect\x18\x03 \x01(\bR\treconnect\"5\n" +
|
|
"\aRefresh\x12\x18\n" +
|
|
"\aexpires\x18\x01 \x01(\bR\aexpires\x12\x10\n" +
|
|
"\x03ttl\x18\x02 \x01(\rR\x03ttl\"\xe5\x02\n" +
|
|
"\x0fSubscribeResult\x12\x18\n" +
|
|
"\aexpires\x18\x01 \x01(\bR\aexpires\x12\x10\n" +
|
|
"\x03ttl\x18\x02 \x01(\rR\x03ttl\x12 \n" +
|
|
"\vrecoverable\x18\x03 \x01(\bR\vrecoverable\x12\x14\n" +
|
|
"\x05epoch\x18\x06 \x01(\tR\x05epoch\x12Q\n" +
|
|
"\fpublications\x18\a \x03(\v2-.centrifugal.centrifugo.unistream.PublicationR\fpublications\x12\x1c\n" +
|
|
"\trecovered\x18\b \x01(\bR\trecovered\x12\x16\n" +
|
|
"\x06offset\x18\t \x01(\x04R\x06offset\x12\x1e\n" +
|
|
"\n" +
|
|
"positioned\x18\n" +
|
|
" \x01(\bR\n" +
|
|
"positioned\x12\x12\n" +
|
|
"\x04data\x18\v \x01(\fR\x04data\x12%\n" +
|
|
"\x0ewas_recovering\x18\f \x01(\bR\rwasRecoveringJ\x04\b\x04\x10\x05J\x04\b\x05\x10\x062|\n" +
|
|
"\x13CentrifugoUniStream\x12e\n" +
|
|
"\aConsume\x120.centrifugal.centrifugo.unistream.ConnectRequest\x1a&.centrifugal.centrifugo.unistream.Push0\x01B\x0eZ\f./;unistreamb\x06proto3"
|
|
|
|
var (
|
|
file_unistream_proto_rawDescOnce sync.Once
|
|
file_unistream_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_unistream_proto_rawDescGZIP() []byte {
|
|
file_unistream_proto_rawDescOnce.Do(func() {
|
|
file_unistream_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_unistream_proto_rawDesc), len(file_unistream_proto_rawDesc)))
|
|
})
|
|
return file_unistream_proto_rawDescData
|
|
}
|
|
|
|
var file_unistream_proto_msgTypes = make([]protoimpl.MessageInfo, 18)
|
|
var file_unistream_proto_goTypes = []any{
|
|
(*ConnectRequest)(nil), // 0: centrifugal.centrifugo.unistream.ConnectRequest
|
|
(*SubscribeRequest)(nil), // 1: centrifugal.centrifugo.unistream.SubscribeRequest
|
|
(*Push)(nil), // 2: centrifugal.centrifugo.unistream.Push
|
|
(*ClientInfo)(nil), // 3: centrifugal.centrifugo.unistream.ClientInfo
|
|
(*Publication)(nil), // 4: centrifugal.centrifugo.unistream.Publication
|
|
(*Join)(nil), // 5: centrifugal.centrifugo.unistream.Join
|
|
(*Leave)(nil), // 6: centrifugal.centrifugo.unistream.Leave
|
|
(*Unsubscribe)(nil), // 7: centrifugal.centrifugo.unistream.Unsubscribe
|
|
(*Subscribe)(nil), // 8: centrifugal.centrifugo.unistream.Subscribe
|
|
(*Message)(nil), // 9: centrifugal.centrifugo.unistream.Message
|
|
(*Connect)(nil), // 10: centrifugal.centrifugo.unistream.Connect
|
|
(*Disconnect)(nil), // 11: centrifugal.centrifugo.unistream.Disconnect
|
|
(*Refresh)(nil), // 12: centrifugal.centrifugo.unistream.Refresh
|
|
(*SubscribeResult)(nil), // 13: centrifugal.centrifugo.unistream.SubscribeResult
|
|
nil, // 14: centrifugal.centrifugo.unistream.ConnectRequest.SubsEntry
|
|
nil, // 15: centrifugal.centrifugo.unistream.ConnectRequest.HeadersEntry
|
|
nil, // 16: centrifugal.centrifugo.unistream.Publication.TagsEntry
|
|
nil, // 17: centrifugal.centrifugo.unistream.Connect.SubsEntry
|
|
}
|
|
var file_unistream_proto_depIdxs = []int32{
|
|
14, // 0: centrifugal.centrifugo.unistream.ConnectRequest.subs:type_name -> centrifugal.centrifugo.unistream.ConnectRequest.SubsEntry
|
|
15, // 1: centrifugal.centrifugo.unistream.ConnectRequest.headers:type_name -> centrifugal.centrifugo.unistream.ConnectRequest.HeadersEntry
|
|
4, // 2: centrifugal.centrifugo.unistream.Push.pub:type_name -> centrifugal.centrifugo.unistream.Publication
|
|
5, // 3: centrifugal.centrifugo.unistream.Push.join:type_name -> centrifugal.centrifugo.unistream.Join
|
|
6, // 4: centrifugal.centrifugo.unistream.Push.leave:type_name -> centrifugal.centrifugo.unistream.Leave
|
|
7, // 5: centrifugal.centrifugo.unistream.Push.unsubscribe:type_name -> centrifugal.centrifugo.unistream.Unsubscribe
|
|
9, // 6: centrifugal.centrifugo.unistream.Push.message:type_name -> centrifugal.centrifugo.unistream.Message
|
|
8, // 7: centrifugal.centrifugo.unistream.Push.subscribe:type_name -> centrifugal.centrifugo.unistream.Subscribe
|
|
10, // 8: centrifugal.centrifugo.unistream.Push.connect:type_name -> centrifugal.centrifugo.unistream.Connect
|
|
11, // 9: centrifugal.centrifugo.unistream.Push.disconnect:type_name -> centrifugal.centrifugo.unistream.Disconnect
|
|
12, // 10: centrifugal.centrifugo.unistream.Push.refresh:type_name -> centrifugal.centrifugo.unistream.Refresh
|
|
3, // 11: centrifugal.centrifugo.unistream.Publication.info:type_name -> centrifugal.centrifugo.unistream.ClientInfo
|
|
16, // 12: centrifugal.centrifugo.unistream.Publication.tags:type_name -> centrifugal.centrifugo.unistream.Publication.TagsEntry
|
|
3, // 13: centrifugal.centrifugo.unistream.Join.info:type_name -> centrifugal.centrifugo.unistream.ClientInfo
|
|
3, // 14: centrifugal.centrifugo.unistream.Leave.info:type_name -> centrifugal.centrifugo.unistream.ClientInfo
|
|
17, // 15: centrifugal.centrifugo.unistream.Connect.subs:type_name -> centrifugal.centrifugo.unistream.Connect.SubsEntry
|
|
4, // 16: centrifugal.centrifugo.unistream.SubscribeResult.publications:type_name -> centrifugal.centrifugo.unistream.Publication
|
|
1, // 17: centrifugal.centrifugo.unistream.ConnectRequest.SubsEntry.value:type_name -> centrifugal.centrifugo.unistream.SubscribeRequest
|
|
13, // 18: centrifugal.centrifugo.unistream.Connect.SubsEntry.value:type_name -> centrifugal.centrifugo.unistream.SubscribeResult
|
|
0, // 19: centrifugal.centrifugo.unistream.CentrifugoUniStream.Consume:input_type -> centrifugal.centrifugo.unistream.ConnectRequest
|
|
2, // 20: centrifugal.centrifugo.unistream.CentrifugoUniStream.Consume:output_type -> centrifugal.centrifugo.unistream.Push
|
|
20, // [20:21] is the sub-list for method output_type
|
|
19, // [19:20] is the sub-list for method input_type
|
|
19, // [19:19] is the sub-list for extension type_name
|
|
19, // [19:19] is the sub-list for extension extendee
|
|
0, // [0:19] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_unistream_proto_init() }
|
|
func file_unistream_proto_init() {
|
|
if File_unistream_proto != nil {
|
|
return
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_unistream_proto_rawDesc), len(file_unistream_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 18,
|
|
NumExtensions: 0,
|
|
NumServices: 1,
|
|
},
|
|
GoTypes: file_unistream_proto_goTypes,
|
|
DependencyIndexes: file_unistream_proto_depIdxs,
|
|
MessageInfos: file_unistream_proto_msgTypes,
|
|
}.Build()
|
|
File_unistream_proto = out.File
|
|
file_unistream_proto_goTypes = nil
|
|
file_unistream_proto_depIdxs = nil
|
|
}
|