Documentation ¶
Index ¶
- Variables
- func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)
- func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)
- type AccessMode
- type AccountEvent
- func (*AccountEvent) Descriptor() ([]byte, []int)deprecated
- func (x *AccountEvent) GetAction() Crud
- func (x *AccountEvent) GetDefaultAcs() *DefaultAcsMode
- func (x *AccountEvent) GetPublic() []byte
- func (x *AccountEvent) GetTags() []string
- func (x *AccountEvent) GetUserId() string
- func (*AccountEvent) ProtoMessage()
- func (x *AccountEvent) ProtoReflect() protoreflect.Message
- func (x *AccountEvent) Reset()
- func (x *AccountEvent) String() string
- type AuthLevel
- type CallEvent
- type ClientAcc
- func (*ClientAcc) Descriptor() ([]byte, []int)deprecated
- func (x *ClientAcc) GetCred() []*ClientCred
- func (x *ClientAcc) GetDesc() *SetDesc
- func (x *ClientAcc) GetId() string
- func (x *ClientAcc) GetLogin() bool
- func (x *ClientAcc) GetScheme() string
- func (x *ClientAcc) GetSecret() []byte
- func (x *ClientAcc) GetState() string
- func (x *ClientAcc) GetTags() []string
- func (x *ClientAcc) GetToken() []byte
- func (x *ClientAcc) GetUserId() string
- func (*ClientAcc) ProtoMessage()
- func (x *ClientAcc) ProtoReflect() protoreflect.Message
- func (x *ClientAcc) Reset()
- func (x *ClientAcc) String() string
- type ClientCred
- func (*ClientCred) Descriptor() ([]byte, []int)deprecated
- func (x *ClientCred) GetMethod() string
- func (x *ClientCred) GetParams() map[string][]byte
- func (x *ClientCred) GetResponse() string
- func (x *ClientCred) GetValue() string
- func (*ClientCred) ProtoMessage()
- func (x *ClientCred) ProtoReflect() protoreflect.Message
- func (x *ClientCred) Reset()
- func (x *ClientCred) String() string
- type ClientDel
- func (*ClientDel) Descriptor() ([]byte, []int)deprecated
- func (x *ClientDel) GetCred() *ClientCred
- func (x *ClientDel) GetDelSeq() []*SeqRange
- func (x *ClientDel) GetHard() bool
- func (x *ClientDel) GetId() string
- func (x *ClientDel) GetTopic() string
- func (x *ClientDel) GetUserId() string
- func (x *ClientDel) GetWhat() ClientDel_What
- func (*ClientDel) ProtoMessage()
- func (x *ClientDel) ProtoReflect() protoreflect.Message
- func (x *ClientDel) Reset()
- func (x *ClientDel) String() string
- type ClientDel_What
- func (ClientDel_What) Descriptor() protoreflect.EnumDescriptor
- func (x ClientDel_What) Enum() *ClientDel_What
- func (ClientDel_What) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClientDel_What) Number() protoreflect.EnumNumber
- func (x ClientDel_What) String() string
- func (ClientDel_What) Type() protoreflect.EnumType
- type ClientExtra
- func (*ClientExtra) Descriptor() ([]byte, []int)deprecated
- func (x *ClientExtra) GetAttachments() []string
- func (x *ClientExtra) GetAuthLevel() AuthLevel
- func (x *ClientExtra) GetOnBehalfOf() string
- func (*ClientExtra) ProtoMessage()
- func (x *ClientExtra) ProtoReflect() protoreflect.Message
- func (x *ClientExtra) Reset()
- func (x *ClientExtra) String() string
- type ClientGet
- func (*ClientGet) Descriptor() ([]byte, []int)deprecated
- func (x *ClientGet) GetId() string
- func (x *ClientGet) GetQuery() *GetQuery
- func (x *ClientGet) GetTopic() string
- func (*ClientGet) ProtoMessage()
- func (x *ClientGet) ProtoReflect() protoreflect.Message
- func (x *ClientGet) Reset()
- func (x *ClientGet) String() string
- type ClientHi
- func (*ClientHi) Descriptor() ([]byte, []int)deprecated
- func (x *ClientHi) GetBackground() bool
- func (x *ClientHi) GetDeviceId() string
- func (x *ClientHi) GetId() string
- func (x *ClientHi) GetLang() string
- func (x *ClientHi) GetPlatform() string
- func (x *ClientHi) GetUserAgent() string
- func (x *ClientHi) GetVer() string
- func (*ClientHi) ProtoMessage()
- func (x *ClientHi) ProtoReflect() protoreflect.Message
- func (x *ClientHi) Reset()
- func (x *ClientHi) String() string
- type ClientLeave
- func (*ClientLeave) Descriptor() ([]byte, []int)deprecated
- func (x *ClientLeave) GetId() string
- func (x *ClientLeave) GetTopic() string
- func (x *ClientLeave) GetUnsub() bool
- func (*ClientLeave) ProtoMessage()
- func (x *ClientLeave) ProtoReflect() protoreflect.Message
- func (x *ClientLeave) Reset()
- func (x *ClientLeave) String() string
- type ClientLogin
- func (*ClientLogin) Descriptor() ([]byte, []int)deprecated
- func (x *ClientLogin) GetCred() []*ClientCred
- func (x *ClientLogin) GetId() string
- func (x *ClientLogin) GetScheme() string
- func (x *ClientLogin) GetSecret() []byte
- func (*ClientLogin) ProtoMessage()
- func (x *ClientLogin) ProtoReflect() protoreflect.Message
- func (x *ClientLogin) Reset()
- func (x *ClientLogin) String() string
- type ClientMsg
- func (*ClientMsg) Descriptor() ([]byte, []int)deprecated
- func (x *ClientMsg) GetAcc() *ClientAcc
- func (x *ClientMsg) GetDel() *ClientDel
- func (x *ClientMsg) GetExtra() *ClientExtra
- func (x *ClientMsg) GetGet() *ClientGet
- func (x *ClientMsg) GetHi() *ClientHi
- func (x *ClientMsg) GetLeave() *ClientLeave
- func (x *ClientMsg) GetLogin() *ClientLogin
- func (m *ClientMsg) GetMessage() isClientMsg_Message
- func (x *ClientMsg) GetNote() *ClientNote
- func (x *ClientMsg) GetPub() *ClientPub
- func (x *ClientMsg) GetSet() *ClientSet
- func (x *ClientMsg) GetSub() *ClientSub
- func (*ClientMsg) ProtoMessage()
- func (x *ClientMsg) ProtoReflect() protoreflect.Message
- func (x *ClientMsg) Reset()
- func (x *ClientMsg) String() string
- type ClientMsg_Acc
- type ClientMsg_Del
- type ClientMsg_Get
- type ClientMsg_Hi
- type ClientMsg_Leave
- type ClientMsg_Login
- type ClientMsg_Note
- type ClientMsg_Pub
- type ClientMsg_Set
- type ClientMsg_Sub
- type ClientNote
- func (*ClientNote) Descriptor() ([]byte, []int)deprecated
- func (x *ClientNote) GetEvent() CallEvent
- func (x *ClientNote) GetPayload() []byte
- func (x *ClientNote) GetSeqId() int32
- func (x *ClientNote) GetTopic() string
- func (x *ClientNote) GetUnread() int32
- func (x *ClientNote) GetWhat() InfoNote
- func (*ClientNote) ProtoMessage()
- func (x *ClientNote) ProtoReflect() protoreflect.Message
- func (x *ClientNote) Reset()
- func (x *ClientNote) String() string
- type ClientPub
- func (*ClientPub) Descriptor() ([]byte, []int)deprecated
- func (x *ClientPub) GetContent() []byte
- func (x *ClientPub) GetHead() map[string][]byte
- func (x *ClientPub) GetId() string
- func (x *ClientPub) GetNoEcho() bool
- func (x *ClientPub) GetTopic() string
- func (*ClientPub) ProtoMessage()
- func (x *ClientPub) ProtoReflect() protoreflect.Message
- func (x *ClientPub) Reset()
- func (x *ClientPub) String() string
- type ClientReq
- type ClientSet
- func (*ClientSet) Descriptor() ([]byte, []int)deprecated
- func (x *ClientSet) GetId() string
- func (x *ClientSet) GetQuery() *SetQuery
- func (x *ClientSet) GetTopic() string
- func (*ClientSet) ProtoMessage()
- func (x *ClientSet) ProtoReflect() protoreflect.Message
- func (x *ClientSet) Reset()
- func (x *ClientSet) String() string
- type ClientSub
- func (*ClientSub) Descriptor() ([]byte, []int)deprecated
- func (x *ClientSub) GetGetQuery() *GetQuery
- func (x *ClientSub) GetId() string
- func (x *ClientSub) GetSetQuery() *SetQuery
- func (x *ClientSub) GetTopic() string
- func (*ClientSub) ProtoMessage()
- func (x *ClientSub) ProtoReflect() protoreflect.Message
- func (x *ClientSub) Reset()
- func (x *ClientSub) String() string
- type Crud
- type DefaultAcsMode
- func (*DefaultAcsMode) Descriptor() ([]byte, []int)deprecated
- func (x *DefaultAcsMode) GetAnon() string
- func (x *DefaultAcsMode) GetAuth() string
- func (*DefaultAcsMode) ProtoMessage()
- func (x *DefaultAcsMode) ProtoReflect() protoreflect.Message
- func (x *DefaultAcsMode) Reset()
- func (x *DefaultAcsMode) String() string
- type DelValues
- type GetOpts
- func (*GetOpts) Descriptor() ([]byte, []int)deprecated
- func (x *GetOpts) GetBeforeId() int32
- func (x *GetOpts) GetIfModifiedSince() int64
- func (x *GetOpts) GetLimit() int32
- func (x *GetOpts) GetSinceId() int32
- func (x *GetOpts) GetTopic() string
- func (x *GetOpts) GetUser() string
- func (*GetOpts) ProtoMessage()
- func (x *GetOpts) ProtoReflect() protoreflect.Message
- func (x *GetOpts) Reset()
- func (x *GetOpts) String() string
- type GetQuery
- func (*GetQuery) Descriptor() ([]byte, []int)deprecated
- func (x *GetQuery) GetData() *GetOpts
- func (x *GetQuery) GetDesc() *GetOpts
- func (x *GetQuery) GetSub() *GetOpts
- func (x *GetQuery) GetWhat() string
- func (*GetQuery) ProtoMessage()
- func (x *GetQuery) ProtoReflect() protoreflect.Message
- func (x *GetQuery) Reset()
- func (x *GetQuery) String() string
- type InfoNote
- type MessageEvent
- func (*MessageEvent) Descriptor() ([]byte, []int)deprecated
- func (x *MessageEvent) GetAction() Crud
- func (x *MessageEvent) GetMsg() *ServerData
- func (*MessageEvent) ProtoMessage()
- func (x *MessageEvent) ProtoReflect() protoreflect.Message
- func (x *MessageEvent) Reset()
- func (x *MessageEvent) String() string
- type NodeClient
- type NodeServer
- type Node_MessageLoopClient
- type Node_MessageLoopServer
- type PluginClient
- type PluginServer
- type RespCode
- type SearchFound
- func (*SearchFound) Descriptor() ([]byte, []int)deprecated
- func (x *SearchFound) GetQuery() string
- func (x *SearchFound) GetResult() []*TopicSub
- func (x *SearchFound) GetStatus() RespCode
- func (*SearchFound) ProtoMessage()
- func (x *SearchFound) ProtoReflect() protoreflect.Message
- func (x *SearchFound) Reset()
- func (x *SearchFound) String() string
- type SearchQuery
- func (*SearchQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SearchQuery) GetQuery() string
- func (x *SearchQuery) GetUserId() string
- func (*SearchQuery) ProtoMessage()
- func (x *SearchQuery) ProtoReflect() protoreflect.Message
- func (x *SearchQuery) Reset()
- func (x *SearchQuery) String() string
- type SeqRange
- type ServerCred
- func (*ServerCred) Descriptor() ([]byte, []int)deprecated
- func (x *ServerCred) GetDone() bool
- func (x *ServerCred) GetMethod() string
- func (x *ServerCred) GetValue() string
- func (*ServerCred) ProtoMessage()
- func (x *ServerCred) ProtoReflect() protoreflect.Message
- func (x *ServerCred) Reset()
- func (x *ServerCred) String() string
- type ServerCtrl
- func (*ServerCtrl) Descriptor() ([]byte, []int)deprecated
- func (x *ServerCtrl) GetCode() int32
- func (x *ServerCtrl) GetId() string
- func (x *ServerCtrl) GetParams() map[string][]byte
- func (x *ServerCtrl) GetText() string
- func (x *ServerCtrl) GetTopic() string
- func (*ServerCtrl) ProtoMessage()
- func (x *ServerCtrl) ProtoReflect() protoreflect.Message
- func (x *ServerCtrl) Reset()
- func (x *ServerCtrl) String() string
- type ServerData
- func (*ServerData) Descriptor() ([]byte, []int)deprecated
- func (x *ServerData) GetContent() []byte
- func (x *ServerData) GetDeletedAt() int64
- func (x *ServerData) GetFromUserId() string
- func (x *ServerData) GetHead() map[string][]byte
- func (x *ServerData) GetSeqId() int32
- func (x *ServerData) GetTimestamp() int64
- func (x *ServerData) GetTopic() string
- func (*ServerData) ProtoMessage()
- func (x *ServerData) ProtoReflect() protoreflect.Message
- func (x *ServerData) Reset()
- func (x *ServerData) String() string
- type ServerInfo
- func (*ServerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ServerInfo) GetEvent() CallEvent
- func (x *ServerInfo) GetFromUserId() string
- func (x *ServerInfo) GetPayload() []byte
- func (x *ServerInfo) GetSeqId() int32
- func (x *ServerInfo) GetSrc() string
- func (x *ServerInfo) GetTopic() string
- func (x *ServerInfo) GetWhat() InfoNote
- func (*ServerInfo) ProtoMessage()
- func (x *ServerInfo) ProtoReflect() protoreflect.Message
- func (x *ServerInfo) Reset()
- func (x *ServerInfo) String() string
- type ServerMeta
- func (*ServerMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMeta) GetCred() []*ServerCred
- func (x *ServerMeta) GetDel() *DelValues
- func (x *ServerMeta) GetDesc() *TopicDesc
- func (x *ServerMeta) GetId() string
- func (x *ServerMeta) GetSub() []*TopicSub
- func (x *ServerMeta) GetTags() []string
- func (x *ServerMeta) GetTopic() string
- func (*ServerMeta) ProtoMessage()
- func (x *ServerMeta) ProtoReflect() protoreflect.Message
- func (x *ServerMeta) Reset()
- func (x *ServerMeta) String() string
- type ServerMsg
- func (*ServerMsg) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMsg) GetCtrl() *ServerCtrl
- func (x *ServerMsg) GetData() *ServerData
- func (x *ServerMsg) GetInfo() *ServerInfo
- func (m *ServerMsg) GetMessage() isServerMsg_Message
- func (x *ServerMsg) GetMeta() *ServerMeta
- func (x *ServerMsg) GetPres() *ServerPres
- func (x *ServerMsg) GetTopic() string
- func (*ServerMsg) ProtoMessage()
- func (x *ServerMsg) ProtoReflect() protoreflect.Message
- func (x *ServerMsg) Reset()
- func (x *ServerMsg) String() string
- type ServerMsg_Ctrl
- type ServerMsg_Data
- type ServerMsg_Info
- type ServerMsg_Meta
- type ServerMsg_Pres
- type ServerPres
- func (*ServerPres) Descriptor() ([]byte, []int)deprecated
- func (x *ServerPres) GetAcs() *AccessMode
- func (x *ServerPres) GetActorUserId() string
- func (x *ServerPres) GetDelId() int32
- func (x *ServerPres) GetDelSeq() []*SeqRange
- func (x *ServerPres) GetSeqId() int32
- func (x *ServerPres) GetSrc() string
- func (x *ServerPres) GetTargetUserId() string
- func (x *ServerPres) GetTopic() string
- func (x *ServerPres) GetUserAgent() string
- func (x *ServerPres) GetWhat() ServerPres_What
- func (*ServerPres) ProtoMessage()
- func (x *ServerPres) ProtoReflect() protoreflect.Message
- func (x *ServerPres) Reset()
- func (x *ServerPres) String() string
- type ServerPres_What
- func (ServerPres_What) Descriptor() protoreflect.EnumDescriptor
- func (x ServerPres_What) Enum() *ServerPres_What
- func (ServerPres_What) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServerPres_What) Number() protoreflect.EnumNumber
- func (x ServerPres_What) String() string
- func (ServerPres_What) Type() protoreflect.EnumType
- type ServerResp
- func (*ServerResp) Descriptor() ([]byte, []int)deprecated
- func (x *ServerResp) GetClmsg() *ClientMsg
- func (x *ServerResp) GetSrvmsg() *ServerMsg
- func (x *ServerResp) GetStatus() RespCode
- func (*ServerResp) ProtoMessage()
- func (x *ServerResp) ProtoReflect() protoreflect.Message
- func (x *ServerResp) Reset()
- func (x *ServerResp) String() string
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetAuthLevel() AuthLevel
- func (x *Session) GetDeviceId() string
- func (x *Session) GetLanguage() string
- func (x *Session) GetRemoteAddr() string
- func (x *Session) GetSessionId() string
- func (x *Session) GetUserAgent() string
- func (x *Session) GetUserId() string
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type SetDesc
- func (*SetDesc) Descriptor() ([]byte, []int)deprecated
- func (x *SetDesc) GetDefaultAcs() *DefaultAcsMode
- func (x *SetDesc) GetPrivate() []byte
- func (x *SetDesc) GetPublic() []byte
- func (x *SetDesc) GetTrusted() []byte
- func (*SetDesc) ProtoMessage()
- func (x *SetDesc) ProtoReflect() protoreflect.Message
- func (x *SetDesc) Reset()
- func (x *SetDesc) String() string
- type SetQuery
- func (*SetQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SetQuery) GetCred() *ClientCred
- func (x *SetQuery) GetDesc() *SetDesc
- func (x *SetQuery) GetSub() *SetSub
- func (x *SetQuery) GetTags() []string
- func (*SetQuery) ProtoMessage()
- func (x *SetQuery) ProtoReflect() protoreflect.Message
- func (x *SetQuery) Reset()
- func (x *SetQuery) String() string
- type SetSub
- type SubscriptionEvent
- func (*SubscriptionEvent) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionEvent) GetAction() Crud
- func (x *SubscriptionEvent) GetDelId() int32
- func (x *SubscriptionEvent) GetMode() *AccessMode
- func (x *SubscriptionEvent) GetPrivate() []byte
- func (x *SubscriptionEvent) GetReadId() int32
- func (x *SubscriptionEvent) GetRecvId() int32
- func (x *SubscriptionEvent) GetTopic() string
- func (x *SubscriptionEvent) GetUserId() string
- func (*SubscriptionEvent) ProtoMessage()
- func (x *SubscriptionEvent) ProtoReflect() protoreflect.Message
- func (x *SubscriptionEvent) Reset()
- func (x *SubscriptionEvent) String() string
- type TopicDesc
- func (*TopicDesc) Descriptor() ([]byte, []int)deprecated
- func (x *TopicDesc) GetAcs() *AccessMode
- func (x *TopicDesc) GetCreatedAt() int64
- func (x *TopicDesc) GetDefacs() *DefaultAcsMode
- func (x *TopicDesc) GetDelId() int32
- func (x *TopicDesc) GetIsChan() bool
- func (x *TopicDesc) GetLastSeenTime() int64
- func (x *TopicDesc) GetLastSeenUserAgent() string
- func (x *TopicDesc) GetPrivate() []byte
- func (x *TopicDesc) GetPublic() []byte
- func (x *TopicDesc) GetReadId() int32
- func (x *TopicDesc) GetRecvId() int32
- func (x *TopicDesc) GetSeqId() int32
- func (x *TopicDesc) GetState() string
- func (x *TopicDesc) GetStateAt() int64
- func (x *TopicDesc) GetTouchedAt() int64
- func (x *TopicDesc) GetTrusted() []byte
- func (x *TopicDesc) GetUpdatedAt() int64
- func (*TopicDesc) ProtoMessage()
- func (x *TopicDesc) ProtoReflect() protoreflect.Message
- func (x *TopicDesc) Reset()
- func (x *TopicDesc) String() string
- type TopicEvent
- func (*TopicEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TopicEvent) GetAction() Crud
- func (x *TopicEvent) GetDesc() *TopicDesc
- func (x *TopicEvent) GetName() string
- func (*TopicEvent) ProtoMessage()
- func (x *TopicEvent) ProtoReflect() protoreflect.Message
- func (x *TopicEvent) Reset()
- func (x *TopicEvent) String() string
- type TopicSub
- func (*TopicSub) Descriptor() ([]byte, []int)deprecated
- func (x *TopicSub) GetAcs() *AccessMode
- func (x *TopicSub) GetDelId() int32
- func (x *TopicSub) GetDeletedAt() int64
- func (x *TopicSub) GetLastSeenTime() int64
- func (x *TopicSub) GetLastSeenUserAgent() string
- func (x *TopicSub) GetOnline() bool
- func (x *TopicSub) GetPrivate() []byte
- func (x *TopicSub) GetPublic() []byte
- func (x *TopicSub) GetReadId() int32
- func (x *TopicSub) GetRecvId() int32
- func (x *TopicSub) GetSeqId() int32
- func (x *TopicSub) GetTopic() string
- func (x *TopicSub) GetTouchedAt() int64
- func (x *TopicSub) GetTrusted() []byte
- func (x *TopicSub) GetUpdatedAt() int64
- func (x *TopicSub) GetUserId() string
- func (*TopicSub) ProtoMessage()
- func (x *TopicSub) ProtoReflect() protoreflect.Message
- func (x *TopicSub) Reset()
- func (x *TopicSub) String() string
- type UnimplementedNodeServer
- type UnimplementedPluginServer
- func (UnimplementedPluginServer) Account(context.Context, *AccountEvent) (*Unused, error)
- func (UnimplementedPluginServer) Find(context.Context, *SearchQuery) (*SearchFound, error)
- func (UnimplementedPluginServer) FireHose(context.Context, *ClientReq) (*ServerResp, error)
- func (UnimplementedPluginServer) Message(context.Context, *MessageEvent) (*Unused, error)
- func (UnimplementedPluginServer) Subscription(context.Context, *SubscriptionEvent) (*Unused, error)
- func (UnimplementedPluginServer) Topic(context.Context, *TopicEvent) (*Unused, error)
- type UnsafeNodeServer
- type UnsafePluginServer
- type Unused
Constants ¶
This section is empty.
Variables ¶
var ( AuthLevel_name = map[int32]string{ 0: "NONE", 10: "ANON", 20: "AUTH", 30: "ROOT", } AuthLevel_value = map[string]int32{ "NONE": 0, "ANON": 10, "AUTH": 20, "ROOT": 30, } )
Enum value maps for AuthLevel.
var ( InfoNote_name = map[int32]string{ 0: "X1", 1: "READ", 2: "RECV", 3: "KP", 4: "CALL", } InfoNote_value = map[string]int32{ "X1": 0, "READ": 1, "RECV": 2, "KP": 3, "CALL": 4, } )
Enum value maps for InfoNote.
var ( CallEvent_name = map[int32]string{ 0: "X2", 1: "ACCEPT", 2: "ANSWER", 3: "HANG_UP", 4: "ICE_CANDIDATE", 5: "INVITE", 6: "OFFER", 7: "RINGING", } CallEvent_value = map[string]int32{ "X2": 0, "ACCEPT": 1, "ANSWER": 2, "HANG_UP": 3, "ICE_CANDIDATE": 4, "INVITE": 5, "OFFER": 6, "RINGING": 7, } )
Enum value maps for CallEvent.
var ( RespCode_name = map[int32]string{ 0: "CONTINUE", 1: "DROP", 2: "RESPOND", 3: "REPLACE", } RespCode_value = map[string]int32{ "CONTINUE": 0, "DROP": 1, "RESPOND": 2, "REPLACE": 3, } )
Enum value maps for RespCode.
var ( Crud_name = map[int32]string{ 0: "CREATE", 1: "UPDATE", 2: "DELETE", } Crud_value = map[string]int32{ "CREATE": 0, "UPDATE": 1, "DELETE": 2, } )
Enum value maps for Crud.
var ( ClientDel_What_name = map[int32]string{ 0: "X0", 1: "MSG", 2: "TOPIC", 3: "SUB", 4: "USER", 5: "CRED", } ClientDel_What_value = map[string]int32{ "X0": 0, "MSG": 1, "TOPIC": 2, "SUB": 3, "USER": 4, "CRED": 5, } )
Enum value maps for ClientDel_What.
var ( ServerPres_What_name = map[int32]string{ 0: "X3", 1: "ON", 2: "OFF", 3: "UA", 4: "UPD", 5: "GONE", 6: "ACS", 7: "TERM", 8: "MSG", 9: "READ", 10: "RECV", 11: "DEL", 12: "TAGS", } ServerPres_What_value = map[string]int32{ "X3": 0, "ON": 1, "OFF": 2, "UA": 3, "UPD": 4, "GONE": 5, "ACS": 6, "TERM": 7, "MSG": 8, "READ": 9, "RECV": 10, "DEL": 11, "TAGS": 12, } )
Enum value maps for ServerPres_What.
var File_model_proto protoreflect.FileDescriptor
var Node_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pbx.Node", HandlerType: (*NodeServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "MessageLoop", Handler: _Node_MessageLoop_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "model.proto", }
Node_ServiceDesc is the grpc.ServiceDesc for Node service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Plugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pbx.Plugin", HandlerType: (*PluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FireHose", Handler: _Plugin_FireHose_Handler, }, { MethodName: "Find", Handler: _Plugin_Find_Handler, }, { MethodName: "Account", Handler: _Plugin_Account_Handler, }, { MethodName: "Topic", Handler: _Plugin_Topic_Handler, }, { MethodName: "Subscription", Handler: _Plugin_Subscription_Handler, }, { MethodName: "Message", Handler: _Plugin_Message_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "model.proto", }
Plugin_ServiceDesc is the grpc.ServiceDesc for Plugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNodeServer ¶
func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)
func RegisterPluginServer ¶
func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)
Types ¶
type AccessMode ¶
type AccessMode struct { // Access mode requested by the user Want string `protobuf:"bytes,1,opt,name=want,proto3" json:"want,omitempty"` // Access mode granted to the user by the admin Given string `protobuf:"bytes,2,opt,name=given,proto3" json:"given,omitempty"` // contains filtered or unexported fields }
Actual access mode
func (*AccessMode) Descriptor
deprecated
func (*AccessMode) Descriptor() ([]byte, []int)
Deprecated: Use AccessMode.ProtoReflect.Descriptor instead.
func (*AccessMode) GetGiven ¶
func (x *AccessMode) GetGiven() string
func (*AccessMode) GetWant ¶
func (x *AccessMode) GetWant() string
func (*AccessMode) ProtoMessage ¶
func (*AccessMode) ProtoMessage()
func (*AccessMode) ProtoReflect ¶
func (x *AccessMode) ProtoReflect() protoreflect.Message
func (*AccessMode) Reset ¶
func (x *AccessMode) Reset()
func (*AccessMode) String ¶
func (x *AccessMode) String() string
type AccountEvent ¶
type AccountEvent struct { Action Crud `protobuf:"varint,1,opt,name=action,proto3,enum=pbx.Crud" json:"action,omitempty"` UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` DefaultAcs *DefaultAcsMode `protobuf:"bytes,3,opt,name=default_acs,json=defaultAcs,proto3" json:"default_acs,omitempty"` Public []byte `protobuf:"bytes,4,opt,name=public,proto3" json:"public,omitempty"` // Indexable tags for user discovery Tags []string `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*AccountEvent) Descriptor
deprecated
func (*AccountEvent) Descriptor() ([]byte, []int)
Deprecated: Use AccountEvent.ProtoReflect.Descriptor instead.
func (*AccountEvent) GetAction ¶
func (x *AccountEvent) GetAction() Crud
func (*AccountEvent) GetDefaultAcs ¶
func (x *AccountEvent) GetDefaultAcs() *DefaultAcsMode
func (*AccountEvent) GetPublic ¶
func (x *AccountEvent) GetPublic() []byte
func (*AccountEvent) GetTags ¶
func (x *AccountEvent) GetTags() []string
func (*AccountEvent) GetUserId ¶
func (x *AccountEvent) GetUserId() string
func (*AccountEvent) ProtoMessage ¶
func (*AccountEvent) ProtoMessage()
func (*AccountEvent) ProtoReflect ¶
func (x *AccountEvent) ProtoReflect() protoreflect.Message
func (*AccountEvent) Reset ¶
func (x *AccountEvent) Reset()
func (*AccountEvent) String ¶
func (x *AccountEvent) String() string
type AuthLevel ¶
type AuthLevel int32
Authentication level
func (AuthLevel) Descriptor ¶
func (AuthLevel) Descriptor() protoreflect.EnumDescriptor
func (AuthLevel) EnumDescriptor
deprecated
func (AuthLevel) Number ¶
func (x AuthLevel) Number() protoreflect.EnumNumber
func (AuthLevel) Type ¶
func (AuthLevel) Type() protoreflect.EnumType
type CallEvent ¶
type CallEvent int32
const ( // Invalid value. The name must be globally unique. CallEvent_X2 CallEvent = 0 CallEvent_ACCEPT CallEvent = 1 CallEvent_ANSWER CallEvent = 2 CallEvent_HANG_UP CallEvent = 3 CallEvent_ICE_CANDIDATE CallEvent = 4 CallEvent_INVITE CallEvent = 5 CallEvent_OFFER CallEvent = 6 CallEvent_RINGING CallEvent = 7 )
func (CallEvent) Descriptor ¶
func (CallEvent) Descriptor() protoreflect.EnumDescriptor
func (CallEvent) EnumDescriptor
deprecated
func (CallEvent) Number ¶
func (x CallEvent) Number() protoreflect.EnumNumber
func (CallEvent) Type ¶
func (CallEvent) Type() protoreflect.EnumType
type ClientAcc ¶
type ClientAcc struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // User being created or updated UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // The initial authentication scheme the account can use Scheme string `protobuf:"bytes,3,opt,name=scheme,proto3" json:"scheme,omitempty"` // Shared secret Secret []byte `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"` // Authenticate session with the newly created account Login bool `protobuf:"varint,5,opt,name=login,proto3" json:"login,omitempty"` // Indexable tags for user discovery Tags []string `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"` // User initialization data when creating a new user, otherwise ignored Desc *SetDesc `protobuf:"bytes,7,opt,name=desc,proto3" json:"desc,omitempty"` // Credentials for verification. Cred []*ClientCred `protobuf:"bytes,8,rep,name=cred,proto3" json:"cred,omitempty"` // Authentication token used for resetting a password. Token []byte `protobuf:"bytes,9,opt,name=token,proto3" json:"token,omitempty"` // Account state: normal ("ok"), suspended State string `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
User creation message {acc}
func (*ClientAcc) Descriptor
deprecated
func (*ClientAcc) GetCred ¶
func (x *ClientAcc) GetCred() []*ClientCred
func (*ClientAcc) ProtoMessage ¶
func (*ClientAcc) ProtoMessage()
func (*ClientAcc) ProtoReflect ¶
func (x *ClientAcc) ProtoReflect() protoreflect.Message
type ClientCred ¶
type ClientCred struct { // Credential type, i.e. `email` or `tel`. Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // Value to verify, i.e. `user@example.com` or `+18003287448` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Verification response Response string `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"` // Request parameters, such as preferences or country code. Params map[string][]byte `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Credentials such as email or phone number
func (*ClientCred) Descriptor
deprecated
func (*ClientCred) Descriptor() ([]byte, []int)
Deprecated: Use ClientCred.ProtoReflect.Descriptor instead.
func (*ClientCred) GetMethod ¶
func (x *ClientCred) GetMethod() string
func (*ClientCred) GetParams ¶
func (x *ClientCred) GetParams() map[string][]byte
func (*ClientCred) GetResponse ¶
func (x *ClientCred) GetResponse() string
func (*ClientCred) GetValue ¶
func (x *ClientCred) GetValue() string
func (*ClientCred) ProtoMessage ¶
func (*ClientCred) ProtoMessage()
func (*ClientCred) ProtoReflect ¶
func (x *ClientCred) ProtoReflect() protoreflect.Message
func (*ClientCred) Reset ¶
func (x *ClientCred) Reset()
func (*ClientCred) String ¶
func (x *ClientCred) String() string
type ClientDel ¶
type ClientDel struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` What ClientDel_What `protobuf:"varint,3,opt,name=what,proto3,enum=pbx.ClientDel_What" json:"what,omitempty"` // Delete messages by id or range of ids DelSeq []*SeqRange `protobuf:"bytes,4,rep,name=del_seq,json=delSeq,proto3" json:"del_seq,omitempty"` // User ID of the subscription to delete UserId string `protobuf:"bytes,5,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // Credential to delete. Cred *ClientCred `protobuf:"bytes,6,opt,name=cred,proto3" json:"cred,omitempty"` // Request to hard-delete messages for all users, if such option is available. Hard bool `protobuf:"varint,7,opt,name=hard,proto3" json:"hard,omitempty"` // contains filtered or unexported fields }
ClientDel delete messages or topic
func (*ClientDel) Descriptor
deprecated
func (*ClientDel) GetCred ¶
func (x *ClientDel) GetCred() *ClientCred
func (*ClientDel) GetWhat ¶
func (x *ClientDel) GetWhat() ClientDel_What
func (*ClientDel) ProtoMessage ¶
func (*ClientDel) ProtoMessage()
func (*ClientDel) ProtoReflect ¶
func (x *ClientDel) ProtoReflect() protoreflect.Message
type ClientDel_What ¶
type ClientDel_What int32
What to delete, either "msg" to delete messages (default) or "topic" to delete the topic or "sub" to delete a subscription to topic.
const ( // Invalid value. The name must be globally unique. ClientDel_X0 ClientDel_What = 0 ClientDel_MSG ClientDel_What = 1 ClientDel_TOPIC ClientDel_What = 2 ClientDel_SUB ClientDel_What = 3 ClientDel_USER ClientDel_What = 4 ClientDel_CRED ClientDel_What = 5 )
func (ClientDel_What) Descriptor ¶
func (ClientDel_What) Descriptor() protoreflect.EnumDescriptor
func (ClientDel_What) Enum ¶
func (x ClientDel_What) Enum() *ClientDel_What
func (ClientDel_What) EnumDescriptor
deprecated
func (ClientDel_What) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientDel_What.Descriptor instead.
func (ClientDel_What) Number ¶
func (x ClientDel_What) Number() protoreflect.EnumNumber
func (ClientDel_What) String ¶
func (x ClientDel_What) String() string
func (ClientDel_What) Type ¶
func (ClientDel_What) Type() protoreflect.EnumType
type ClientExtra ¶
type ClientExtra struct { Attachments []string `protobuf:"bytes,1,rep,name=attachments,proto3" json:"attachments,omitempty"` // Root user may send messages on behalf of other users. OnBehalfOf string `protobuf:"bytes,2,opt,name=on_behalf_of,json=onBehalfOf,proto3" json:"on_behalf_of,omitempty"` AuthLevel AuthLevel `protobuf:"varint,3,opt,name=auth_level,json=authLevel,proto3,enum=pbx.AuthLevel" json:"auth_level,omitempty"` // contains filtered or unexported fields }
func (*ClientExtra) Descriptor
deprecated
func (*ClientExtra) Descriptor() ([]byte, []int)
Deprecated: Use ClientExtra.ProtoReflect.Descriptor instead.
func (*ClientExtra) GetAttachments ¶
func (x *ClientExtra) GetAttachments() []string
func (*ClientExtra) GetAuthLevel ¶
func (x *ClientExtra) GetAuthLevel() AuthLevel
func (*ClientExtra) GetOnBehalfOf ¶
func (x *ClientExtra) GetOnBehalfOf() string
func (*ClientExtra) ProtoMessage ¶
func (*ClientExtra) ProtoMessage()
func (*ClientExtra) ProtoReflect ¶
func (x *ClientExtra) ProtoReflect() protoreflect.Message
func (*ClientExtra) Reset ¶
func (x *ClientExtra) Reset()
func (*ClientExtra) String ¶
func (x *ClientExtra) String() string
type ClientGet ¶
type ClientGet struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Query *GetQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
Query topic state {get}
func (*ClientGet) Descriptor
deprecated
func (*ClientGet) ProtoMessage ¶
func (*ClientGet) ProtoMessage()
func (*ClientGet) ProtoReflect ¶
func (x *ClientGet) ProtoReflect() protoreflect.Message
type ClientHi ¶
type ClientHi struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` UserAgent string `protobuf:"bytes,2,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` Ver string `protobuf:"bytes,3,opt,name=ver,proto3" json:"ver,omitempty"` DeviceId string `protobuf:"bytes,4,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Lang string `protobuf:"bytes,5,opt,name=lang,proto3" json:"lang,omitempty"` Platform string `protobuf:"bytes,6,opt,name=platform,proto3" json:"platform,omitempty"` Background bool `protobuf:"varint,7,opt,name=background,proto3" json:"background,omitempty"` // contains filtered or unexported fields }
Client handshake
func (*ClientHi) Descriptor
deprecated
func (*ClientHi) GetBackground ¶
func (*ClientHi) GetDeviceId ¶
func (*ClientHi) GetPlatform ¶
func (*ClientHi) GetUserAgent ¶
func (*ClientHi) ProtoMessage ¶
func (*ClientHi) ProtoMessage()
func (*ClientHi) ProtoReflect ¶
func (x *ClientHi) ProtoReflect() protoreflect.Message
type ClientLeave ¶
type ClientLeave struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Unsub bool `protobuf:"varint,3,opt,name=unsub,proto3" json:"unsub,omitempty"` // contains filtered or unexported fields }
Unsubscribe {leave} request message
func (*ClientLeave) Descriptor
deprecated
func (*ClientLeave) Descriptor() ([]byte, []int)
Deprecated: Use ClientLeave.ProtoReflect.Descriptor instead.
func (*ClientLeave) GetId ¶
func (x *ClientLeave) GetId() string
func (*ClientLeave) GetTopic ¶
func (x *ClientLeave) GetTopic() string
func (*ClientLeave) GetUnsub ¶
func (x *ClientLeave) GetUnsub() bool
func (*ClientLeave) ProtoMessage ¶
func (*ClientLeave) ProtoMessage()
func (*ClientLeave) ProtoReflect ¶
func (x *ClientLeave) ProtoReflect() protoreflect.Message
func (*ClientLeave) Reset ¶
func (x *ClientLeave) Reset()
func (*ClientLeave) String ¶
func (x *ClientLeave) String() string
type ClientLogin ¶
type ClientLogin struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Authentication scheme Scheme string `protobuf:"bytes,2,opt,name=scheme,proto3" json:"scheme,omitempty"` // Shared secret Secret []byte `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"` // Credentials for verification. Cred []*ClientCred `protobuf:"bytes,4,rep,name=cred,proto3" json:"cred,omitempty"` // contains filtered or unexported fields }
Login {login} message
func (*ClientLogin) Descriptor
deprecated
func (*ClientLogin) Descriptor() ([]byte, []int)
Deprecated: Use ClientLogin.ProtoReflect.Descriptor instead.
func (*ClientLogin) GetCred ¶
func (x *ClientLogin) GetCred() []*ClientCred
func (*ClientLogin) GetId ¶
func (x *ClientLogin) GetId() string
func (*ClientLogin) GetScheme ¶
func (x *ClientLogin) GetScheme() string
func (*ClientLogin) GetSecret ¶
func (x *ClientLogin) GetSecret() []byte
func (*ClientLogin) ProtoMessage ¶
func (*ClientLogin) ProtoMessage()
func (*ClientLogin) ProtoReflect ¶
func (x *ClientLogin) ProtoReflect() protoreflect.Message
func (*ClientLogin) Reset ¶
func (x *ClientLogin) Reset()
func (*ClientLogin) String ¶
func (x *ClientLogin) String() string
type ClientMsg ¶
type ClientMsg struct { // Types that are assignable to Message: // *ClientMsg_Hi // *ClientMsg_Acc // *ClientMsg_Login // *ClientMsg_Sub // *ClientMsg_Leave // *ClientMsg_Pub // *ClientMsg_Get // *ClientMsg_Set // *ClientMsg_Del // *ClientMsg_Note Message isClientMsg_Message `protobuf_oneof:"Message"` // Additional message parameters. Extra *ClientExtra `protobuf:"bytes,13,opt,name=extra,proto3" json:"extra,omitempty"` // contains filtered or unexported fields }
func (*ClientMsg) Descriptor
deprecated
func (*ClientMsg) GetExtra ¶
func (x *ClientMsg) GetExtra() *ClientExtra
func (*ClientMsg) GetLeave ¶
func (x *ClientMsg) GetLeave() *ClientLeave
func (*ClientMsg) GetLogin ¶
func (x *ClientMsg) GetLogin() *ClientLogin
func (*ClientMsg) GetMessage ¶
func (m *ClientMsg) GetMessage() isClientMsg_Message
func (*ClientMsg) GetNote ¶
func (x *ClientMsg) GetNote() *ClientNote
func (*ClientMsg) ProtoMessage ¶
func (*ClientMsg) ProtoMessage()
func (*ClientMsg) ProtoReflect ¶
func (x *ClientMsg) ProtoReflect() protoreflect.Message
type ClientMsg_Acc ¶
type ClientMsg_Acc struct {
Acc *ClientAcc `protobuf:"bytes,2,opt,name=acc,proto3,oneof"`
}
type ClientMsg_Del ¶
type ClientMsg_Del struct {
Del *ClientDel `protobuf:"bytes,9,opt,name=del,proto3,oneof"`
}
type ClientMsg_Get ¶
type ClientMsg_Get struct {
Get *ClientGet `protobuf:"bytes,7,opt,name=get,proto3,oneof"`
}
type ClientMsg_Hi ¶
type ClientMsg_Hi struct {
Hi *ClientHi `protobuf:"bytes,1,opt,name=hi,proto3,oneof"`
}
type ClientMsg_Leave ¶
type ClientMsg_Leave struct {
Leave *ClientLeave `protobuf:"bytes,5,opt,name=leave,proto3,oneof"`
}
type ClientMsg_Login ¶
type ClientMsg_Login struct {
Login *ClientLogin `protobuf:"bytes,3,opt,name=login,proto3,oneof"`
}
type ClientMsg_Note ¶
type ClientMsg_Note struct {
Note *ClientNote `protobuf:"bytes,10,opt,name=note,proto3,oneof"`
}
type ClientMsg_Pub ¶
type ClientMsg_Pub struct {
Pub *ClientPub `protobuf:"bytes,6,opt,name=pub,proto3,oneof"`
}
type ClientMsg_Set ¶
type ClientMsg_Set struct {
Set *ClientSet `protobuf:"bytes,8,opt,name=set,proto3,oneof"`
}
type ClientMsg_Sub ¶
type ClientMsg_Sub struct {
Sub *ClientSub `protobuf:"bytes,4,opt,name=sub,proto3,oneof"`
}
type ClientNote ¶
type ClientNote struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // what is being reported: "recv" - message received, "read" - message read, // "kp" - typing notification, "call" - voice/video call What InfoNote `protobuf:"varint,2,opt,name=what,proto3,enum=pbx.InfoNote" json:"what,omitempty"` // Server-issued message ID being reported SeqId int32 `protobuf:"varint,3,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` // Client's count of unread messages to report back to the server. Used in push notifications on iOS. Unread int32 `protobuf:"varint,4,opt,name=unread,proto3" json:"unread,omitempty"` // Call event. Event CallEvent `protobuf:"varint,5,opt,name=event,proto3,enum=pbx.CallEvent" json:"event,omitempty"` // Arbitrary json payload (used in video calls). Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
ClientNote is a client-generated notification for topic subscribers
func (*ClientNote) Descriptor
deprecated
func (*ClientNote) Descriptor() ([]byte, []int)
Deprecated: Use ClientNote.ProtoReflect.Descriptor instead.
func (*ClientNote) GetEvent ¶
func (x *ClientNote) GetEvent() CallEvent
func (*ClientNote) GetPayload ¶
func (x *ClientNote) GetPayload() []byte
func (*ClientNote) GetSeqId ¶
func (x *ClientNote) GetSeqId() int32
func (*ClientNote) GetTopic ¶
func (x *ClientNote) GetTopic() string
func (*ClientNote) GetUnread ¶
func (x *ClientNote) GetUnread() int32
func (*ClientNote) GetWhat ¶
func (x *ClientNote) GetWhat() InfoNote
func (*ClientNote) ProtoMessage ¶
func (*ClientNote) ProtoMessage()
func (*ClientNote) ProtoReflect ¶
func (x *ClientNote) ProtoReflect() protoreflect.Message
func (*ClientNote) Reset ¶
func (x *ClientNote) Reset()
func (*ClientNote) String ¶
func (x *ClientNote) String() string
type ClientPub ¶
type ClientPub struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` NoEcho bool `protobuf:"varint,3,opt,name=no_echo,json=noEcho,proto3" json:"no_echo,omitempty"` Head map[string][]byte `` /* 149-byte string literal not displayed */ Content []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
ClientPub is client's request to publish data to topic subscribers {pub}
func (*ClientPub) Descriptor
deprecated
func (*ClientPub) GetContent ¶
func (*ClientPub) ProtoMessage ¶
func (*ClientPub) ProtoMessage()
func (*ClientPub) ProtoReflect ¶
func (x *ClientPub) ProtoReflect() protoreflect.Message
type ClientReq ¶
type ClientReq struct { Msg *ClientMsg `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Sess *Session `protobuf:"bytes,2,opt,name=sess,proto3" json:"sess,omitempty"` // contains filtered or unexported fields }
func (*ClientReq) Descriptor
deprecated
func (*ClientReq) ProtoMessage ¶
func (*ClientReq) ProtoMessage()
func (*ClientReq) ProtoReflect ¶
func (x *ClientReq) ProtoReflect() protoreflect.Message
type ClientSet ¶
type ClientSet struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Query *SetQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
Update topic state {set}
func (*ClientSet) Descriptor
deprecated
func (*ClientSet) ProtoMessage ¶
func (*ClientSet) ProtoMessage()
func (*ClientSet) ProtoReflect ¶
func (x *ClientSet) ProtoReflect() protoreflect.Message
type ClientSub ¶
type ClientSub struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` // mirrors {set} SetQuery *SetQuery `protobuf:"bytes,3,opt,name=set_query,json=setQuery,proto3" json:"set_query,omitempty"` // mirrors {get} GetQuery *GetQuery `protobuf:"bytes,4,opt,name=get_query,json=getQuery,proto3" json:"get_query,omitempty"` // contains filtered or unexported fields }
Subscription request {sub} message
func (*ClientSub) Descriptor
deprecated
func (*ClientSub) GetGetQuery ¶
func (*ClientSub) GetSetQuery ¶
func (*ClientSub) ProtoMessage ¶
func (*ClientSub) ProtoMessage()
func (*ClientSub) ProtoReflect ¶
func (x *ClientSub) ProtoReflect() protoreflect.Message
type Crud ¶
type Crud int32
func (Crud) Descriptor ¶
func (Crud) Descriptor() protoreflect.EnumDescriptor
func (Crud) EnumDescriptor
deprecated
func (Crud) Number ¶
func (x Crud) Number() protoreflect.EnumNumber
func (Crud) Type ¶
func (Crud) Type() protoreflect.EnumType
type DefaultAcsMode ¶
type DefaultAcsMode struct { Auth string `protobuf:"bytes,1,opt,name=auth,proto3" json:"auth,omitempty"` Anon string `protobuf:"bytes,2,opt,name=anon,proto3" json:"anon,omitempty"` // contains filtered or unexported fields }
Topic default access mode
func (*DefaultAcsMode) Descriptor
deprecated
func (*DefaultAcsMode) Descriptor() ([]byte, []int)
Deprecated: Use DefaultAcsMode.ProtoReflect.Descriptor instead.
func (*DefaultAcsMode) GetAnon ¶
func (x *DefaultAcsMode) GetAnon() string
func (*DefaultAcsMode) GetAuth ¶
func (x *DefaultAcsMode) GetAuth() string
func (*DefaultAcsMode) ProtoMessage ¶
func (*DefaultAcsMode) ProtoMessage()
func (*DefaultAcsMode) ProtoReflect ¶
func (x *DefaultAcsMode) ProtoReflect() protoreflect.Message
func (*DefaultAcsMode) Reset ¶
func (x *DefaultAcsMode) Reset()
func (*DefaultAcsMode) String ¶
func (x *DefaultAcsMode) String() string
type DelValues ¶
type DelValues struct { DelId int32 `protobuf:"varint,1,opt,name=del_id,json=delId,proto3" json:"del_id,omitempty"` DelSeq []*SeqRange `protobuf:"bytes,2,rep,name=del_seq,json=delSeq,proto3" json:"del_seq,omitempty"` // contains filtered or unexported fields }
func (*DelValues) Descriptor
deprecated
func (*DelValues) ProtoMessage ¶
func (*DelValues) ProtoMessage()
func (*DelValues) ProtoReflect ¶
func (x *DelValues) ProtoReflect() protoreflect.Message
type GetOpts ¶
type GetOpts struct { // Timestamp in milliseconds since epoch 01/01/1970 IfModifiedSince int64 `protobuf:"varint,1,opt,name=if_modified_since,json=ifModifiedSince,proto3" json:"if_modified_since,omitempty"` // Limit search to this user ID User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // Limit search results to one topic; Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` // Load messages with seq id equal or greater than this SinceId int32 `protobuf:"varint,4,opt,name=since_id,json=sinceId,proto3" json:"since_id,omitempty"` // Load messages with seq id lower than this BeforeId int32 `protobuf:"varint,5,opt,name=before_id,json=beforeId,proto3" json:"before_id,omitempty"` // Maximum number of results to return Limit int32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetOpts) Descriptor
deprecated
func (*GetOpts) GetBeforeId ¶
func (*GetOpts) GetIfModifiedSince ¶
func (*GetOpts) GetSinceId ¶
func (*GetOpts) ProtoMessage ¶
func (*GetOpts) ProtoMessage()
func (*GetOpts) ProtoReflect ¶
func (x *GetOpts) ProtoReflect() protoreflect.Message
type GetQuery ¶
type GetQuery struct { What string `protobuf:"bytes,1,opt,name=what,proto3" json:"what,omitempty"` // Parameters of "desc" request Desc *GetOpts `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"` // Parameters of "sub" request Sub *GetOpts `protobuf:"bytes,3,opt,name=sub,proto3" json:"sub,omitempty"` // Parameters of "data" request Data *GetOpts `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GetQuery) Descriptor
deprecated
func (*GetQuery) ProtoMessage ¶
func (*GetQuery) ProtoMessage()
func (*GetQuery) ProtoReflect ¶
func (x *GetQuery) ProtoReflect() protoreflect.Message
type InfoNote ¶
type InfoNote int32
func (InfoNote) Descriptor ¶
func (InfoNote) Descriptor() protoreflect.EnumDescriptor
func (InfoNote) EnumDescriptor
deprecated
func (InfoNote) Number ¶
func (x InfoNote) Number() protoreflect.EnumNumber
func (InfoNote) Type ¶
func (InfoNote) Type() protoreflect.EnumType
type MessageEvent ¶
type MessageEvent struct { Action Crud `protobuf:"varint,1,opt,name=action,proto3,enum=pbx.Crud" json:"action,omitempty"` Msg *ServerData `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*MessageEvent) Descriptor
deprecated
func (*MessageEvent) Descriptor() ([]byte, []int)
Deprecated: Use MessageEvent.ProtoReflect.Descriptor instead.
func (*MessageEvent) GetAction ¶
func (x *MessageEvent) GetAction() Crud
func (*MessageEvent) GetMsg ¶
func (x *MessageEvent) GetMsg() *ServerData
func (*MessageEvent) ProtoMessage ¶
func (*MessageEvent) ProtoMessage()
func (*MessageEvent) ProtoReflect ¶
func (x *MessageEvent) ProtoReflect() protoreflect.Message
func (*MessageEvent) Reset ¶
func (x *MessageEvent) Reset()
func (*MessageEvent) String ¶
func (x *MessageEvent) String() string
type NodeClient ¶
type NodeClient interface { // Client sends a stream of ClientMsg, server responds with a stream of ServerMsg MessageLoop(ctx context.Context, opts ...grpc.CallOption) (Node_MessageLoopClient, error) }
NodeClient is the client API for Node service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewNodeClient ¶
func NewNodeClient(cc grpc.ClientConnInterface) NodeClient
type NodeServer ¶
type NodeServer interface { // Client sends a stream of ClientMsg, server responds with a stream of ServerMsg MessageLoop(Node_MessageLoopServer) error // contains filtered or unexported methods }
NodeServer is the server API for Node service. All implementations must embed UnimplementedNodeServer for forward compatibility
type Node_MessageLoopClient ¶
type Node_MessageLoopServer ¶
type PluginClient ¶
type PluginClient interface { // This plugin method is called by Tinode server for every message received from the clients. The // method returns a ServerCtrl message. Non-zero ServerCtrl.code indicates that no further // processing is needed. The Tinode server will generate a {ctrl} message from the returned ServerCtrl // and forward it to the client session. // ServerCtrl.code equals to 0 instructs the server to continue with default processing of the client message. FireHose(ctx context.Context, in *ClientReq, opts ...grpc.CallOption) (*ServerResp, error) // An alteranative user and topic discovery mechanism. // A search request issued on a 'fnd' topic. This method is called to generate an alternative result set. Find(ctx context.Context, in *SearchQuery, opts ...grpc.CallOption) (*SearchFound, error) // Account created, updated or deleted Account(ctx context.Context, in *AccountEvent, opts ...grpc.CallOption) (*Unused, error) // Topic created, updated [or deleted -- not supported yet] Topic(ctx context.Context, in *TopicEvent, opts ...grpc.CallOption) (*Unused, error) // Subscription created, updated or deleted Subscription(ctx context.Context, in *SubscriptionEvent, opts ...grpc.CallOption) (*Unused, error) // Message published or deleted Message(ctx context.Context, in *MessageEvent, opts ...grpc.CallOption) (*Unused, error) }
PluginClient is the client API for Plugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPluginClient ¶
func NewPluginClient(cc grpc.ClientConnInterface) PluginClient
type PluginServer ¶
type PluginServer interface { // This plugin method is called by Tinode server for every message received from the clients. The // method returns a ServerCtrl message. Non-zero ServerCtrl.code indicates that no further // processing is needed. The Tinode server will generate a {ctrl} message from the returned ServerCtrl // and forward it to the client session. // ServerCtrl.code equals to 0 instructs the server to continue with default processing of the client message. FireHose(context.Context, *ClientReq) (*ServerResp, error) // An alteranative user and topic discovery mechanism. // A search request issued on a 'fnd' topic. This method is called to generate an alternative result set. Find(context.Context, *SearchQuery) (*SearchFound, error) // Account created, updated or deleted Account(context.Context, *AccountEvent) (*Unused, error) // Topic created, updated [or deleted -- not supported yet] Topic(context.Context, *TopicEvent) (*Unused, error) // Subscription created, updated or deleted Subscription(context.Context, *SubscriptionEvent) (*Unused, error) // Message published or deleted Message(context.Context, *MessageEvent) (*Unused, error) // contains filtered or unexported methods }
PluginServer is the server API for Plugin service. All implementations must embed UnimplementedPluginServer for forward compatibility
type RespCode ¶
type RespCode int32
Plugin response codes
const ( // Instruct Tinode server to continue with default processing of the client request. RespCode_CONTINUE RespCode = 0 // Drop the request as if the client did not send it RespCode_DROP RespCode = 1 // Send the the provided response to the client. RespCode_RESPOND RespCode = 2 // Replace client's original request with the provided request then continue with // processing. RespCode_REPLACE RespCode = 3 )
func (RespCode) Descriptor ¶
func (RespCode) Descriptor() protoreflect.EnumDescriptor
func (RespCode) EnumDescriptor
deprecated
func (RespCode) Number ¶
func (x RespCode) Number() protoreflect.EnumNumber
func (RespCode) Type ¶
func (RespCode) Type() protoreflect.EnumType
type SearchFound ¶
type SearchFound struct { Status RespCode `protobuf:"varint,1,opt,name=status,proto3,enum=pbx.RespCode" json:"status,omitempty"` // New search query If status == REPLACE, otherwise unset. Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // Search results. Result []*TopicSub `protobuf:"bytes,3,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*SearchFound) Descriptor
deprecated
func (*SearchFound) Descriptor() ([]byte, []int)
Deprecated: Use SearchFound.ProtoReflect.Descriptor instead.
func (*SearchFound) GetQuery ¶
func (x *SearchFound) GetQuery() string
func (*SearchFound) GetResult ¶
func (x *SearchFound) GetResult() []*TopicSub
func (*SearchFound) GetStatus ¶
func (x *SearchFound) GetStatus() RespCode
func (*SearchFound) ProtoMessage ¶
func (*SearchFound) ProtoMessage()
func (*SearchFound) ProtoReflect ¶
func (x *SearchFound) ProtoReflect() protoreflect.Message
func (*SearchFound) Reset ¶
func (x *SearchFound) Reset()
func (*SearchFound) String ¶
func (x *SearchFound) String() string
type SearchQuery ¶
type SearchQuery struct { UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*SearchQuery) Descriptor
deprecated
func (*SearchQuery) Descriptor() ([]byte, []int)
Deprecated: Use SearchQuery.ProtoReflect.Descriptor instead.
func (*SearchQuery) GetQuery ¶
func (x *SearchQuery) GetQuery() string
func (*SearchQuery) GetUserId ¶
func (x *SearchQuery) GetUserId() string
func (*SearchQuery) ProtoMessage ¶
func (*SearchQuery) ProtoMessage()
func (*SearchQuery) ProtoReflect ¶
func (x *SearchQuery) ProtoReflect() protoreflect.Message
func (*SearchQuery) Reset ¶
func (x *SearchQuery) Reset()
func (*SearchQuery) String ¶
func (x *SearchQuery) String() string
type SeqRange ¶
type SeqRange struct { Low int32 `protobuf:"varint,1,opt,name=low,proto3" json:"low,omitempty"` Hi int32 `protobuf:"varint,2,opt,name=hi,proto3" json:"hi,omitempty"` // contains filtered or unexported fields }
func (*SeqRange) Descriptor
deprecated
func (*SeqRange) ProtoMessage ¶
func (*SeqRange) ProtoMessage()
func (*SeqRange) ProtoReflect ¶
func (x *SeqRange) ProtoReflect() protoreflect.Message
type ServerCred ¶
type ServerCred struct { // Credential type, i.e. `email` or `tel`. Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // Value to verify, i.e. `user@example.com` or `+18003287448` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Indicator that the credential is validated Done bool `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"` // contains filtered or unexported fields }
Credentials
func (*ServerCred) Descriptor
deprecated
func (*ServerCred) Descriptor() ([]byte, []int)
Deprecated: Use ServerCred.ProtoReflect.Descriptor instead.
func (*ServerCred) GetDone ¶
func (x *ServerCred) GetDone() bool
func (*ServerCred) GetMethod ¶
func (x *ServerCred) GetMethod() string
func (*ServerCred) GetValue ¶
func (x *ServerCred) GetValue() string
func (*ServerCred) ProtoMessage ¶
func (*ServerCred) ProtoMessage()
func (*ServerCred) ProtoReflect ¶
func (x *ServerCred) ProtoReflect() protoreflect.Message
func (*ServerCred) Reset ¶
func (x *ServerCred) Reset()
func (*ServerCred) String ¶
func (x *ServerCred) String() string
type ServerCtrl ¶
type ServerCtrl struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Code int32 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"` Text string `protobuf:"bytes,4,opt,name=text,proto3" json:"text,omitempty"` Params map[string][]byte `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
{ctrl} message
func (*ServerCtrl) Descriptor
deprecated
func (*ServerCtrl) Descriptor() ([]byte, []int)
Deprecated: Use ServerCtrl.ProtoReflect.Descriptor instead.
func (*ServerCtrl) GetCode ¶
func (x *ServerCtrl) GetCode() int32
func (*ServerCtrl) GetId ¶
func (x *ServerCtrl) GetId() string
func (*ServerCtrl) GetParams ¶
func (x *ServerCtrl) GetParams() map[string][]byte
func (*ServerCtrl) GetText ¶
func (x *ServerCtrl) GetText() string
func (*ServerCtrl) GetTopic ¶
func (x *ServerCtrl) GetTopic() string
func (*ServerCtrl) ProtoMessage ¶
func (*ServerCtrl) ProtoMessage()
func (*ServerCtrl) ProtoReflect ¶
func (x *ServerCtrl) ProtoReflect() protoreflect.Message
func (*ServerCtrl) Reset ¶
func (x *ServerCtrl) Reset()
func (*ServerCtrl) String ¶
func (x *ServerCtrl) String() string
type ServerData ¶
type ServerData struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // ID of the user who originated the message as {pub}, could be empty if sent by the system FromUserId string `protobuf:"bytes,2,opt,name=from_user_id,json=fromUserId,proto3" json:"from_user_id,omitempty"` // Timestamp when the message was sent. Timestamp int64 `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Timestamp when the message was deleted or 0. Milliseconds since the epoch 01/01/1970 DeletedAt int64 `protobuf:"varint,3,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"` SeqId int32 `protobuf:"varint,4,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` Head map[string][]byte `` /* 149-byte string literal not displayed */ Content []byte `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
{data} message
func (*ServerData) Descriptor
deprecated
func (*ServerData) Descriptor() ([]byte, []int)
Deprecated: Use ServerData.ProtoReflect.Descriptor instead.
func (*ServerData) GetContent ¶
func (x *ServerData) GetContent() []byte
func (*ServerData) GetDeletedAt ¶
func (x *ServerData) GetDeletedAt() int64
func (*ServerData) GetFromUserId ¶
func (x *ServerData) GetFromUserId() string
func (*ServerData) GetHead ¶
func (x *ServerData) GetHead() map[string][]byte
func (*ServerData) GetSeqId ¶
func (x *ServerData) GetSeqId() int32
func (*ServerData) GetTimestamp ¶
func (x *ServerData) GetTimestamp() int64
func (*ServerData) GetTopic ¶
func (x *ServerData) GetTopic() string
func (*ServerData) ProtoMessage ¶
func (*ServerData) ProtoMessage()
func (*ServerData) ProtoReflect ¶
func (x *ServerData) ProtoReflect() protoreflect.Message
func (*ServerData) Reset ¶
func (x *ServerData) Reset()
func (*ServerData) String ¶
func (x *ServerData) String() string
type ServerInfo ¶
type ServerInfo struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` FromUserId string `protobuf:"bytes,2,opt,name=from_user_id,json=fromUserId,proto3" json:"from_user_id,omitempty"` What InfoNote `protobuf:"varint,3,opt,name=what,proto3,enum=pbx.InfoNote" json:"what,omitempty"` SeqId int32 `protobuf:"varint,4,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` Src string `protobuf:"bytes,5,opt,name=src,proto3" json:"src,omitempty"` Event CallEvent `protobuf:"varint,6,opt,name=event,proto3,enum=pbx.CallEvent" json:"event,omitempty"` Payload []byte `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
{info} message: server-side copy of ClientNote with From and optional Src added.
func (*ServerInfo) Descriptor
deprecated
func (*ServerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.
func (*ServerInfo) GetEvent ¶
func (x *ServerInfo) GetEvent() CallEvent
func (*ServerInfo) GetFromUserId ¶
func (x *ServerInfo) GetFromUserId() string
func (*ServerInfo) GetPayload ¶
func (x *ServerInfo) GetPayload() []byte
func (*ServerInfo) GetSeqId ¶
func (x *ServerInfo) GetSeqId() int32
func (*ServerInfo) GetSrc ¶
func (x *ServerInfo) GetSrc() string
func (*ServerInfo) GetTopic ¶
func (x *ServerInfo) GetTopic() string
func (*ServerInfo) GetWhat ¶
func (x *ServerInfo) GetWhat() InfoNote
func (*ServerInfo) ProtoMessage ¶
func (*ServerInfo) ProtoMessage()
func (*ServerInfo) ProtoReflect ¶
func (x *ServerInfo) ProtoReflect() protoreflect.Message
func (*ServerInfo) Reset ¶
func (x *ServerInfo) Reset()
func (*ServerInfo) String ¶
func (x *ServerInfo) String() string
type ServerMeta ¶
type ServerMeta struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Desc *TopicDesc `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"` Sub []*TopicSub `protobuf:"bytes,4,rep,name=sub,proto3" json:"sub,omitempty"` Del *DelValues `protobuf:"bytes,5,opt,name=del,proto3" json:"del,omitempty"` Tags []string `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"` Cred []*ServerCred `protobuf:"bytes,7,rep,name=cred,proto3" json:"cred,omitempty"` // contains filtered or unexported fields }
{meta} message
func (*ServerMeta) Descriptor
deprecated
func (*ServerMeta) Descriptor() ([]byte, []int)
Deprecated: Use ServerMeta.ProtoReflect.Descriptor instead.
func (*ServerMeta) GetCred ¶
func (x *ServerMeta) GetCred() []*ServerCred
func (*ServerMeta) GetDel ¶
func (x *ServerMeta) GetDel() *DelValues
func (*ServerMeta) GetDesc ¶
func (x *ServerMeta) GetDesc() *TopicDesc
func (*ServerMeta) GetId ¶
func (x *ServerMeta) GetId() string
func (*ServerMeta) GetSub ¶
func (x *ServerMeta) GetSub() []*TopicSub
func (*ServerMeta) GetTags ¶
func (x *ServerMeta) GetTags() []string
func (*ServerMeta) GetTopic ¶
func (x *ServerMeta) GetTopic() string
func (*ServerMeta) ProtoMessage ¶
func (*ServerMeta) ProtoMessage()
func (*ServerMeta) ProtoReflect ¶
func (x *ServerMeta) ProtoReflect() protoreflect.Message
func (*ServerMeta) Reset ¶
func (x *ServerMeta) Reset()
func (*ServerMeta) String ¶
func (x *ServerMeta) String() string
type ServerMsg ¶
type ServerMsg struct { // Types that are assignable to Message: // *ServerMsg_Ctrl // *ServerMsg_Data // *ServerMsg_Pres // *ServerMsg_Meta // *ServerMsg_Info Message isServerMsg_Message `protobuf_oneof:"Message"` // When response is sent to Root, send internal topic name too. Topic string `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
Cumulative message
func (*ServerMsg) Descriptor
deprecated
func (*ServerMsg) GetCtrl ¶
func (x *ServerMsg) GetCtrl() *ServerCtrl
func (*ServerMsg) GetData ¶
func (x *ServerMsg) GetData() *ServerData
func (*ServerMsg) GetInfo ¶
func (x *ServerMsg) GetInfo() *ServerInfo
func (*ServerMsg) GetMessage ¶
func (m *ServerMsg) GetMessage() isServerMsg_Message
func (*ServerMsg) GetMeta ¶
func (x *ServerMsg) GetMeta() *ServerMeta
func (*ServerMsg) GetPres ¶
func (x *ServerMsg) GetPres() *ServerPres
func (*ServerMsg) ProtoMessage ¶
func (*ServerMsg) ProtoMessage()
func (*ServerMsg) ProtoReflect ¶
func (x *ServerMsg) ProtoReflect() protoreflect.Message
type ServerMsg_Ctrl ¶
type ServerMsg_Ctrl struct {
Ctrl *ServerCtrl `protobuf:"bytes,1,opt,name=ctrl,proto3,oneof"`
}
type ServerMsg_Data ¶
type ServerMsg_Data struct {
Data *ServerData `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type ServerMsg_Info ¶
type ServerMsg_Info struct {
Info *ServerInfo `protobuf:"bytes,5,opt,name=info,proto3,oneof"`
}
type ServerMsg_Meta ¶
type ServerMsg_Meta struct {
Meta *ServerMeta `protobuf:"bytes,4,opt,name=meta,proto3,oneof"`
}
type ServerMsg_Pres ¶
type ServerMsg_Pres struct {
Pres *ServerPres `protobuf:"bytes,3,opt,name=pres,proto3,oneof"`
}
type ServerPres ¶
type ServerPres struct { Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` Src string `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"` What ServerPres_What `protobuf:"varint,3,opt,name=what,proto3,enum=pbx.ServerPres_What" json:"what,omitempty"` UserAgent string `protobuf:"bytes,4,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` SeqId int32 `protobuf:"varint,5,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` DelId int32 `protobuf:"varint,6,opt,name=del_id,json=delId,proto3" json:"del_id,omitempty"` DelSeq []*SeqRange `protobuf:"bytes,7,rep,name=del_seq,json=delSeq,proto3" json:"del_seq,omitempty"` TargetUserId string `protobuf:"bytes,8,opt,name=target_user_id,json=targetUserId,proto3" json:"target_user_id,omitempty"` ActorUserId string `protobuf:"bytes,9,opt,name=actor_user_id,json=actorUserId,proto3" json:"actor_user_id,omitempty"` Acs *AccessMode `protobuf:"bytes,10,opt,name=acs,proto3" json:"acs,omitempty"` // contains filtered or unexported fields }
{pres} message
func (*ServerPres) Descriptor
deprecated
func (*ServerPres) Descriptor() ([]byte, []int)
Deprecated: Use ServerPres.ProtoReflect.Descriptor instead.
func (*ServerPres) GetAcs ¶
func (x *ServerPres) GetAcs() *AccessMode
func (*ServerPres) GetActorUserId ¶
func (x *ServerPres) GetActorUserId() string
func (*ServerPres) GetDelId ¶
func (x *ServerPres) GetDelId() int32
func (*ServerPres) GetDelSeq ¶
func (x *ServerPres) GetDelSeq() []*SeqRange
func (*ServerPres) GetSeqId ¶
func (x *ServerPres) GetSeqId() int32
func (*ServerPres) GetSrc ¶
func (x *ServerPres) GetSrc() string
func (*ServerPres) GetTargetUserId ¶
func (x *ServerPres) GetTargetUserId() string
func (*ServerPres) GetTopic ¶
func (x *ServerPres) GetTopic() string
func (*ServerPres) GetUserAgent ¶
func (x *ServerPres) GetUserAgent() string
func (*ServerPres) GetWhat ¶
func (x *ServerPres) GetWhat() ServerPres_What
func (*ServerPres) ProtoMessage ¶
func (*ServerPres) ProtoMessage()
func (*ServerPres) ProtoReflect ¶
func (x *ServerPres) ProtoReflect() protoreflect.Message
func (*ServerPres) Reset ¶
func (x *ServerPres) Reset()
func (*ServerPres) String ¶
func (x *ServerPres) String() string
type ServerPres_What ¶
type ServerPres_What int32
const ( // Invalid value. The name must be globally unique. ServerPres_X3 ServerPres_What = 0 ServerPres_ON ServerPres_What = 1 ServerPres_OFF ServerPres_What = 2 ServerPres_UA ServerPres_What = 3 ServerPres_UPD ServerPres_What = 4 ServerPres_GONE ServerPres_What = 5 ServerPres_ACS ServerPres_What = 6 ServerPres_TERM ServerPres_What = 7 ServerPres_MSG ServerPres_What = 8 ServerPres_READ ServerPres_What = 9 ServerPres_RECV ServerPres_What = 10 ServerPres_DEL ServerPres_What = 11 ServerPres_TAGS ServerPres_What = 12 )
func (ServerPres_What) Descriptor ¶
func (ServerPres_What) Descriptor() protoreflect.EnumDescriptor
func (ServerPres_What) Enum ¶
func (x ServerPres_What) Enum() *ServerPres_What
func (ServerPres_What) EnumDescriptor
deprecated
func (ServerPres_What) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServerPres_What.Descriptor instead.
func (ServerPres_What) Number ¶
func (x ServerPres_What) Number() protoreflect.EnumNumber
func (ServerPres_What) String ¶
func (x ServerPres_What) String() string
func (ServerPres_What) Type ¶
func (ServerPres_What) Type() protoreflect.EnumType
type ServerResp ¶
type ServerResp struct { Status RespCode `protobuf:"varint,1,opt,name=status,proto3,enum=pbx.RespCode" json:"status,omitempty"` Srvmsg *ServerMsg `protobuf:"bytes,2,opt,name=srvmsg,proto3" json:"srvmsg,omitempty"` Clmsg *ClientMsg `protobuf:"bytes,3,opt,name=clmsg,proto3" json:"clmsg,omitempty"` // contains filtered or unexported fields }
func (*ServerResp) Descriptor
deprecated
func (*ServerResp) Descriptor() ([]byte, []int)
Deprecated: Use ServerResp.ProtoReflect.Descriptor instead.
func (*ServerResp) GetClmsg ¶
func (x *ServerResp) GetClmsg() *ClientMsg
func (*ServerResp) GetSrvmsg ¶
func (x *ServerResp) GetSrvmsg() *ServerMsg
func (*ServerResp) GetStatus ¶
func (x *ServerResp) GetStatus() RespCode
func (*ServerResp) ProtoMessage ¶
func (*ServerResp) ProtoMessage()
func (*ServerResp) ProtoReflect ¶
func (x *ServerResp) ProtoReflect() protoreflect.Message
func (*ServerResp) Reset ¶
func (x *ServerResp) Reset()
func (*ServerResp) String ¶
func (x *ServerResp) String() string
type Session ¶
type Session struct { SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` AuthLevel AuthLevel `protobuf:"varint,3,opt,name=auth_level,json=authLevel,proto3,enum=pbx.AuthLevel" json:"auth_level,omitempty"` RemoteAddr string `protobuf:"bytes,4,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"` UserAgent string `protobuf:"bytes,5,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` DeviceId string `protobuf:"bytes,6,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Language string `protobuf:"bytes,7,opt,name=language,proto3" json:"language,omitempty"` // contains filtered or unexported fields }
Context message
func (*Session) Descriptor
deprecated
func (*Session) GetAuthLevel ¶
func (*Session) GetDeviceId ¶
func (*Session) GetLanguage ¶
func (*Session) GetRemoteAddr ¶
func (*Session) GetSessionId ¶
func (*Session) GetUserAgent ¶
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type SetDesc ¶
type SetDesc struct { DefaultAcs *DefaultAcsMode `protobuf:"bytes,1,opt,name=default_acs,json=defaultAcs,proto3" json:"default_acs,omitempty"` Public []byte `protobuf:"bytes,2,opt,name=public,proto3" json:"public,omitempty"` Private []byte `protobuf:"bytes,3,opt,name=private,proto3" json:"private,omitempty"` Trusted []byte `protobuf:"bytes,4,opt,name=trusted,proto3" json:"trusted,omitempty"` // contains filtered or unexported fields }
SetDesc: C2S in set.what == "desc" and sub.init message
func (*SetDesc) Descriptor
deprecated
func (*SetDesc) GetDefaultAcs ¶
func (x *SetDesc) GetDefaultAcs() *DefaultAcsMode
func (*SetDesc) GetPrivate ¶
func (*SetDesc) GetTrusted ¶
func (*SetDesc) ProtoMessage ¶
func (*SetDesc) ProtoMessage()
func (*SetDesc) ProtoReflect ¶
func (x *SetDesc) ProtoReflect() protoreflect.Message
type SetQuery ¶
type SetQuery struct { // Topic metadata, new topic & new subscriptions only Desc *SetDesc `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"` // Subscription parameters Sub *SetSub `protobuf:"bytes,2,opt,name=sub,proto3" json:"sub,omitempty"` // Indexable tags Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // Credential being updated. Cred *ClientCred `protobuf:"bytes,4,opt,name=cred,proto3" json:"cred,omitempty"` // contains filtered or unexported fields }
func (*SetQuery) Descriptor
deprecated
func (*SetQuery) GetCred ¶
func (x *SetQuery) GetCred() *ClientCred
func (*SetQuery) ProtoMessage ¶
func (*SetQuery) ProtoMessage()
func (*SetQuery) ProtoReflect ¶
func (x *SetQuery) ProtoReflect() protoreflect.Message
type SetSub ¶
type SetSub struct { // User affected by this request. Default (empty): current user UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // Access mode change, either Given or Want depending on context Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"` // contains filtered or unexported fields }
SetSub: payload in set.sub request to update current subscription or invite another user, {sub.what} == "sub"
func (*SetSub) Descriptor
deprecated
func (*SetSub) ProtoMessage ¶
func (*SetSub) ProtoMessage()
func (*SetSub) ProtoReflect ¶
func (x *SetSub) ProtoReflect() protoreflect.Message
type SubscriptionEvent ¶
type SubscriptionEvent struct { Action Crud `protobuf:"varint,1,opt,name=action,proto3,enum=pbx.Crud" json:"action,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` DelId int32 `protobuf:"varint,4,opt,name=del_id,json=delId,proto3" json:"del_id,omitempty"` ReadId int32 `protobuf:"varint,5,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"` RecvId int32 `protobuf:"varint,6,opt,name=recv_id,json=recvId,proto3" json:"recv_id,omitempty"` Mode *AccessMode `protobuf:"bytes,7,opt,name=mode,proto3" json:"mode,omitempty"` Private []byte `protobuf:"bytes,8,opt,name=private,proto3" json:"private,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionEvent) Descriptor
deprecated
func (*SubscriptionEvent) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionEvent.ProtoReflect.Descriptor instead.
func (*SubscriptionEvent) GetAction ¶
func (x *SubscriptionEvent) GetAction() Crud
func (*SubscriptionEvent) GetDelId ¶
func (x *SubscriptionEvent) GetDelId() int32
func (*SubscriptionEvent) GetMode ¶
func (x *SubscriptionEvent) GetMode() *AccessMode
func (*SubscriptionEvent) GetPrivate ¶
func (x *SubscriptionEvent) GetPrivate() []byte
func (*SubscriptionEvent) GetReadId ¶
func (x *SubscriptionEvent) GetReadId() int32
func (*SubscriptionEvent) GetRecvId ¶
func (x *SubscriptionEvent) GetRecvId() int32
func (*SubscriptionEvent) GetTopic ¶
func (x *SubscriptionEvent) GetTopic() string
func (*SubscriptionEvent) GetUserId ¶
func (x *SubscriptionEvent) GetUserId() string
func (*SubscriptionEvent) ProtoMessage ¶
func (*SubscriptionEvent) ProtoMessage()
func (*SubscriptionEvent) ProtoReflect ¶
func (x *SubscriptionEvent) ProtoReflect() protoreflect.Message
func (*SubscriptionEvent) Reset ¶
func (x *SubscriptionEvent) Reset()
func (*SubscriptionEvent) String ¶
func (x *SubscriptionEvent) String() string
type TopicDesc ¶
type TopicDesc struct { CreatedAt int64 `protobuf:"varint,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt int64 `protobuf:"varint,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` TouchedAt int64 `protobuf:"varint,3,opt,name=touched_at,json=touchedAt,proto3" json:"touched_at,omitempty"` Defacs *DefaultAcsMode `protobuf:"bytes,4,opt,name=defacs,proto3" json:"defacs,omitempty"` Acs *AccessMode `protobuf:"bytes,5,opt,name=acs,proto3" json:"acs,omitempty"` SeqId int32 `protobuf:"varint,6,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` ReadId int32 `protobuf:"varint,7,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"` RecvId int32 `protobuf:"varint,8,opt,name=recv_id,json=recvId,proto3" json:"recv_id,omitempty"` DelId int32 `protobuf:"varint,9,opt,name=del_id,json=delId,proto3" json:"del_id,omitempty"` Public []byte `protobuf:"bytes,10,opt,name=public,proto3" json:"public,omitempty"` Private []byte `protobuf:"bytes,11,opt,name=private,proto3" json:"private,omitempty"` State string `protobuf:"bytes,12,opt,name=state,proto3" json:"state,omitempty"` StateAt int64 `protobuf:"varint,13,opt,name=state_at,json=stateAt,proto3" json:"state_at,omitempty"` Trusted []byte `protobuf:"bytes,14,opt,name=trusted,proto3" json:"trusted,omitempty"` IsChan bool `protobuf:"varint,17,opt,name=is_chan,json=isChan,proto3" json:"is_chan,omitempty"` // 17! // P2P only: other user's last online timestamp & user agent LastSeenTime int64 `protobuf:"varint,15,opt,name=last_seen_time,json=lastSeenTime,proto3" json:"last_seen_time,omitempty"` LastSeenUserAgent string `protobuf:"bytes,16,opt,name=last_seen_user_agent,json=lastSeenUserAgent,proto3" json:"last_seen_user_agent,omitempty"` // contains filtered or unexported fields }
Topic description, S2C in Meta message
func (*TopicDesc) Descriptor
deprecated
func (*TopicDesc) GetAcs ¶
func (x *TopicDesc) GetAcs() *AccessMode
func (*TopicDesc) GetCreatedAt ¶
func (*TopicDesc) GetDefacs ¶
func (x *TopicDesc) GetDefacs() *DefaultAcsMode
func (*TopicDesc) GetLastSeenTime ¶
func (*TopicDesc) GetLastSeenUserAgent ¶
func (*TopicDesc) GetPrivate ¶
func (*TopicDesc) GetStateAt ¶
func (*TopicDesc) GetTouchedAt ¶
func (*TopicDesc) GetTrusted ¶
func (*TopicDesc) GetUpdatedAt ¶
func (*TopicDesc) ProtoMessage ¶
func (*TopicDesc) ProtoMessage()
func (*TopicDesc) ProtoReflect ¶
func (x *TopicDesc) ProtoReflect() protoreflect.Message
type TopicEvent ¶
type TopicEvent struct { Action Crud `protobuf:"varint,1,opt,name=action,proto3,enum=pbx.Crud" json:"action,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Desc *TopicDesc `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"` // contains filtered or unexported fields }
func (*TopicEvent) Descriptor
deprecated
func (*TopicEvent) Descriptor() ([]byte, []int)
Deprecated: Use TopicEvent.ProtoReflect.Descriptor instead.
func (*TopicEvent) GetAction ¶
func (x *TopicEvent) GetAction() Crud
func (*TopicEvent) GetDesc ¶
func (x *TopicEvent) GetDesc() *TopicDesc
func (*TopicEvent) GetName ¶
func (x *TopicEvent) GetName() string
func (*TopicEvent) ProtoMessage ¶
func (*TopicEvent) ProtoMessage()
func (*TopicEvent) ProtoReflect ¶
func (x *TopicEvent) ProtoReflect() protoreflect.Message
func (*TopicEvent) Reset ¶
func (x *TopicEvent) Reset()
func (*TopicEvent) String ¶
func (x *TopicEvent) String() string
type TopicSub ¶
type TopicSub struct { UpdatedAt int64 `protobuf:"varint,1,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` DeletedAt int64 `protobuf:"varint,2,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"` Online bool `protobuf:"varint,3,opt,name=online,proto3" json:"online,omitempty"` Acs *AccessMode `protobuf:"bytes,4,opt,name=acs,proto3" json:"acs,omitempty"` ReadId int32 `protobuf:"varint,5,opt,name=read_id,json=readId,proto3" json:"read_id,omitempty"` RecvId int32 `protobuf:"varint,6,opt,name=recv_id,json=recvId,proto3" json:"recv_id,omitempty"` Public []byte `protobuf:"bytes,7,opt,name=public,proto3" json:"public,omitempty"` Trusted []byte `protobuf:"bytes,16,opt,name=trusted,proto3" json:"trusted,omitempty"` // 16! Private []byte `protobuf:"bytes,8,opt,name=private,proto3" json:"private,omitempty"` // Uid of the subscribed user UserId string `protobuf:"bytes,9,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // Topic name of this subscription Topic string `protobuf:"bytes,10,opt,name=topic,proto3" json:"topic,omitempty"` TouchedAt int64 `protobuf:"varint,11,opt,name=touched_at,json=touchedAt,proto3" json:"touched_at,omitempty"` // ID of the last {data} message in a topic SeqId int32 `protobuf:"varint,12,opt,name=seq_id,json=seqId,proto3" json:"seq_id,omitempty"` // Messages are deleted up to this ID DelId int32 `protobuf:"varint,13,opt,name=del_id,json=delId,proto3" json:"del_id,omitempty"` // Other user's last online timestamp & user agent LastSeenTime int64 `protobuf:"varint,14,opt,name=last_seen_time,json=lastSeenTime,proto3" json:"last_seen_time,omitempty"` LastSeenUserAgent string `protobuf:"bytes,15,opt,name=last_seen_user_agent,json=lastSeenUserAgent,proto3" json:"last_seen_user_agent,omitempty"` // contains filtered or unexported fields }
MsgTopicSub: topic subscription details, sent in Meta message
func (*TopicSub) Descriptor
deprecated
func (*TopicSub) GetAcs ¶
func (x *TopicSub) GetAcs() *AccessMode
func (*TopicSub) GetDeletedAt ¶
func (*TopicSub) GetLastSeenTime ¶
func (*TopicSub) GetLastSeenUserAgent ¶
func (*TopicSub) GetPrivate ¶
func (*TopicSub) GetTouchedAt ¶
func (*TopicSub) GetTrusted ¶
func (*TopicSub) GetUpdatedAt ¶
func (*TopicSub) ProtoMessage ¶
func (*TopicSub) ProtoMessage()
func (*TopicSub) ProtoReflect ¶
func (x *TopicSub) ProtoReflect() protoreflect.Message
type UnimplementedNodeServer ¶
type UnimplementedNodeServer struct { }
UnimplementedNodeServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeServer) MessageLoop ¶
func (UnimplementedNodeServer) MessageLoop(Node_MessageLoopServer) error
type UnimplementedPluginServer ¶
type UnimplementedPluginServer struct { }
UnimplementedPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedPluginServer) Account ¶
func (UnimplementedPluginServer) Account(context.Context, *AccountEvent) (*Unused, error)
func (UnimplementedPluginServer) Find ¶
func (UnimplementedPluginServer) Find(context.Context, *SearchQuery) (*SearchFound, error)
func (UnimplementedPluginServer) FireHose ¶
func (UnimplementedPluginServer) FireHose(context.Context, *ClientReq) (*ServerResp, error)
func (UnimplementedPluginServer) Message ¶
func (UnimplementedPluginServer) Message(context.Context, *MessageEvent) (*Unused, error)
func (UnimplementedPluginServer) Subscription ¶
func (UnimplementedPluginServer) Subscription(context.Context, *SubscriptionEvent) (*Unused, error)
func (UnimplementedPluginServer) Topic ¶
func (UnimplementedPluginServer) Topic(context.Context, *TopicEvent) (*Unused, error)
type UnsafeNodeServer ¶
type UnsafeNodeServer interface {
// contains filtered or unexported methods
}
UnsafeNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServer will result in compilation errors.
type UnsafePluginServer ¶
type UnsafePluginServer interface {
// contains filtered or unexported methods
}
UnsafePluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServer will result in compilation errors.
type Unused ¶
type Unused struct {
// contains filtered or unexported fields
}
Dummy placeholder message.
func (*Unused) Descriptor
deprecated
func (*Unused) ProtoMessage ¶
func (*Unused) ProtoMessage()
func (*Unused) ProtoReflect ¶
func (x *Unused) ProtoReflect() protoreflect.Message