rrapiv1

Documentation

Index

• Variables
• type OnJoin
  • func (*OnJoin) Descriptor() ([]byte, []int)
  • func (x *OnJoin) GetChanInfo() []byte
  • func (x *OnJoin) GetClient() string
  • func (x *OnJoin) GetConnInfo() []byte
  • func (x *OnJoin) GetUser() string
  • func (*OnJoin) ProtoMessage()
  • func (x *OnJoin) ProtoReflect() protoreflect.Message
  • func (x *OnJoin) Reset()
  • func (x *OnJoin) String() string
• type Subscribe
  • func (*Subscribe) Descriptor() ([]byte, []int)
  • func (x *Subscribe) GetChannel() string
  • func (x *Subscribe) GetData() []byte
  • func (x *Subscribe) GetJoinleave() bool
  • func (x *Subscribe) GetPositioned() bool
  • func (x *Subscribe) GetRecoverable() bool
  • func (*Subscribe) ProtoMessage()
  • func (x *Subscribe) ProtoReflect() protoreflect.Message
  • func (x *Subscribe) Reset()
  • func (x *Subscribe) String() string
• type SubscribeResponse
  • func (*SubscribeResponse) Descriptor() ([]byte, []int)
  • func (x *SubscribeResponse) GetChannel() string
  • func (x *SubscribeResponse) GetSubstate() string
  • func (*SubscribeResponse) ProtoMessage()
  • func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
  • func (x *SubscribeResponse) Reset()
  • func (x *SubscribeResponse) String() string

Variables

var File_proto_centrifugo_rrapi_v1_api_proto protoreflect.FileDescriptor

Types

type OnJoin

type OnJoin struct {
	Client   string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	User     string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	ChanInfo []byte `protobuf:"bytes,3,opt,name=chanInfo,proto3" json:"chanInfo,omitempty"`
	ConnInfo []byte `protobuf:"bytes,4,opt,name=connInfo,proto3" json:"connInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*OnJoin) Descriptor

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

Deprecated: Use OnJoin.ProtoReflect.Descriptor instead.

func (*OnJoin) GetChanInfo

func (x *OnJoin) GetChanInfo() []byte

func (*OnJoin) GetClient

func (x *OnJoin) GetClient() string

func (*OnJoin) GetConnInfo

func (x *OnJoin) GetConnInfo() []byte

func (*OnJoin) GetUser

func (x *OnJoin) GetUser() string

func (*OnJoin) ProtoMessage

func (*OnJoin) ProtoMessage()

func (*OnJoin) ProtoReflect

func (x *OnJoin) ProtoReflect() protoreflect.Message

func (*OnJoin) Reset

func (x *OnJoin) Reset()

func (*OnJoin) String

func (x *OnJoin) String() string

type Subscribe

type Subscribe struct {
	Data        []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Channel     string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Positioned  bool   `protobuf:"varint,3,opt,name=positioned,proto3" json:"positioned,omitempty"`
	Recoverable bool   `protobuf:"varint,4,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
	Joinleave   bool   `protobuf:"varint,5,opt,name=joinleave,proto3" json:"joinleave,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscribe) Descriptor

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

Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.

func (*Subscribe) GetChannel

func (x *Subscribe) GetChannel() string

func (*Subscribe) GetData

func (x *Subscribe) GetData() []byte

func (*Subscribe) GetJoinleave

func (x *Subscribe) GetJoinleave() bool

func (*Subscribe) GetPositioned

func (x *Subscribe) GetPositioned() bool

func (*Subscribe) GetRecoverable

func (x *Subscribe) GetRecoverable() bool

func (*Subscribe) ProtoMessage

func (*Subscribe) ProtoMessage()

func (*Subscribe) ProtoReflect

func (x *Subscribe) ProtoReflect() protoreflect.Message

func (*Subscribe) Reset

func (x *Subscribe) Reset()

func (*Subscribe) String

func (x *Subscribe) String() string

type SubscribeResponse

type SubscribeResponse struct {
	Channel  string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Substate string `protobuf:"bytes,2,opt,name=substate,proto3" json:"substate,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetChannel

func (x *SubscribeResponse) GetChannel() string

func (*SubscribeResponse) GetSubstate

func (x *SubscribeResponse) GetSubstate() string

func (*SubscribeResponse) ProtoMessage

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect

func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

func (*SubscribeResponse) Reset

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String

func (x *SubscribeResponse) String() string