Versions in this module Expand all Collapse all v0 v0.14.2 Feb 27, 2018 Changes in this version + var RespCode_name = map[int32]string + var RespCode_value = map[string]int32 type ClientDel + DelSeq []*SeqRange + func (m *ClientDel) GetDelSeq() []*SeqRange + type DelValues struct + DelId int32 + DelSeq []*SeqRange + func (*DelValues) Descriptor() ([]byte, []int) + func (*DelValues) ProtoMessage() + func (m *DelValues) GetDelId() int32 + func (m *DelValues) GetDelSeq() []*SeqRange + func (m *DelValues) Reset() + func (m *DelValues) String() string type MessageEvent + Msg *ServerData + func (m *MessageEvent) GetMsg() *ServerData type PluginClient + Find func(ctx context.Context, in *SearchQuery, opts ...grpc.CallOption) (*SearchFound, error) type PluginServer + Find func(context.Context, *SearchQuery) (*SearchFound, error) + type RespCode int32 + const RespCode_CONTINUE + const RespCode_DROP + const RespCode_REPLACE + const RespCode_RESPOND + func (RespCode) EnumDescriptor() ([]byte, []int) + func (x RespCode) String() string + type SearchFound struct + Result []*TopicSub + Status RespCode + Terms []string + func (*SearchFound) Descriptor() ([]byte, []int) + func (*SearchFound) ProtoMessage() + func (m *SearchFound) GetResult() []*TopicSub + func (m *SearchFound) GetStatus() RespCode + func (m *SearchFound) GetTerms() []string + func (m *SearchFound) Reset() + func (m *SearchFound) String() string + type SearchQuery struct + Terms []string + UserId string + func (*SearchQuery) Descriptor() ([]byte, []int) + func (*SearchQuery) ProtoMessage() + func (m *SearchQuery) GetTerms() []string + func (m *SearchQuery) GetUserId() string + func (m *SearchQuery) Reset() + func (m *SearchQuery) String() string + type SeqRange struct + Hi int32 + Low int32 + func (*SeqRange) Descriptor() ([]byte, []int) + func (*SeqRange) ProtoMessage() + func (m *SeqRange) GetHi() int32 + func (m *SeqRange) GetLow() int32 + func (m *SeqRange) Reset() + func (m *SeqRange) String() string type ServerMeta + Del *DelValues + func (m *ServerMeta) GetDel() *DelValues type ServerPres + DelId int32 + DelSeq []*SeqRange + func (m *ServerPres) GetDelId() int32 + func (m *ServerPres) GetDelSeq() []*SeqRange type SubscriptionEvent + DelId int32 + Mode *AccessMode + Private []byte + ReadId int32 + RecvId int32 + Topic string + UserId string + func (m *SubscriptionEvent) GetDelId() int32 + func (m *SubscriptionEvent) GetMode() *AccessMode + func (m *SubscriptionEvent) GetPrivate() []byte + func (m *SubscriptionEvent) GetReadId() int32 + func (m *SubscriptionEvent) GetRecvId() int32 + func (m *SubscriptionEvent) GetTopic() string + func (m *SubscriptionEvent) GetUserId() string type TopicDesc + DelId int32 + func (m *TopicDesc) GetDelId() int32 type TopicSub + DelId int32 + func (m *TopicSub) GetDelId() int32 v0.13.1 Nov 28, 2017 Changes in this version + var ClientDel_What_name = map[int32]string + var ClientDel_What_value = map[string]int32 + var Crud_name = map[int32]string + var Crud_value = map[string]int32 + var InfoNote_name = map[int32]string + var InfoNote_value = map[string]int32 + var ServerPres_What_name = map[int32]string + var ServerPres_What_value = map[string]int32 + var ServerResp_RespCode_name = map[int32]string + var ServerResp_RespCode_value = map[string]int32 + var Session_AuthLevel_name = map[int32]string + var Session_AuthLevel_value = map[string]int32 + func RegisterNodeServer(s *grpc.Server, srv NodeServer) + func RegisterPluginServer(s *grpc.Server, srv PluginServer) + type AccessMode struct + Given string + Want string + func (*AccessMode) Descriptor() ([]byte, []int) + func (*AccessMode) ProtoMessage() + func (m *AccessMode) GetGiven() string + func (m *AccessMode) GetWant() string + func (m *AccessMode) Reset() + func (m *AccessMode) String() string + type AccountEvent struct + Action Crud + DefaultAcs *DefaultAcsMode + Public []byte + Tags []string + UserId string + func (*AccountEvent) Descriptor() ([]byte, []int) + func (*AccountEvent) ProtoMessage() + func (m *AccountEvent) GetAction() Crud + func (m *AccountEvent) GetDefaultAcs() *DefaultAcsMode + func (m *AccountEvent) GetPublic() []byte + func (m *AccountEvent) GetTags() []string + func (m *AccountEvent) GetUserId() string + func (m *AccountEvent) Reset() + func (m *AccountEvent) String() string + type BrowseOpts struct + BeforeId int32 + BeforeTs int64 + Limit int32 + SinceId int32 + SinceTs int64 + func (*BrowseOpts) Descriptor() ([]byte, []int) + func (*BrowseOpts) ProtoMessage() + func (m *BrowseOpts) GetBeforeId() int32 + func (m *BrowseOpts) GetBeforeTs() int64 + func (m *BrowseOpts) GetLimit() int32 + func (m *BrowseOpts) GetSinceId() int32 + func (m *BrowseOpts) GetSinceTs() int64 + func (m *BrowseOpts) Reset() + func (m *BrowseOpts) String() string + type ClientAcc struct + Desc *SetDesc + Id string + Login bool + Scheme string + Secret []byte + Tags []string + UserId string + func (*ClientAcc) Descriptor() ([]byte, []int) + func (*ClientAcc) ProtoMessage() + func (m *ClientAcc) GetDesc() *SetDesc + func (m *ClientAcc) GetId() string + func (m *ClientAcc) GetLogin() bool + func (m *ClientAcc) GetScheme() string + func (m *ClientAcc) GetSecret() []byte + func (m *ClientAcc) GetTags() []string + func (m *ClientAcc) GetUserId() string + func (m *ClientAcc) Reset() + func (m *ClientAcc) String() string + type ClientDel struct + Before int32 + Hard bool + Id string + SeqList []int32 + Topic string + UserId string + What ClientDel_What + func (*ClientDel) Descriptor() ([]byte, []int) + func (*ClientDel) ProtoMessage() + func (m *ClientDel) GetBefore() int32 + func (m *ClientDel) GetHard() bool + func (m *ClientDel) GetId() string + func (m *ClientDel) GetSeqList() []int32 + func (m *ClientDel) GetTopic() string + func (m *ClientDel) GetUserId() string + func (m *ClientDel) GetWhat() ClientDel_What + func (m *ClientDel) Reset() + func (m *ClientDel) String() string + type ClientDel_What int32 + const ClientDel_MSG + const ClientDel_SUB + const ClientDel_TOPIC + func (ClientDel_What) EnumDescriptor() ([]byte, []int) + func (x ClientDel_What) String() string + type ClientGet struct + Id string + Query *GetQuery + Topic string + func (*ClientGet) Descriptor() ([]byte, []int) + func (*ClientGet) ProtoMessage() + func (m *ClientGet) GetId() string + func (m *ClientGet) GetQuery() *GetQuery + func (m *ClientGet) GetTopic() string + func (m *ClientGet) Reset() + func (m *ClientGet) String() string + type ClientHi struct + DeviceId string + Id string + Lang string + UserAgent string + Ver int32 + func (*ClientHi) Descriptor() ([]byte, []int) + func (*ClientHi) ProtoMessage() + func (m *ClientHi) GetDeviceId() string + func (m *ClientHi) GetId() string + func (m *ClientHi) GetLang() string + func (m *ClientHi) GetUserAgent() string + func (m *ClientHi) GetVer() int32 + func (m *ClientHi) Reset() + func (m *ClientHi) String() string + type ClientLeave struct + Id string + Topic string + Unsub bool + func (*ClientLeave) Descriptor() ([]byte, []int) + func (*ClientLeave) ProtoMessage() + func (m *ClientLeave) GetId() string + func (m *ClientLeave) GetTopic() string + func (m *ClientLeave) GetUnsub() bool + func (m *ClientLeave) Reset() + func (m *ClientLeave) String() string + type ClientLogin struct + Id string + Scheme string + Secret []byte + func (*ClientLogin) Descriptor() ([]byte, []int) + func (*ClientLogin) ProtoMessage() + func (m *ClientLogin) GetId() string + func (m *ClientLogin) GetScheme() string + func (m *ClientLogin) GetSecret() []byte + func (m *ClientLogin) Reset() + func (m *ClientLogin) String() string + type ClientMsg struct + Message isClientMsg_Message + func (*ClientMsg) Descriptor() ([]byte, []int) + func (*ClientMsg) ProtoMessage() + func (*ClientMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ClientMsg) GetAcc() *ClientAcc + func (m *ClientMsg) GetDel() *ClientDel + func (m *ClientMsg) GetGet() *ClientGet + func (m *ClientMsg) GetHi() *ClientHi + func (m *ClientMsg) GetLeave() *ClientLeave + func (m *ClientMsg) GetLogin() *ClientLogin + func (m *ClientMsg) GetMessage() isClientMsg_Message + func (m *ClientMsg) GetNote() *ClientNote + func (m *ClientMsg) GetPub() *ClientPub + func (m *ClientMsg) GetSet() *ClientSet + func (m *ClientMsg) GetSub() *ClientSub + func (m *ClientMsg) Reset() + func (m *ClientMsg) String() string + type ClientMsg_Acc struct + Acc *ClientAcc + type ClientMsg_Del struct + Del *ClientDel + type ClientMsg_Get struct + Get *ClientGet + type ClientMsg_Hi struct + Hi *ClientHi + type ClientMsg_Leave struct + Leave *ClientLeave + type ClientMsg_Login struct + Login *ClientLogin + type ClientMsg_Note struct + Note *ClientNote + type ClientMsg_Pub struct + Pub *ClientPub + type ClientMsg_Set struct + Set *ClientSet + type ClientMsg_Sub struct + Sub *ClientSub + type ClientNote struct + SeqId int32 + Topic string + What InfoNote + func (*ClientNote) Descriptor() ([]byte, []int) + func (*ClientNote) ProtoMessage() + func (m *ClientNote) GetSeqId() int32 + func (m *ClientNote) GetTopic() string + func (m *ClientNote) GetWhat() InfoNote + func (m *ClientNote) Reset() + func (m *ClientNote) String() string + type ClientPub struct + Content []byte + Head map[string]string + Id string + NoEcho bool + Topic string + func (*ClientPub) Descriptor() ([]byte, []int) + func (*ClientPub) ProtoMessage() + func (m *ClientPub) GetContent() []byte + func (m *ClientPub) GetHead() map[string]string + func (m *ClientPub) GetId() string + func (m *ClientPub) GetNoEcho() bool + func (m *ClientPub) GetTopic() string + func (m *ClientPub) Reset() + func (m *ClientPub) String() string + type ClientReq struct + Msg *ClientMsg + Sess *Session + func (*ClientReq) Descriptor() ([]byte, []int) + func (*ClientReq) ProtoMessage() + func (m *ClientReq) GetMsg() *ClientMsg + func (m *ClientReq) GetSess() *Session + func (m *ClientReq) Reset() + func (m *ClientReq) String() string + type ClientSet struct + Id string + Query *SetQuery + Topic string + func (*ClientSet) Descriptor() ([]byte, []int) + func (*ClientSet) ProtoMessage() + func (m *ClientSet) GetId() string + func (m *ClientSet) GetQuery() *SetQuery + func (m *ClientSet) GetTopic() string + func (m *ClientSet) Reset() + func (m *ClientSet) String() string + type ClientSub struct + GetQuery *GetQuery + Id string + SetQuery *SetQuery + Topic string + func (*ClientSub) Descriptor() ([]byte, []int) + func (*ClientSub) ProtoMessage() + func (m *ClientSub) GetGetQuery() *GetQuery + func (m *ClientSub) GetId() string + func (m *ClientSub) GetSetQuery() *SetQuery + func (m *ClientSub) GetTopic() string + func (m *ClientSub) Reset() + func (m *ClientSub) String() string + type Crud int32 + const Crud_CREATE + const Crud_DELETE + const Crud_UPDATE + func (Crud) EnumDescriptor() ([]byte, []int) + func (x Crud) String() string + type DefaultAcsMode struct + Anon string + Auth string + func (*DefaultAcsMode) Descriptor() ([]byte, []int) + func (*DefaultAcsMode) ProtoMessage() + func (m *DefaultAcsMode) GetAnon() string + func (m *DefaultAcsMode) GetAuth() string + func (m *DefaultAcsMode) Reset() + func (m *DefaultAcsMode) String() string + type GetOpts struct + IfModifiedSince int64 + Limit int32 + func (*GetOpts) Descriptor() ([]byte, []int) + func (*GetOpts) ProtoMessage() + func (m *GetOpts) GetIfModifiedSince() int64 + func (m *GetOpts) GetLimit() int32 + func (m *GetOpts) Reset() + func (m *GetOpts) String() string + type GetQuery struct + Data *BrowseOpts + Desc *GetOpts + Sub *GetOpts + What string + func (*GetQuery) Descriptor() ([]byte, []int) + func (*GetQuery) ProtoMessage() + func (m *GetQuery) GetData() *BrowseOpts + func (m *GetQuery) GetDesc() *GetOpts + func (m *GetQuery) GetSub() *GetOpts + func (m *GetQuery) GetWhat() string + func (m *GetQuery) Reset() + func (m *GetQuery) String() string + type InfoNote int32 + const InfoNote_KP + const InfoNote_READ + const InfoNote_RECV + func (InfoNote) EnumDescriptor() ([]byte, []int) + func (x InfoNote) String() string + type MessageEvent struct + Action Crud + func (*MessageEvent) Descriptor() ([]byte, []int) + func (*MessageEvent) ProtoMessage() + func (m *MessageEvent) GetAction() Crud + func (m *MessageEvent) Reset() + func (m *MessageEvent) String() string + type NodeClient interface + MessageLoop func(ctx context.Context, opts ...grpc.CallOption) (Node_MessageLoopClient, error) + func NewNodeClient(cc *grpc.ClientConn) NodeClient + type NodeServer interface + MessageLoop func(Node_MessageLoopServer) error + type Node_MessageLoopClient interface + Recv func() (*ServerMsg, error) + Send func(*ClientMsg) error + type Node_MessageLoopServer interface + Recv func() (*ClientMsg, error) + Send func(*ServerMsg) error + type PluginClient interface + Account func(ctx context.Context, in *AccountEvent, opts ...grpc.CallOption) (*Unused, error) + FireHose func(ctx context.Context, in *ClientReq, opts ...grpc.CallOption) (*ServerResp, error) + Message func(ctx context.Context, in *MessageEvent, opts ...grpc.CallOption) (*Unused, error) + Subscription func(ctx context.Context, in *SubscriptionEvent, opts ...grpc.CallOption) (*Unused, error) + Topic func(ctx context.Context, in *TopicEvent, opts ...grpc.CallOption) (*Unused, error) + func NewPluginClient(cc *grpc.ClientConn) PluginClient + type PluginServer interface + Account func(context.Context, *AccountEvent) (*Unused, error) + FireHose func(context.Context, *ClientReq) (*ServerResp, error) + Message func(context.Context, *MessageEvent) (*Unused, error) + Subscription func(context.Context, *SubscriptionEvent) (*Unused, error) + Topic func(context.Context, *TopicEvent) (*Unused, error) + type ServerCtrl struct + Code int32 + Id string + Params map[string][]byte + Text string + Topic string + func (*ServerCtrl) Descriptor() ([]byte, []int) + func (*ServerCtrl) ProtoMessage() + func (m *ServerCtrl) GetCode() int32 + func (m *ServerCtrl) GetId() string + func (m *ServerCtrl) GetParams() map[string][]byte + func (m *ServerCtrl) GetText() string + func (m *ServerCtrl) GetTopic() string + func (m *ServerCtrl) Reset() + func (m *ServerCtrl) String() string + type ServerData struct + Content []byte + DeletedAt int64 + FromUserId string + Head map[string]string + SeqId int32 + Topic string + func (*ServerData) Descriptor() ([]byte, []int) + func (*ServerData) ProtoMessage() + func (m *ServerData) GetContent() []byte + func (m *ServerData) GetDeletedAt() int64 + func (m *ServerData) GetFromUserId() string + func (m *ServerData) GetHead() map[string]string + func (m *ServerData) GetSeqId() int32 + func (m *ServerData) GetTopic() string + func (m *ServerData) Reset() + func (m *ServerData) String() string + type ServerInfo struct + FromUserId string + SeqId int32 + Topic string + What InfoNote + func (*ServerInfo) Descriptor() ([]byte, []int) + func (*ServerInfo) ProtoMessage() + func (m *ServerInfo) GetFromUserId() string + func (m *ServerInfo) GetSeqId() int32 + func (m *ServerInfo) GetTopic() string + func (m *ServerInfo) GetWhat() InfoNote + func (m *ServerInfo) Reset() + func (m *ServerInfo) String() string + type ServerMeta struct + Desc *TopicDesc + Id string + Sub []*TopicSub + Topic string + func (*ServerMeta) Descriptor() ([]byte, []int) + func (*ServerMeta) ProtoMessage() + func (m *ServerMeta) GetDesc() *TopicDesc + func (m *ServerMeta) GetId() string + func (m *ServerMeta) GetSub() []*TopicSub + func (m *ServerMeta) GetTopic() string + func (m *ServerMeta) Reset() + func (m *ServerMeta) String() string + type ServerMsg struct + Message isServerMsg_Message + func (*ServerMsg) Descriptor() ([]byte, []int) + func (*ServerMsg) ProtoMessage() + func (*ServerMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ServerMsg) GetCtrl() *ServerCtrl + func (m *ServerMsg) GetData() *ServerData + func (m *ServerMsg) GetInfo() *ServerInfo + func (m *ServerMsg) GetMessage() isServerMsg_Message + func (m *ServerMsg) GetMeta() *ServerMeta + func (m *ServerMsg) GetPres() *ServerPres + func (m *ServerMsg) Reset() + func (m *ServerMsg) String() string + type ServerMsg_Ctrl struct + Ctrl *ServerCtrl + type ServerMsg_Data struct + Data *ServerData + type ServerMsg_Info struct + Info *ServerInfo + type ServerMsg_Meta struct + Meta *ServerMeta + type ServerMsg_Pres struct + Pres *ServerPres + type ServerPres struct + Acs *AccessMode + ActorUserId string + SeqId int32 + SeqList []int32 + Src string + TargetUserId string + Topic string + UserAgent string + What ServerPres_What + func (*ServerPres) Descriptor() ([]byte, []int) + func (*ServerPres) ProtoMessage() + func (m *ServerPres) GetAcs() *AccessMode + func (m *ServerPres) GetActorUserId() string + func (m *ServerPres) GetSeqId() int32 + func (m *ServerPres) GetSeqList() []int32 + func (m *ServerPres) GetSrc() string + func (m *ServerPres) GetTargetUserId() string + func (m *ServerPres) GetTopic() string + func (m *ServerPres) GetUserAgent() string + func (m *ServerPres) GetWhat() ServerPres_What + func (m *ServerPres) Reset() + func (m *ServerPres) String() string + type ServerPres_What int32 + const ServerPres_ACS + const ServerPres_DEL + const ServerPres_GONE + const ServerPres_MSG + const ServerPres_OFF + const ServerPres_ON + const ServerPres_READ + const ServerPres_RECV + const ServerPres_TERM + const ServerPres_UA + const ServerPres_UPD + func (ServerPres_What) EnumDescriptor() ([]byte, []int) + func (x ServerPres_What) String() string + type ServerResp struct + Clmsg *ClientMsg + Srvmsg *ServerMsg + Status ServerResp_RespCode + func (*ServerResp) Descriptor() ([]byte, []int) + func (*ServerResp) ProtoMessage() + func (m *ServerResp) GetClmsg() *ClientMsg + func (m *ServerResp) GetSrvmsg() *ServerMsg + func (m *ServerResp) GetStatus() ServerResp_RespCode + func (m *ServerResp) Reset() + func (m *ServerResp) String() string + type ServerResp_RespCode int32 + const ServerResp_CONTINUE + const ServerResp_DROP + const ServerResp_REPLACE + const ServerResp_RESPOND + func (ServerResp_RespCode) EnumDescriptor() ([]byte, []int) + func (x ServerResp_RespCode) String() string + type Session struct + AuthLevel Session_AuthLevel + DeviceId string + Language string + RemoteAddr string + SessionId string + UserAgent string + UserId string + func (*Session) Descriptor() ([]byte, []int) + func (*Session) ProtoMessage() + func (m *Session) GetAuthLevel() Session_AuthLevel + func (m *Session) GetDeviceId() string + func (m *Session) GetLanguage() string + func (m *Session) GetRemoteAddr() string + func (m *Session) GetSessionId() string + func (m *Session) GetUserAgent() string + func (m *Session) GetUserId() string + func (m *Session) Reset() + func (m *Session) String() string + type Session_AuthLevel int32 + const Session_ANON + const Session_AUTH + const Session_NONE + const Session_ROOT + func (Session_AuthLevel) EnumDescriptor() ([]byte, []int) + func (x Session_AuthLevel) String() string + type SetDesc struct + DefaultAcs *DefaultAcsMode + Private []byte + Public []byte + func (*SetDesc) Descriptor() ([]byte, []int) + func (*SetDesc) ProtoMessage() + func (m *SetDesc) GetDefaultAcs() *DefaultAcsMode + func (m *SetDesc) GetPrivate() []byte + func (m *SetDesc) GetPublic() []byte + func (m *SetDesc) Reset() + func (m *SetDesc) String() string + type SetQuery struct + Desc *SetDesc + Sub *SetSub + func (*SetQuery) Descriptor() ([]byte, []int) + func (*SetQuery) ProtoMessage() + func (m *SetQuery) GetDesc() *SetDesc + func (m *SetQuery) GetSub() *SetSub + func (m *SetQuery) Reset() + func (m *SetQuery) String() string + type SetSub struct + Mode string + UserId string + func (*SetSub) Descriptor() ([]byte, []int) + func (*SetSub) ProtoMessage() + func (m *SetSub) GetMode() string + func (m *SetSub) GetUserId() string + func (m *SetSub) Reset() + func (m *SetSub) String() string + type SubscriptionEvent struct + Action Crud + Sub *TopicSub + SubId string + func (*SubscriptionEvent) Descriptor() ([]byte, []int) + func (*SubscriptionEvent) ProtoMessage() + func (m *SubscriptionEvent) GetAction() Crud + func (m *SubscriptionEvent) GetSub() *TopicSub + func (m *SubscriptionEvent) GetSubId() string + func (m *SubscriptionEvent) Reset() + func (m *SubscriptionEvent) String() string + type TopicDesc struct + Acs *AccessMode + ClearId int32 + CreatedAt int64 + Defacs *DefaultAcsMode + Private []byte + Public []byte + ReadId int32 + RecvId int32 + SeqId int32 + UpdatedAt int64 + func (*TopicDesc) Descriptor() ([]byte, []int) + func (*TopicDesc) ProtoMessage() + func (m *TopicDesc) GetAcs() *AccessMode + func (m *TopicDesc) GetClearId() int32 + func (m *TopicDesc) GetCreatedAt() int64 + func (m *TopicDesc) GetDefacs() *DefaultAcsMode + func (m *TopicDesc) GetPrivate() []byte + func (m *TopicDesc) GetPublic() []byte + func (m *TopicDesc) GetReadId() int32 + func (m *TopicDesc) GetRecvId() int32 + func (m *TopicDesc) GetSeqId() int32 + func (m *TopicDesc) GetUpdatedAt() int64 + func (m *TopicDesc) Reset() + func (m *TopicDesc) String() string + type TopicEvent struct + Action Crud + Desc *TopicDesc + Name string + func (*TopicEvent) Descriptor() ([]byte, []int) + func (*TopicEvent) ProtoMessage() + func (m *TopicEvent) GetAction() Crud + func (m *TopicEvent) GetDesc() *TopicDesc + func (m *TopicEvent) GetName() string + func (m *TopicEvent) Reset() + func (m *TopicEvent) String() string + type TopicSub struct + Acs *AccessMode + ClearId int32 + DeletedAt int64 + LastSeenTime int64 + LastSeenUserAgent string + Online bool + Private []byte + Public []byte + ReadId int32 + RecvId int32 + SeqId int32 + Topic string + UpdatedAt int64 + UserId string + func (*TopicSub) Descriptor() ([]byte, []int) + func (*TopicSub) ProtoMessage() + func (m *TopicSub) GetAcs() *AccessMode + func (m *TopicSub) GetClearId() int32 + func (m *TopicSub) GetDeletedAt() int64 + func (m *TopicSub) GetLastSeenTime() int64 + func (m *TopicSub) GetLastSeenUserAgent() string + func (m *TopicSub) GetOnline() bool + func (m *TopicSub) GetPrivate() []byte + func (m *TopicSub) GetPublic() []byte + func (m *TopicSub) GetReadId() int32 + func (m *TopicSub) GetRecvId() int32 + func (m *TopicSub) GetSeqId() int32 + func (m *TopicSub) GetTopic() string + func (m *TopicSub) GetUpdatedAt() int64 + func (m *TopicSub) GetUserId() string + func (m *TopicSub) Reset() + func (m *TopicSub) String() string + type Unused struct + func (*Unused) Descriptor() ([]byte, []int) + func (*Unused) ProtoMessage() + func (m *Unused) Reset() + func (m *Unused) String() string