chat: github.com/tinode/chat/pbx Index | Files

package pbx

import "github.com/tinode/chat/pbx"

Index

Package Files

model.pb.go

Variables

var AuthLevel_name = map[int32]string{
    0:  "NONE",
    10: "ANON",
    20: "AUTH",
    30: "ROOT",
}
var AuthLevel_value = map[string]int32{
    "NONE": 0,
    "ANON": 10,
    "AUTH": 20,
    "ROOT": 30,
}
var ClientDel_What_name = map[int32]string{
    0:  "MSG",
    1:  "TOPIC",
    2:  "SUB",
    3:  "USER",
    4:  "CRED",
}
var ClientDel_What_value = map[string]int32{
    "MSG":   0,
    "TOPIC": 1,
    "SUB":   2,
    "USER":  3,
    "CRED":  4,
}
var Crud_name = map[int32]string{
    0:  "CREATE",
    1:  "UPDATE",
    2:  "DELETE",
}
var Crud_value = map[string]int32{
    "CREATE": 0,
    "UPDATE": 1,
    "DELETE": 2,
}
var InfoNote_name = map[int32]string{
    0:  "READ",
    1:  "RECV",
    2:  "KP",
}
var InfoNote_value = map[string]int32{
    "READ": 0,
    "RECV": 1,
    "KP":   2,
}
var RespCode_name = map[int32]string{
    0:  "CONTINUE",
    1:  "DROP",
    2:  "RESPOND",
    3:  "REPLACE",
}
var RespCode_value = map[string]int32{
    "CONTINUE": 0,
    "DROP":     1,
    "RESPOND":  2,
    "REPLACE":  3,
}
var ServerPres_What_name = map[int32]string{
    0:  "ON",
    1:  "OFF",
    3:  "UA",
    4:  "UPD",
    5:  "GONE",
    6:  "ACS",
    7:  "TERM",
    8:  "MSG",
    9:  "READ",
    10: "RECV",
    11: "DEL",
    12: "TAGS",
}
var ServerPres_What_value = map[string]int32{
    "ON":   0,
    "OFF":  1,
    "UA":   3,
    "UPD":  4,
    "GONE": 5,
    "ACS":  6,
    "TERM": 7,
    "MSG":  8,
    "READ": 9,
    "RECV": 10,
    "DEL":  11,
    "TAGS": 12,
}

func RegisterNodeServer Uses

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

func RegisterPluginServer Uses

func RegisterPluginServer(s *grpc.Server, srv PluginServer)

type AccessMode Uses

type AccessMode struct {
    // Access mode requested by the user
    Want string `protobuf:"bytes,1,opt,name=want" json:"want,omitempty"`
    // Access mode granted to the user by the admin
    Given                string   `protobuf:"bytes,2,opt,name=given" json:"given,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Actual access mode

func (*AccessMode) Descriptor Uses

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

func (*AccessMode) GetGiven Uses

func (m *AccessMode) GetGiven() string

func (*AccessMode) GetWant Uses

func (m *AccessMode) GetWant() string

func (*AccessMode) ProtoMessage Uses

func (*AccessMode) ProtoMessage()

func (*AccessMode) Reset Uses

func (m *AccessMode) Reset()

func (*AccessMode) String Uses

func (m *AccessMode) String() string

func (*AccessMode) XXX_DiscardUnknown Uses

func (m *AccessMode) XXX_DiscardUnknown()

func (*AccessMode) XXX_Marshal Uses

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

func (*AccessMode) XXX_Merge Uses

func (dst *AccessMode) XXX_Merge(src proto.Message)

func (*AccessMode) XXX_Size Uses

func (m *AccessMode) XXX_Size() int

func (*AccessMode) XXX_Unmarshal Uses

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

type AccountEvent Uses

type AccountEvent struct {
    Action     Crud            `protobuf:"varint,1,opt,name=action,enum=pbx.Crud" json:"action,omitempty"`
    UserId     string          `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    DefaultAcs *DefaultAcsMode `protobuf:"bytes,3,opt,name=default_acs,json=defaultAcs" 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" json:"tags,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*AccountEvent) Descriptor Uses

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

func (*AccountEvent) GetAction Uses

func (m *AccountEvent) GetAction() Crud

func (*AccountEvent) GetDefaultAcs Uses

func (m *AccountEvent) GetDefaultAcs() *DefaultAcsMode

func (*AccountEvent) GetPublic Uses

func (m *AccountEvent) GetPublic() []byte

func (*AccountEvent) GetTags Uses

func (m *AccountEvent) GetTags() []string

func (*AccountEvent) GetUserId Uses

func (m *AccountEvent) GetUserId() string

func (*AccountEvent) ProtoMessage Uses

func (*AccountEvent) ProtoMessage()

func (*AccountEvent) Reset Uses

func (m *AccountEvent) Reset()

func (*AccountEvent) String Uses

func (m *AccountEvent) String() string

func (*AccountEvent) XXX_DiscardUnknown Uses

func (m *AccountEvent) XXX_DiscardUnknown()

func (*AccountEvent) XXX_Marshal Uses

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

func (*AccountEvent) XXX_Merge Uses

func (dst *AccountEvent) XXX_Merge(src proto.Message)

func (*AccountEvent) XXX_Size Uses

func (m *AccountEvent) XXX_Size() int

func (*AccountEvent) XXX_Unmarshal Uses

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

type AuthLevel Uses

type AuthLevel int32

Authentication level

const (
    AuthLevel_NONE AuthLevel = 0
    AuthLevel_ANON AuthLevel = 10
    AuthLevel_AUTH AuthLevel = 20
    AuthLevel_ROOT AuthLevel = 30
)

func (AuthLevel) EnumDescriptor Uses

func (AuthLevel) EnumDescriptor() ([]byte, []int)

func (AuthLevel) String Uses

func (x AuthLevel) String() string

type ClientAcc Uses

type ClientAcc struct {
    Id  string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    // User being created or updated
    UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    // The initial authentication scheme the account can use
    Scheme string `protobuf:"bytes,3,opt,name=scheme" 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" json:"login,omitempty"`
    // Indexable tags for user discovery
    Tags []string `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
    // User initialization data when creating a new user, otherwise ignored
    Desc *SetDesc `protobuf:"bytes,7,opt,name=desc" json:"desc,omitempty"`
    // Credentials for verification.
    Cred []*ClientCred `protobuf:"bytes,8,rep,name=cred" json:"cred,omitempty"`
    // Authentication token used for resetting a password.
    Token                []byte   `protobuf:"bytes,9,opt,name=token,proto3" json:"token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

User creation message {acc}

func (*ClientAcc) Descriptor Uses

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

func (*ClientAcc) GetCred Uses

func (m *ClientAcc) GetCred() []*ClientCred

func (*ClientAcc) GetDesc Uses

func (m *ClientAcc) GetDesc() *SetDesc

func (*ClientAcc) GetId Uses

func (m *ClientAcc) GetId() string

func (*ClientAcc) GetLogin Uses

func (m *ClientAcc) GetLogin() bool

func (*ClientAcc) GetScheme Uses

func (m *ClientAcc) GetScheme() string

func (*ClientAcc) GetSecret Uses

func (m *ClientAcc) GetSecret() []byte

func (*ClientAcc) GetTags Uses

func (m *ClientAcc) GetTags() []string

func (*ClientAcc) GetToken Uses

func (m *ClientAcc) GetToken() []byte

func (*ClientAcc) GetUserId Uses

func (m *ClientAcc) GetUserId() string

func (*ClientAcc) ProtoMessage Uses

func (*ClientAcc) ProtoMessage()

func (*ClientAcc) Reset Uses

func (m *ClientAcc) Reset()

func (*ClientAcc) String Uses

func (m *ClientAcc) String() string

func (*ClientAcc) XXX_DiscardUnknown Uses

func (m *ClientAcc) XXX_DiscardUnknown()

func (*ClientAcc) XXX_Marshal Uses

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

func (*ClientAcc) XXX_Merge Uses

func (dst *ClientAcc) XXX_Merge(src proto.Message)

func (*ClientAcc) XXX_Size Uses

func (m *ClientAcc) XXX_Size() int

func (*ClientAcc) XXX_Unmarshal Uses

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

type ClientCred Uses

type ClientCred struct {
    // Credential type, i.e. `email` or `tel`.
    Method string `protobuf:"bytes,1,opt,name=method" json:"method,omitempty"`
    // Value to verify, i.e. `user@example.com` or `+18003287448`
    Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
    // Verification response
    Response string `protobuf:"bytes,3,opt,name=response" json:"response,omitempty"`
    // Request parameters, such as preferences.
    Params               []byte   `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Credentials such as email or phone number

func (*ClientCred) Descriptor Uses

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

func (*ClientCred) GetMethod Uses

func (m *ClientCred) GetMethod() string

func (*ClientCred) GetParams Uses

func (m *ClientCred) GetParams() []byte

func (*ClientCred) GetResponse Uses

func (m *ClientCred) GetResponse() string

func (*ClientCred) GetValue Uses

func (m *ClientCred) GetValue() string

func (*ClientCred) ProtoMessage Uses

func (*ClientCred) ProtoMessage()

func (*ClientCred) Reset Uses

func (m *ClientCred) Reset()

func (*ClientCred) String Uses

func (m *ClientCred) String() string

func (*ClientCred) XXX_DiscardUnknown Uses

func (m *ClientCred) XXX_DiscardUnknown()

func (*ClientCred) XXX_Marshal Uses

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

func (*ClientCred) XXX_Merge Uses

func (dst *ClientCred) XXX_Merge(src proto.Message)

func (*ClientCred) XXX_Size Uses

func (m *ClientCred) XXX_Size() int

func (*ClientCred) XXX_Unmarshal Uses

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

type ClientDel Uses

type ClientDel struct {
    Id    string         `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic string         `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    What  ClientDel_What `protobuf:"varint,3,opt,name=what,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" json:"del_seq,omitempty"`
    // User ID of the subscription to delete
    UserId string `protobuf:"bytes,5,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    // Credential to delete.
    Cred *ClientCred `protobuf:"bytes,6,opt,name=cred" json:"cred,omitempty"`
    // Request to hard-delete messages for all users, if such option is available.
    Hard                 bool     `protobuf:"varint,7,opt,name=hard" json:"hard,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ClientDel delete messages or topic

func (*ClientDel) Descriptor Uses

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

func (*ClientDel) GetCred Uses

func (m *ClientDel) GetCred() *ClientCred

func (*ClientDel) GetDelSeq Uses

func (m *ClientDel) GetDelSeq() []*SeqRange

func (*ClientDel) GetHard Uses

func (m *ClientDel) GetHard() bool

func (*ClientDel) GetId Uses

func (m *ClientDel) GetId() string

func (*ClientDel) GetTopic Uses

func (m *ClientDel) GetTopic() string

func (*ClientDel) GetUserId Uses

func (m *ClientDel) GetUserId() string

func (*ClientDel) GetWhat Uses

func (m *ClientDel) GetWhat() ClientDel_What

func (*ClientDel) ProtoMessage Uses

func (*ClientDel) ProtoMessage()

func (*ClientDel) Reset Uses

func (m *ClientDel) Reset()

func (*ClientDel) String Uses

func (m *ClientDel) String() string

func (*ClientDel) XXX_DiscardUnknown Uses

func (m *ClientDel) XXX_DiscardUnknown()

func (*ClientDel) XXX_Marshal Uses

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

func (*ClientDel) XXX_Merge Uses

func (dst *ClientDel) XXX_Merge(src proto.Message)

func (*ClientDel) XXX_Size Uses

func (m *ClientDel) XXX_Size() int

func (*ClientDel) XXX_Unmarshal Uses

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

type ClientDel_What Uses

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 (
    ClientDel_MSG   ClientDel_What = 0
    ClientDel_TOPIC ClientDel_What = 1
    ClientDel_SUB   ClientDel_What = 2
    ClientDel_USER  ClientDel_What = 3
    ClientDel_CRED  ClientDel_What = 4
)

func (ClientDel_What) EnumDescriptor Uses

func (ClientDel_What) EnumDescriptor() ([]byte, []int)

func (ClientDel_What) String Uses

func (x ClientDel_What) String() string

type ClientGet Uses

type ClientGet struct {
    Id                   string    `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string    `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    Query                *GetQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

Query topic state {get}

func (*ClientGet) Descriptor Uses

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

func (*ClientGet) GetId Uses

func (m *ClientGet) GetId() string

func (*ClientGet) GetQuery Uses

func (m *ClientGet) GetQuery() *GetQuery

func (*ClientGet) GetTopic Uses

func (m *ClientGet) GetTopic() string

func (*ClientGet) ProtoMessage Uses

func (*ClientGet) ProtoMessage()

func (*ClientGet) Reset Uses

func (m *ClientGet) Reset()

func (*ClientGet) String Uses

func (m *ClientGet) String() string

func (*ClientGet) XXX_DiscardUnknown Uses

func (m *ClientGet) XXX_DiscardUnknown()

func (*ClientGet) XXX_Marshal Uses

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

func (*ClientGet) XXX_Merge Uses

func (dst *ClientGet) XXX_Merge(src proto.Message)

func (*ClientGet) XXX_Size Uses

func (m *ClientGet) XXX_Size() int

func (*ClientGet) XXX_Unmarshal Uses

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

type ClientHi Uses

type ClientHi struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    UserAgent            string   `protobuf:"bytes,2,opt,name=user_agent,json=userAgent" json:"user_agent,omitempty"`
    Ver                  string   `protobuf:"bytes,3,opt,name=ver" json:"ver,omitempty"`
    DeviceId             string   `protobuf:"bytes,4,opt,name=device_id,json=deviceId" json:"device_id,omitempty"`
    Lang                 string   `protobuf:"bytes,5,opt,name=lang" json:"lang,omitempty"`
    Platform             string   `protobuf:"bytes,6,opt,name=platform" json:"platform,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Client handshake

func (*ClientHi) Descriptor Uses

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

func (*ClientHi) GetDeviceId Uses

func (m *ClientHi) GetDeviceId() string

func (*ClientHi) GetId Uses

func (m *ClientHi) GetId() string

func (*ClientHi) GetLang Uses

func (m *ClientHi) GetLang() string

func (*ClientHi) GetPlatform Uses

func (m *ClientHi) GetPlatform() string

func (*ClientHi) GetUserAgent Uses

func (m *ClientHi) GetUserAgent() string

func (*ClientHi) GetVer Uses

func (m *ClientHi) GetVer() string

func (*ClientHi) ProtoMessage Uses

func (*ClientHi) ProtoMessage()

func (*ClientHi) Reset Uses

func (m *ClientHi) Reset()

func (*ClientHi) String Uses

func (m *ClientHi) String() string

func (*ClientHi) XXX_DiscardUnknown Uses

func (m *ClientHi) XXX_DiscardUnknown()

func (*ClientHi) XXX_Marshal Uses

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

func (*ClientHi) XXX_Merge Uses

func (dst *ClientHi) XXX_Merge(src proto.Message)

func (*ClientHi) XXX_Size Uses

func (m *ClientHi) XXX_Size() int

func (*ClientHi) XXX_Unmarshal Uses

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

type ClientLeave Uses

type ClientLeave struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string   `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    Unsub                bool     `protobuf:"varint,3,opt,name=unsub" json:"unsub,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Unsubscribe {leave} request message

func (*ClientLeave) Descriptor Uses

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

func (*ClientLeave) GetId Uses

func (m *ClientLeave) GetId() string

func (*ClientLeave) GetTopic Uses

func (m *ClientLeave) GetTopic() string

func (*ClientLeave) GetUnsub Uses

func (m *ClientLeave) GetUnsub() bool

func (*ClientLeave) ProtoMessage Uses

func (*ClientLeave) ProtoMessage()

func (*ClientLeave) Reset Uses

func (m *ClientLeave) Reset()

func (*ClientLeave) String Uses

func (m *ClientLeave) String() string

func (*ClientLeave) XXX_DiscardUnknown Uses

func (m *ClientLeave) XXX_DiscardUnknown()

func (*ClientLeave) XXX_Marshal Uses

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

func (*ClientLeave) XXX_Merge Uses

func (dst *ClientLeave) XXX_Merge(src proto.Message)

func (*ClientLeave) XXX_Size Uses

func (m *ClientLeave) XXX_Size() int

func (*ClientLeave) XXX_Unmarshal Uses

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

type ClientLogin Uses

type ClientLogin struct {
    Id  string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    // Authentication scheme
    Scheme string `protobuf:"bytes,2,opt,name=scheme" 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" json:"cred,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

Login {login} message

func (*ClientLogin) Descriptor Uses

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

func (*ClientLogin) GetCred Uses

func (m *ClientLogin) GetCred() []*ClientCred

func (*ClientLogin) GetId Uses

func (m *ClientLogin) GetId() string

func (*ClientLogin) GetScheme Uses

func (m *ClientLogin) GetScheme() string

func (*ClientLogin) GetSecret Uses

func (m *ClientLogin) GetSecret() []byte

func (*ClientLogin) ProtoMessage Uses

func (*ClientLogin) ProtoMessage()

func (*ClientLogin) Reset Uses

func (m *ClientLogin) Reset()

func (*ClientLogin) String Uses

func (m *ClientLogin) String() string

func (*ClientLogin) XXX_DiscardUnknown Uses

func (m *ClientLogin) XXX_DiscardUnknown()

func (*ClientLogin) XXX_Marshal Uses

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

func (*ClientLogin) XXX_Merge Uses

func (dst *ClientLogin) XXX_Merge(src proto.Message)

func (*ClientLogin) XXX_Size Uses

func (m *ClientLogin) XXX_Size() int

func (*ClientLogin) XXX_Unmarshal Uses

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

type ClientMsg Uses

type ClientMsg struct {
    // Types that are valid to be assigned 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"`
    // Root user may send messages on behalf of other users.
    OnBehalfOf           string    `protobuf:"bytes,11,opt,name=on_behalf_of,json=onBehalfOf" json:"on_behalf_of,omitempty"`
    AuthLevel            AuthLevel `protobuf:"varint,12,opt,name=auth_level,json=authLevel,enum=pbx.AuthLevel" json:"auth_level,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*ClientMsg) Descriptor Uses

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

func (*ClientMsg) GetAcc Uses

func (m *ClientMsg) GetAcc() *ClientAcc

func (*ClientMsg) GetAuthLevel Uses

func (m *ClientMsg) GetAuthLevel() AuthLevel

func (*ClientMsg) GetDel Uses

func (m *ClientMsg) GetDel() *ClientDel

func (*ClientMsg) GetGet Uses

func (m *ClientMsg) GetGet() *ClientGet

func (*ClientMsg) GetHi Uses

func (m *ClientMsg) GetHi() *ClientHi

func (*ClientMsg) GetLeave Uses

func (m *ClientMsg) GetLeave() *ClientLeave

func (*ClientMsg) GetLogin Uses

func (m *ClientMsg) GetLogin() *ClientLogin

func (*ClientMsg) GetMessage Uses

func (m *ClientMsg) GetMessage() isClientMsg_Message

func (*ClientMsg) GetNote Uses

func (m *ClientMsg) GetNote() *ClientNote

func (*ClientMsg) GetOnBehalfOf Uses

func (m *ClientMsg) GetOnBehalfOf() string

func (*ClientMsg) GetPub Uses

func (m *ClientMsg) GetPub() *ClientPub

func (*ClientMsg) GetSet Uses

func (m *ClientMsg) GetSet() *ClientSet

func (*ClientMsg) GetSub Uses

func (m *ClientMsg) GetSub() *ClientSub

func (*ClientMsg) ProtoMessage Uses

func (*ClientMsg) ProtoMessage()

func (*ClientMsg) Reset Uses

func (m *ClientMsg) Reset()

func (*ClientMsg) String Uses

func (m *ClientMsg) String() string

func (*ClientMsg) XXX_DiscardUnknown Uses

func (m *ClientMsg) XXX_DiscardUnknown()

func (*ClientMsg) XXX_Marshal Uses

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

func (*ClientMsg) XXX_Merge Uses

func (dst *ClientMsg) XXX_Merge(src proto.Message)

func (*ClientMsg) XXX_OneofFuncs Uses

func (*ClientMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ClientMsg) XXX_Size Uses

func (m *ClientMsg) XXX_Size() int

func (*ClientMsg) XXX_Unmarshal Uses

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

type ClientMsg_Acc Uses

type ClientMsg_Acc struct {
    Acc *ClientAcc `protobuf:"bytes,2,opt,name=acc,oneof"`
}

type ClientMsg_Del Uses

type ClientMsg_Del struct {
    Del *ClientDel `protobuf:"bytes,9,opt,name=del,oneof"`
}

type ClientMsg_Get Uses

type ClientMsg_Get struct {
    Get *ClientGet `protobuf:"bytes,7,opt,name=get,oneof"`
}

type ClientMsg_Hi Uses

type ClientMsg_Hi struct {
    Hi *ClientHi `protobuf:"bytes,1,opt,name=hi,oneof"`
}

type ClientMsg_Leave Uses

type ClientMsg_Leave struct {
    Leave *ClientLeave `protobuf:"bytes,5,opt,name=leave,oneof"`
}

type ClientMsg_Login Uses

type ClientMsg_Login struct {
    Login *ClientLogin `protobuf:"bytes,3,opt,name=login,oneof"`
}

type ClientMsg_Note Uses

type ClientMsg_Note struct {
    Note *ClientNote `protobuf:"bytes,10,opt,name=note,oneof"`
}

type ClientMsg_Pub Uses

type ClientMsg_Pub struct {
    Pub *ClientPub `protobuf:"bytes,6,opt,name=pub,oneof"`
}

type ClientMsg_Set Uses

type ClientMsg_Set struct {
    Set *ClientSet `protobuf:"bytes,8,opt,name=set,oneof"`
}

type ClientMsg_Sub Uses

type ClientMsg_Sub struct {
    Sub *ClientSub `protobuf:"bytes,4,opt,name=sub,oneof"`
}

type ClientNote Uses

type ClientNote struct {
    Topic string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
    // what is being reported: "recv" - message received, "read" - message read, "kp" - typing notification
    What InfoNote `protobuf:"varint,2,opt,name=what,enum=pbx.InfoNote" json:"what,omitempty"`
    // Server-issued message ID being reported
    SeqId                int32    `protobuf:"varint,3,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ClientNote is a client-generated notification for topic subscribers

func (*ClientNote) Descriptor Uses

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

func (*ClientNote) GetSeqId Uses

func (m *ClientNote) GetSeqId() int32

func (*ClientNote) GetTopic Uses

func (m *ClientNote) GetTopic() string

func (*ClientNote) GetWhat Uses

func (m *ClientNote) GetWhat() InfoNote

func (*ClientNote) ProtoMessage Uses

func (*ClientNote) ProtoMessage()

func (*ClientNote) Reset Uses

func (m *ClientNote) Reset()

func (*ClientNote) String Uses

func (m *ClientNote) String() string

func (*ClientNote) XXX_DiscardUnknown Uses

func (m *ClientNote) XXX_DiscardUnknown()

func (*ClientNote) XXX_Marshal Uses

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

func (*ClientNote) XXX_Merge Uses

func (dst *ClientNote) XXX_Merge(src proto.Message)

func (*ClientNote) XXX_Size Uses

func (m *ClientNote) XXX_Size() int

func (*ClientNote) XXX_Unmarshal Uses

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

type ClientPub Uses

type ClientPub struct {
    Id                   string            `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string            `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    NoEcho               bool              `protobuf:"varint,3,opt,name=no_echo,json=noEcho" json:"no_echo,omitempty"`
    Head                 map[string][]byte `protobuf:"bytes,4,rep,name=head" json:"head,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Content              []byte            `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

ClientPub is client's request to publish data to topic subscribers {pub}

func (*ClientPub) Descriptor Uses

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

func (*ClientPub) GetContent Uses

func (m *ClientPub) GetContent() []byte

func (*ClientPub) GetHead Uses

func (m *ClientPub) GetHead() map[string][]byte

func (*ClientPub) GetId Uses

func (m *ClientPub) GetId() string

func (*ClientPub) GetNoEcho Uses

func (m *ClientPub) GetNoEcho() bool

func (*ClientPub) GetTopic Uses

func (m *ClientPub) GetTopic() string

func (*ClientPub) ProtoMessage Uses

func (*ClientPub) ProtoMessage()

func (*ClientPub) Reset Uses

func (m *ClientPub) Reset()

func (*ClientPub) String Uses

func (m *ClientPub) String() string

func (*ClientPub) XXX_DiscardUnknown Uses

func (m *ClientPub) XXX_DiscardUnknown()

func (*ClientPub) XXX_Marshal Uses

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

func (*ClientPub) XXX_Merge Uses

func (dst *ClientPub) XXX_Merge(src proto.Message)

func (*ClientPub) XXX_Size Uses

func (m *ClientPub) XXX_Size() int

func (*ClientPub) XXX_Unmarshal Uses

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

type ClientReq Uses

type ClientReq struct {
    Msg                  *ClientMsg `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
    Sess                 *Session   `protobuf:"bytes,2,opt,name=sess" json:"sess,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*ClientReq) Descriptor Uses

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

func (*ClientReq) GetMsg Uses

func (m *ClientReq) GetMsg() *ClientMsg

func (*ClientReq) GetSess Uses

func (m *ClientReq) GetSess() *Session

func (*ClientReq) ProtoMessage Uses

func (*ClientReq) ProtoMessage()

func (*ClientReq) Reset Uses

func (m *ClientReq) Reset()

func (*ClientReq) String Uses

func (m *ClientReq) String() string

func (*ClientReq) XXX_DiscardUnknown Uses

func (m *ClientReq) XXX_DiscardUnknown()

func (*ClientReq) XXX_Marshal Uses

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

func (*ClientReq) XXX_Merge Uses

func (dst *ClientReq) XXX_Merge(src proto.Message)

func (*ClientReq) XXX_Size Uses

func (m *ClientReq) XXX_Size() int

func (*ClientReq) XXX_Unmarshal Uses

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

type ClientSet Uses

type ClientSet struct {
    Id                   string    `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string    `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    Query                *SetQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

Update topic state {set}

func (*ClientSet) Descriptor Uses

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

func (*ClientSet) GetId Uses

func (m *ClientSet) GetId() string

func (*ClientSet) GetQuery Uses

func (m *ClientSet) GetQuery() *SetQuery

func (*ClientSet) GetTopic Uses

func (m *ClientSet) GetTopic() string

func (*ClientSet) ProtoMessage Uses

func (*ClientSet) ProtoMessage()

func (*ClientSet) Reset Uses

func (m *ClientSet) Reset()

func (*ClientSet) String Uses

func (m *ClientSet) String() string

func (*ClientSet) XXX_DiscardUnknown Uses

func (m *ClientSet) XXX_DiscardUnknown()

func (*ClientSet) XXX_Marshal Uses

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

func (*ClientSet) XXX_Merge Uses

func (dst *ClientSet) XXX_Merge(src proto.Message)

func (*ClientSet) XXX_Size Uses

func (m *ClientSet) XXX_Size() int

func (*ClientSet) XXX_Unmarshal Uses

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

type ClientSub Uses

type ClientSub struct {
    Id    string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    // mirrors {set}
    SetQuery *SetQuery `protobuf:"bytes,3,opt,name=set_query,json=setQuery" json:"set_query,omitempty"`
    // mirrors {get}
    GetQuery             *GetQuery `protobuf:"bytes,4,opt,name=get_query,json=getQuery" json:"get_query,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

Subscription request {sub} message

func (*ClientSub) Descriptor Uses

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

func (*ClientSub) GetGetQuery Uses

func (m *ClientSub) GetGetQuery() *GetQuery

func (*ClientSub) GetId Uses

func (m *ClientSub) GetId() string

func (*ClientSub) GetSetQuery Uses

func (m *ClientSub) GetSetQuery() *SetQuery

func (*ClientSub) GetTopic Uses

func (m *ClientSub) GetTopic() string

func (*ClientSub) ProtoMessage Uses

func (*ClientSub) ProtoMessage()

func (*ClientSub) Reset Uses

func (m *ClientSub) Reset()

func (*ClientSub) String Uses

func (m *ClientSub) String() string

func (*ClientSub) XXX_DiscardUnknown Uses

func (m *ClientSub) XXX_DiscardUnknown()

func (*ClientSub) XXX_Marshal Uses

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

func (*ClientSub) XXX_Merge Uses

func (dst *ClientSub) XXX_Merge(src proto.Message)

func (*ClientSub) XXX_Size Uses

func (m *ClientSub) XXX_Size() int

func (*ClientSub) XXX_Unmarshal Uses

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

type Crud Uses

type Crud int32
const (
    Crud_CREATE Crud = 0
    Crud_UPDATE Crud = 1
    Crud_DELETE Crud = 2
)

func (Crud) EnumDescriptor Uses

func (Crud) EnumDescriptor() ([]byte, []int)

func (Crud) String Uses

func (x Crud) String() string

type DefaultAcsMode Uses

type DefaultAcsMode struct {
    Auth                 string   `protobuf:"bytes,1,opt,name=auth" json:"auth,omitempty"`
    Anon                 string   `protobuf:"bytes,2,opt,name=anon" json:"anon,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Topic default access mode

func (*DefaultAcsMode) Descriptor Uses

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

func (*DefaultAcsMode) GetAnon Uses

func (m *DefaultAcsMode) GetAnon() string

func (*DefaultAcsMode) GetAuth Uses

func (m *DefaultAcsMode) GetAuth() string

func (*DefaultAcsMode) ProtoMessage Uses

func (*DefaultAcsMode) ProtoMessage()

func (*DefaultAcsMode) Reset Uses

func (m *DefaultAcsMode) Reset()

func (*DefaultAcsMode) String Uses

func (m *DefaultAcsMode) String() string

func (*DefaultAcsMode) XXX_DiscardUnknown Uses

func (m *DefaultAcsMode) XXX_DiscardUnknown()

func (*DefaultAcsMode) XXX_Marshal Uses

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

func (*DefaultAcsMode) XXX_Merge Uses

func (dst *DefaultAcsMode) XXX_Merge(src proto.Message)

func (*DefaultAcsMode) XXX_Size Uses

func (m *DefaultAcsMode) XXX_Size() int

func (*DefaultAcsMode) XXX_Unmarshal Uses

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

type DelValues Uses

type DelValues struct {
    DelId                int32       `protobuf:"varint,1,opt,name=del_id,json=delId" json:"del_id,omitempty"`
    DelSeq               []*SeqRange `protobuf:"bytes,2,rep,name=del_seq,json=delSeq" json:"del_seq,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*DelValues) Descriptor Uses

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

func (*DelValues) GetDelId Uses

func (m *DelValues) GetDelId() int32

func (*DelValues) GetDelSeq Uses

func (m *DelValues) GetDelSeq() []*SeqRange

func (*DelValues) ProtoMessage Uses

func (*DelValues) ProtoMessage()

func (*DelValues) Reset Uses

func (m *DelValues) Reset()

func (*DelValues) String Uses

func (m *DelValues) String() string

func (*DelValues) XXX_DiscardUnknown Uses

func (m *DelValues) XXX_DiscardUnknown()

func (*DelValues) XXX_Marshal Uses

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

func (*DelValues) XXX_Merge Uses

func (dst *DelValues) XXX_Merge(src proto.Message)

func (*DelValues) XXX_Size Uses

func (m *DelValues) XXX_Size() int

func (*DelValues) XXX_Unmarshal Uses

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

type GetOpts Uses

type GetOpts struct {
    // Timestamp in milliseconds since epoch 01/01/1970
    IfModifiedSince int64 `protobuf:"varint,1,opt,name=if_modified_since,json=ifModifiedSince" json:"if_modified_since,omitempty"`
    // Limit search to this user ID
    User string `protobuf:"bytes,2,opt,name=user" json:"user,omitempty"`
    // Limit search results to one topic;
    Topic string `protobuf:"bytes,3,opt,name=topic" json:"topic,omitempty"`
    // Load messages with seq id equal or greater than this
    SinceId int32 `protobuf:"varint,4,opt,name=since_id,json=sinceId" json:"since_id,omitempty"`
    // Load messages with seq id lower than this
    BeforeId int32 `protobuf:"varint,5,opt,name=before_id,json=beforeId" json:"before_id,omitempty"`
    // Maximum number of results to return
    Limit                int32    `protobuf:"varint,6,opt,name=limit" json:"limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetOpts) Descriptor Uses

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

func (*GetOpts) GetBeforeId Uses

func (m *GetOpts) GetBeforeId() int32

func (*GetOpts) GetIfModifiedSince Uses

func (m *GetOpts) GetIfModifiedSince() int64

func (*GetOpts) GetLimit Uses

func (m *GetOpts) GetLimit() int32

func (*GetOpts) GetSinceId Uses

func (m *GetOpts) GetSinceId() int32

func (*GetOpts) GetTopic Uses

func (m *GetOpts) GetTopic() string

func (*GetOpts) GetUser Uses

func (m *GetOpts) GetUser() string

func (*GetOpts) ProtoMessage Uses

func (*GetOpts) ProtoMessage()

func (*GetOpts) Reset Uses

func (m *GetOpts) Reset()

func (*GetOpts) String Uses

func (m *GetOpts) String() string

func (*GetOpts) XXX_DiscardUnknown Uses

func (m *GetOpts) XXX_DiscardUnknown()

func (*GetOpts) XXX_Marshal Uses

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

func (*GetOpts) XXX_Merge Uses

func (dst *GetOpts) XXX_Merge(src proto.Message)

func (*GetOpts) XXX_Size Uses

func (m *GetOpts) XXX_Size() int

func (*GetOpts) XXX_Unmarshal Uses

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

type GetQuery Uses

type GetQuery struct {
    What string `protobuf:"bytes,1,opt,name=what" json:"what,omitempty"`
    // Parameters of "desc" request
    Desc *GetOpts `protobuf:"bytes,2,opt,name=desc" json:"desc,omitempty"`
    // Parameters of "sub" request
    Sub *GetOpts `protobuf:"bytes,3,opt,name=sub" json:"sub,omitempty"`
    // Parameters of "data" request
    Data                 *GetOpts `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetQuery) Descriptor Uses

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

func (*GetQuery) GetData Uses

func (m *GetQuery) GetData() *GetOpts

func (*GetQuery) GetDesc Uses

func (m *GetQuery) GetDesc() *GetOpts

func (*GetQuery) GetSub Uses

func (m *GetQuery) GetSub() *GetOpts

func (*GetQuery) GetWhat Uses

func (m *GetQuery) GetWhat() string

func (*GetQuery) ProtoMessage Uses

func (*GetQuery) ProtoMessage()

func (*GetQuery) Reset Uses

func (m *GetQuery) Reset()

func (*GetQuery) String Uses

func (m *GetQuery) String() string

func (*GetQuery) XXX_DiscardUnknown Uses

func (m *GetQuery) XXX_DiscardUnknown()

func (*GetQuery) XXX_Marshal Uses

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

func (*GetQuery) XXX_Merge Uses

func (dst *GetQuery) XXX_Merge(src proto.Message)

func (*GetQuery) XXX_Size Uses

func (m *GetQuery) XXX_Size() int

func (*GetQuery) XXX_Unmarshal Uses

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

type InfoNote Uses

type InfoNote int32
const (
    InfoNote_READ InfoNote = 0
    InfoNote_RECV InfoNote = 1
    InfoNote_KP   InfoNote = 2
)

func (InfoNote) EnumDescriptor Uses

func (InfoNote) EnumDescriptor() ([]byte, []int)

func (InfoNote) String Uses

func (x InfoNote) String() string

type MessageEvent Uses

type MessageEvent struct {
    Action               Crud        `protobuf:"varint,1,opt,name=action,enum=pbx.Crud" json:"action,omitempty"`
    Msg                  *ServerData `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*MessageEvent) Descriptor Uses

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

func (*MessageEvent) GetAction Uses

func (m *MessageEvent) GetAction() Crud

func (*MessageEvent) GetMsg Uses

func (m *MessageEvent) GetMsg() *ServerData

func (*MessageEvent) ProtoMessage Uses

func (*MessageEvent) ProtoMessage()

func (*MessageEvent) Reset Uses

func (m *MessageEvent) Reset()

func (*MessageEvent) String Uses

func (m *MessageEvent) String() string

func (*MessageEvent) XXX_DiscardUnknown Uses

func (m *MessageEvent) XXX_DiscardUnknown()

func (*MessageEvent) XXX_Marshal Uses

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

func (*MessageEvent) XXX_Merge Uses

func (dst *MessageEvent) XXX_Merge(src proto.Message)

func (*MessageEvent) XXX_Size Uses

func (m *MessageEvent) XXX_Size() int

func (*MessageEvent) XXX_Unmarshal Uses

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

type NodeClient Uses

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)
}

func NewNodeClient Uses

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeServer Uses

type NodeServer interface {
    // Client sends a stream of ClientMsg, server responds with a stream of ServerMsg
    MessageLoop(Node_MessageLoopServer) error
}

type Node_MessageLoopClient Uses

type Node_MessageLoopClient interface {
    Send(*ClientMsg) error
    Recv() (*ServerMsg, error)
    grpc.ClientStream
}

type Node_MessageLoopServer Uses

type Node_MessageLoopServer interface {
    Send(*ServerMsg) error
    Recv() (*ClientMsg, error)
    grpc.ServerStream
}

type PluginClient Uses

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)
}

func NewPluginClient Uses

func NewPluginClient(cc *grpc.ClientConn) PluginClient

type PluginServer Uses

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)
}

type RespCode Uses

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) EnumDescriptor Uses

func (RespCode) EnumDescriptor() ([]byte, []int)

func (RespCode) String Uses

func (x RespCode) String() string

type SearchFound Uses

type SearchFound struct {
    Status RespCode `protobuf:"varint,1,opt,name=status,enum=pbx.RespCode" json:"status,omitempty"`
    // New search query If status == REPLACE, otherwise unset.
    Query string `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
    // Search results.
    Result               []*TopicSub `protobuf:"bytes,3,rep,name=result" json:"result,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*SearchFound) Descriptor Uses

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

func (*SearchFound) GetQuery Uses

func (m *SearchFound) GetQuery() string

func (*SearchFound) GetResult Uses

func (m *SearchFound) GetResult() []*TopicSub

func (*SearchFound) GetStatus Uses

func (m *SearchFound) GetStatus() RespCode

func (*SearchFound) ProtoMessage Uses

func (*SearchFound) ProtoMessage()

func (*SearchFound) Reset Uses

func (m *SearchFound) Reset()

func (*SearchFound) String Uses

func (m *SearchFound) String() string

func (*SearchFound) XXX_DiscardUnknown Uses

func (m *SearchFound) XXX_DiscardUnknown()

func (*SearchFound) XXX_Marshal Uses

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

func (*SearchFound) XXX_Merge Uses

func (dst *SearchFound) XXX_Merge(src proto.Message)

func (*SearchFound) XXX_Size Uses

func (m *SearchFound) XXX_Size() int

func (*SearchFound) XXX_Unmarshal Uses

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

type SearchQuery Uses

type SearchQuery struct {
    UserId               string   `protobuf:"bytes,1,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    Query                string   `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SearchQuery) Descriptor Uses

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

func (*SearchQuery) GetQuery Uses

func (m *SearchQuery) GetQuery() string

func (*SearchQuery) GetUserId Uses

func (m *SearchQuery) GetUserId() string

func (*SearchQuery) ProtoMessage Uses

func (*SearchQuery) ProtoMessage()

func (*SearchQuery) Reset Uses

func (m *SearchQuery) Reset()

func (*SearchQuery) String Uses

func (m *SearchQuery) String() string

func (*SearchQuery) XXX_DiscardUnknown Uses

func (m *SearchQuery) XXX_DiscardUnknown()

func (*SearchQuery) XXX_Marshal Uses

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

func (*SearchQuery) XXX_Merge Uses

func (dst *SearchQuery) XXX_Merge(src proto.Message)

func (*SearchQuery) XXX_Size Uses

func (m *SearchQuery) XXX_Size() int

func (*SearchQuery) XXX_Unmarshal Uses

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

type SeqRange Uses

type SeqRange struct {
    Low                  int32    `protobuf:"varint,1,opt,name=low" json:"low,omitempty"`
    Hi                   int32    `protobuf:"varint,2,opt,name=hi" json:"hi,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SeqRange) Descriptor Uses

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

func (*SeqRange) GetHi Uses

func (m *SeqRange) GetHi() int32

func (*SeqRange) GetLow Uses

func (m *SeqRange) GetLow() int32

func (*SeqRange) ProtoMessage Uses

func (*SeqRange) ProtoMessage()

func (*SeqRange) Reset Uses

func (m *SeqRange) Reset()

func (*SeqRange) String Uses

func (m *SeqRange) String() string

func (*SeqRange) XXX_DiscardUnknown Uses

func (m *SeqRange) XXX_DiscardUnknown()

func (*SeqRange) XXX_Marshal Uses

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

func (*SeqRange) XXX_Merge Uses

func (dst *SeqRange) XXX_Merge(src proto.Message)

func (*SeqRange) XXX_Size Uses

func (m *SeqRange) XXX_Size() int

func (*SeqRange) XXX_Unmarshal Uses

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

type ServerCred Uses

type ServerCred struct {
    // Credential type, i.e. `email` or `tel`.
    Method string `protobuf:"bytes,1,opt,name=method" json:"method,omitempty"`
    // Value to verify, i.e. `user@example.com` or `+18003287448`
    Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
    // Indicator that the credential is validated
    Done                 bool     `protobuf:"varint,3,opt,name=done" json:"done,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Credentials

func (*ServerCred) Descriptor Uses

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

func (*ServerCred) GetDone Uses

func (m *ServerCred) GetDone() bool

func (*ServerCred) GetMethod Uses

func (m *ServerCred) GetMethod() string

func (*ServerCred) GetValue Uses

func (m *ServerCred) GetValue() string

func (*ServerCred) ProtoMessage Uses

func (*ServerCred) ProtoMessage()

func (*ServerCred) Reset Uses

func (m *ServerCred) Reset()

func (*ServerCred) String Uses

func (m *ServerCred) String() string

func (*ServerCred) XXX_DiscardUnknown Uses

func (m *ServerCred) XXX_DiscardUnknown()

func (*ServerCred) XXX_Marshal Uses

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

func (*ServerCred) XXX_Merge Uses

func (dst *ServerCred) XXX_Merge(src proto.Message)

func (*ServerCred) XXX_Size Uses

func (m *ServerCred) XXX_Size() int

func (*ServerCred) XXX_Unmarshal Uses

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

type ServerCtrl Uses

type ServerCtrl struct {
    Id                   string            `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string            `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    Code                 int32             `protobuf:"varint,3,opt,name=code" json:"code,omitempty"`
    Text                 string            `protobuf:"bytes,4,opt,name=text" json:"text,omitempty"`
    Params               map[string][]byte `protobuf:"bytes,5,rep,name=params" json:"params,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

{ctrl} message

func (*ServerCtrl) Descriptor Uses

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

func (*ServerCtrl) GetCode Uses

func (m *ServerCtrl) GetCode() int32

func (*ServerCtrl) GetId Uses

func (m *ServerCtrl) GetId() string

func (*ServerCtrl) GetParams Uses

func (m *ServerCtrl) GetParams() map[string][]byte

func (*ServerCtrl) GetText Uses

func (m *ServerCtrl) GetText() string

func (*ServerCtrl) GetTopic Uses

func (m *ServerCtrl) GetTopic() string

func (*ServerCtrl) ProtoMessage Uses

func (*ServerCtrl) ProtoMessage()

func (*ServerCtrl) Reset Uses

func (m *ServerCtrl) Reset()

func (*ServerCtrl) String Uses

func (m *ServerCtrl) String() string

func (*ServerCtrl) XXX_DiscardUnknown Uses

func (m *ServerCtrl) XXX_DiscardUnknown()

func (*ServerCtrl) XXX_Marshal Uses

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

func (*ServerCtrl) XXX_Merge Uses

func (dst *ServerCtrl) XXX_Merge(src proto.Message)

func (*ServerCtrl) XXX_Size Uses

func (m *ServerCtrl) XXX_Size() int

func (*ServerCtrl) XXX_Unmarshal Uses

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

type ServerData Uses

type ServerData struct {
    Topic string `protobuf:"bytes,1,opt,name=topic" 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" json:"from_user_id,omitempty"`
    // Timestamp when the message was sent.
    Timestamp int64 `protobuf:"varint,7,opt,name=timestamp" 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" json:"deleted_at,omitempty"`
    SeqId                int32             `protobuf:"varint,4,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    Head                 map[string][]byte `protobuf:"bytes,5,rep,name=head" json:"head,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Content              []byte            `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

{data} message

func (*ServerData) Descriptor Uses

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

func (*ServerData) GetContent Uses

func (m *ServerData) GetContent() []byte

func (*ServerData) GetDeletedAt Uses

func (m *ServerData) GetDeletedAt() int64

func (*ServerData) GetFromUserId Uses

func (m *ServerData) GetFromUserId() string

func (*ServerData) GetHead Uses

func (m *ServerData) GetHead() map[string][]byte

func (*ServerData) GetSeqId Uses

func (m *ServerData) GetSeqId() int32

func (*ServerData) GetTimestamp Uses

func (m *ServerData) GetTimestamp() int64

func (*ServerData) GetTopic Uses

func (m *ServerData) GetTopic() string

func (*ServerData) ProtoMessage Uses

func (*ServerData) ProtoMessage()

func (*ServerData) Reset Uses

func (m *ServerData) Reset()

func (*ServerData) String Uses

func (m *ServerData) String() string

func (*ServerData) XXX_DiscardUnknown Uses

func (m *ServerData) XXX_DiscardUnknown()

func (*ServerData) XXX_Marshal Uses

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

func (*ServerData) XXX_Merge Uses

func (dst *ServerData) XXX_Merge(src proto.Message)

func (*ServerData) XXX_Size Uses

func (m *ServerData) XXX_Size() int

func (*ServerData) XXX_Unmarshal Uses

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

type ServerInfo Uses

type ServerInfo struct {
    Topic                string   `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
    FromUserId           string   `protobuf:"bytes,2,opt,name=from_user_id,json=fromUserId" json:"from_user_id,omitempty"`
    What                 InfoNote `protobuf:"varint,3,opt,name=what,enum=pbx.InfoNote" json:"what,omitempty"`
    SeqId                int32    `protobuf:"varint,4,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

{info} message: server-side copy of ClientNote with From added

func (*ServerInfo) Descriptor Uses

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

func (*ServerInfo) GetFromUserId Uses

func (m *ServerInfo) GetFromUserId() string

func (*ServerInfo) GetSeqId Uses

func (m *ServerInfo) GetSeqId() int32

func (*ServerInfo) GetTopic Uses

func (m *ServerInfo) GetTopic() string

func (*ServerInfo) GetWhat Uses

func (m *ServerInfo) GetWhat() InfoNote

func (*ServerInfo) ProtoMessage Uses

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) Reset Uses

func (m *ServerInfo) Reset()

func (*ServerInfo) String Uses

func (m *ServerInfo) String() string

func (*ServerInfo) XXX_DiscardUnknown Uses

func (m *ServerInfo) XXX_DiscardUnknown()

func (*ServerInfo) XXX_Marshal Uses

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

func (*ServerInfo) XXX_Merge Uses

func (dst *ServerInfo) XXX_Merge(src proto.Message)

func (*ServerInfo) XXX_Size Uses

func (m *ServerInfo) XXX_Size() int

func (*ServerInfo) XXX_Unmarshal Uses

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

type ServerMeta Uses

type ServerMeta struct {
    Id                   string        `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Topic                string        `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    Desc                 *TopicDesc    `protobuf:"bytes,3,opt,name=desc" json:"desc,omitempty"`
    Sub                  []*TopicSub   `protobuf:"bytes,4,rep,name=sub" json:"sub,omitempty"`
    Del                  *DelValues    `protobuf:"bytes,5,opt,name=del" json:"del,omitempty"`
    Tags                 []string      `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
    Cred                 []*ServerCred `protobuf:"bytes,7,rep,name=cred" json:"cred,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

{meta} message

func (*ServerMeta) Descriptor Uses

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

func (*ServerMeta) GetCred Uses

func (m *ServerMeta) GetCred() []*ServerCred

func (*ServerMeta) GetDel Uses

func (m *ServerMeta) GetDel() *DelValues

func (*ServerMeta) GetDesc Uses

func (m *ServerMeta) GetDesc() *TopicDesc

func (*ServerMeta) GetId Uses

func (m *ServerMeta) GetId() string

func (*ServerMeta) GetSub Uses

func (m *ServerMeta) GetSub() []*TopicSub

func (*ServerMeta) GetTags Uses

func (m *ServerMeta) GetTags() []string

func (*ServerMeta) GetTopic Uses

func (m *ServerMeta) GetTopic() string

func (*ServerMeta) ProtoMessage Uses

func (*ServerMeta) ProtoMessage()

func (*ServerMeta) Reset Uses

func (m *ServerMeta) Reset()

func (*ServerMeta) String Uses

func (m *ServerMeta) String() string

func (*ServerMeta) XXX_DiscardUnknown Uses

func (m *ServerMeta) XXX_DiscardUnknown()

func (*ServerMeta) XXX_Marshal Uses

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

func (*ServerMeta) XXX_Merge Uses

func (dst *ServerMeta) XXX_Merge(src proto.Message)

func (*ServerMeta) XXX_Size Uses

func (m *ServerMeta) XXX_Size() int

func (*ServerMeta) XXX_Unmarshal Uses

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

type ServerMsg Uses

type ServerMsg struct {
    // Types that are valid to be assigned 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" json:"topic,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Cumulative message

func (*ServerMsg) Descriptor Uses

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

func (*ServerMsg) GetCtrl Uses

func (m *ServerMsg) GetCtrl() *ServerCtrl

func (*ServerMsg) GetData Uses

func (m *ServerMsg) GetData() *ServerData

func (*ServerMsg) GetInfo Uses

func (m *ServerMsg) GetInfo() *ServerInfo

func (*ServerMsg) GetMessage Uses

func (m *ServerMsg) GetMessage() isServerMsg_Message

func (*ServerMsg) GetMeta Uses

func (m *ServerMsg) GetMeta() *ServerMeta

func (*ServerMsg) GetPres Uses

func (m *ServerMsg) GetPres() *ServerPres

func (*ServerMsg) GetTopic Uses

func (m *ServerMsg) GetTopic() string

func (*ServerMsg) ProtoMessage Uses

func (*ServerMsg) ProtoMessage()

func (*ServerMsg) Reset Uses

func (m *ServerMsg) Reset()

func (*ServerMsg) String Uses

func (m *ServerMsg) String() string

func (*ServerMsg) XXX_DiscardUnknown Uses

func (m *ServerMsg) XXX_DiscardUnknown()

func (*ServerMsg) XXX_Marshal Uses

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

func (*ServerMsg) XXX_Merge Uses

func (dst *ServerMsg) XXX_Merge(src proto.Message)

func (*ServerMsg) XXX_OneofFuncs Uses

func (*ServerMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ServerMsg) XXX_Size Uses

func (m *ServerMsg) XXX_Size() int

func (*ServerMsg) XXX_Unmarshal Uses

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

type ServerMsg_Ctrl Uses

type ServerMsg_Ctrl struct {
    Ctrl *ServerCtrl `protobuf:"bytes,1,opt,name=ctrl,oneof"`
}

type ServerMsg_Data Uses

type ServerMsg_Data struct {
    Data *ServerData `protobuf:"bytes,2,opt,name=data,oneof"`
}

type ServerMsg_Info Uses

type ServerMsg_Info struct {
    Info *ServerInfo `protobuf:"bytes,5,opt,name=info,oneof"`
}

type ServerMsg_Meta Uses

type ServerMsg_Meta struct {
    Meta *ServerMeta `protobuf:"bytes,4,opt,name=meta,oneof"`
}

type ServerMsg_Pres Uses

type ServerMsg_Pres struct {
    Pres *ServerPres `protobuf:"bytes,3,opt,name=pres,oneof"`
}

type ServerPres Uses

type ServerPres struct {
    Topic                string          `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
    Src                  string          `protobuf:"bytes,2,opt,name=src" json:"src,omitempty"`
    What                 ServerPres_What `protobuf:"varint,3,opt,name=what,enum=pbx.ServerPres_What" json:"what,omitempty"`
    UserAgent            string          `protobuf:"bytes,4,opt,name=user_agent,json=userAgent" json:"user_agent,omitempty"`
    SeqId                int32           `protobuf:"varint,5,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    DelId                int32           `protobuf:"varint,6,opt,name=del_id,json=delId" json:"del_id,omitempty"`
    DelSeq               []*SeqRange     `protobuf:"bytes,7,rep,name=del_seq,json=delSeq" json:"del_seq,omitempty"`
    TargetUserId         string          `protobuf:"bytes,8,opt,name=target_user_id,json=targetUserId" json:"target_user_id,omitempty"`
    ActorUserId          string          `protobuf:"bytes,9,opt,name=actor_user_id,json=actorUserId" json:"actor_user_id,omitempty"`
    Acs                  *AccessMode     `protobuf:"bytes,10,opt,name=acs" json:"acs,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

{pres} message

func (*ServerPres) Descriptor Uses

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

func (*ServerPres) GetAcs Uses

func (m *ServerPres) GetAcs() *AccessMode

func (*ServerPres) GetActorUserId Uses

func (m *ServerPres) GetActorUserId() string

func (*ServerPres) GetDelId Uses

func (m *ServerPres) GetDelId() int32

func (*ServerPres) GetDelSeq Uses

func (m *ServerPres) GetDelSeq() []*SeqRange

func (*ServerPres) GetSeqId Uses

func (m *ServerPres) GetSeqId() int32

func (*ServerPres) GetSrc Uses

func (m *ServerPres) GetSrc() string

func (*ServerPres) GetTargetUserId Uses

func (m *ServerPres) GetTargetUserId() string

func (*ServerPres) GetTopic Uses

func (m *ServerPres) GetTopic() string

func (*ServerPres) GetUserAgent Uses

func (m *ServerPres) GetUserAgent() string

func (*ServerPres) GetWhat Uses

func (m *ServerPres) GetWhat() ServerPres_What

func (*ServerPres) ProtoMessage Uses

func (*ServerPres) ProtoMessage()

func (*ServerPres) Reset Uses

func (m *ServerPres) Reset()

func (*ServerPres) String Uses

func (m *ServerPres) String() string

func (*ServerPres) XXX_DiscardUnknown Uses

func (m *ServerPres) XXX_DiscardUnknown()

func (*ServerPres) XXX_Marshal Uses

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

func (*ServerPres) XXX_Merge Uses

func (dst *ServerPres) XXX_Merge(src proto.Message)

func (*ServerPres) XXX_Size Uses

func (m *ServerPres) XXX_Size() int

func (*ServerPres) XXX_Unmarshal Uses

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

type ServerPres_What Uses

type ServerPres_What int32
const (
    ServerPres_ON   ServerPres_What = 0
    ServerPres_OFF  ServerPres_What = 1
    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) EnumDescriptor Uses

func (ServerPres_What) EnumDescriptor() ([]byte, []int)

func (ServerPres_What) String Uses

func (x ServerPres_What) String() string

type ServerResp Uses

type ServerResp struct {
    Status               RespCode   `protobuf:"varint,1,opt,name=status,enum=pbx.RespCode" json:"status,omitempty"`
    Srvmsg               *ServerMsg `protobuf:"bytes,2,opt,name=srvmsg" json:"srvmsg,omitempty"`
    Clmsg                *ClientMsg `protobuf:"bytes,3,opt,name=clmsg" json:"clmsg,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*ServerResp) Descriptor Uses

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

func (*ServerResp) GetClmsg Uses

func (m *ServerResp) GetClmsg() *ClientMsg

func (*ServerResp) GetSrvmsg Uses

func (m *ServerResp) GetSrvmsg() *ServerMsg

func (*ServerResp) GetStatus Uses

func (m *ServerResp) GetStatus() RespCode

func (*ServerResp) ProtoMessage Uses

func (*ServerResp) ProtoMessage()

func (*ServerResp) Reset Uses

func (m *ServerResp) Reset()

func (*ServerResp) String Uses

func (m *ServerResp) String() string

func (*ServerResp) XXX_DiscardUnknown Uses

func (m *ServerResp) XXX_DiscardUnknown()

func (*ServerResp) XXX_Marshal Uses

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

func (*ServerResp) XXX_Merge Uses

func (dst *ServerResp) XXX_Merge(src proto.Message)

func (*ServerResp) XXX_Size Uses

func (m *ServerResp) XXX_Size() int

func (*ServerResp) XXX_Unmarshal Uses

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

type Session Uses

type Session struct {
    SessionId            string    `protobuf:"bytes,1,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`
    UserId               string    `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    AuthLevel            AuthLevel `protobuf:"varint,3,opt,name=auth_level,json=authLevel,enum=pbx.AuthLevel" json:"auth_level,omitempty"`
    RemoteAddr           string    `protobuf:"bytes,4,opt,name=remote_addr,json=remoteAddr" json:"remote_addr,omitempty"`
    UserAgent            string    `protobuf:"bytes,5,opt,name=user_agent,json=userAgent" json:"user_agent,omitempty"`
    DeviceId             string    `protobuf:"bytes,6,opt,name=device_id,json=deviceId" json:"device_id,omitempty"`
    Language             string    `protobuf:"bytes,7,opt,name=language" json:"language,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

Context message

func (*Session) Descriptor Uses

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

func (*Session) GetAuthLevel Uses

func (m *Session) GetAuthLevel() AuthLevel

func (*Session) GetDeviceId Uses

func (m *Session) GetDeviceId() string

func (*Session) GetLanguage Uses

func (m *Session) GetLanguage() string

func (*Session) GetRemoteAddr Uses

func (m *Session) GetRemoteAddr() string

func (*Session) GetSessionId Uses

func (m *Session) GetSessionId() string

func (*Session) GetUserAgent Uses

func (m *Session) GetUserAgent() string

func (*Session) GetUserId Uses

func (m *Session) GetUserId() string

func (*Session) ProtoMessage Uses

func (*Session) ProtoMessage()

func (*Session) Reset Uses

func (m *Session) Reset()

func (*Session) String Uses

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown Uses

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal Uses

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

func (*Session) XXX_Merge Uses

func (dst *Session) XXX_Merge(src proto.Message)

func (*Session) XXX_Size Uses

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal Uses

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

type SetDesc Uses

type SetDesc struct {
    DefaultAcs           *DefaultAcsMode `protobuf:"bytes,1,opt,name=default_acs,json=defaultAcs" 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"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

SetDesc: C2S in set.what == "desc" and sub.init message

func (*SetDesc) Descriptor Uses

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

func (*SetDesc) GetDefaultAcs Uses

func (m *SetDesc) GetDefaultAcs() *DefaultAcsMode

func (*SetDesc) GetPrivate Uses

func (m *SetDesc) GetPrivate() []byte

func (*SetDesc) GetPublic Uses

func (m *SetDesc) GetPublic() []byte

func (*SetDesc) ProtoMessage Uses

func (*SetDesc) ProtoMessage()

func (*SetDesc) Reset Uses

func (m *SetDesc) Reset()

func (*SetDesc) String Uses

func (m *SetDesc) String() string

func (*SetDesc) XXX_DiscardUnknown Uses

func (m *SetDesc) XXX_DiscardUnknown()

func (*SetDesc) XXX_Marshal Uses

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

func (*SetDesc) XXX_Merge Uses

func (dst *SetDesc) XXX_Merge(src proto.Message)

func (*SetDesc) XXX_Size Uses

func (m *SetDesc) XXX_Size() int

func (*SetDesc) XXX_Unmarshal Uses

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

type SetQuery Uses

type SetQuery struct {
    // Topic metadata, new topic & new subscriptions only
    Desc *SetDesc `protobuf:"bytes,1,opt,name=desc" json:"desc,omitempty"`
    // Subscription parameters
    Sub *SetSub `protobuf:"bytes,2,opt,name=sub" json:"sub,omitempty"`
    // Indexable tags
    Tags []string `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"`
    // Credential being updated.
    Cred                 *ClientCred `protobuf:"bytes,4,opt,name=cred" json:"cred,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*SetQuery) Descriptor Uses

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

func (*SetQuery) GetCred Uses

func (m *SetQuery) GetCred() *ClientCred

func (*SetQuery) GetDesc Uses

func (m *SetQuery) GetDesc() *SetDesc

func (*SetQuery) GetSub Uses

func (m *SetQuery) GetSub() *SetSub

func (*SetQuery) GetTags Uses

func (m *SetQuery) GetTags() []string

func (*SetQuery) ProtoMessage Uses

func (*SetQuery) ProtoMessage()

func (*SetQuery) Reset Uses

func (m *SetQuery) Reset()

func (*SetQuery) String Uses

func (m *SetQuery) String() string

func (*SetQuery) XXX_DiscardUnknown Uses

func (m *SetQuery) XXX_DiscardUnknown()

func (*SetQuery) XXX_Marshal Uses

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

func (*SetQuery) XXX_Merge Uses

func (dst *SetQuery) XXX_Merge(src proto.Message)

func (*SetQuery) XXX_Size Uses

func (m *SetQuery) XXX_Size() int

func (*SetQuery) XXX_Unmarshal Uses

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

type SetSub Uses

type SetSub struct {
    // User affected by this request. Default (empty): current user
    UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    // Access mode change, either Given or Want depending on context
    Mode                 string   `protobuf:"bytes,2,opt,name=mode" json:"mode,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SetSub: payload in set.sub request to update current subscription or invite another user, {sub.what} == "sub"

func (*SetSub) Descriptor Uses

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

func (*SetSub) GetMode Uses

func (m *SetSub) GetMode() string

func (*SetSub) GetUserId Uses

func (m *SetSub) GetUserId() string

func (*SetSub) ProtoMessage Uses

func (*SetSub) ProtoMessage()

func (*SetSub) Reset Uses

func (m *SetSub) Reset()

func (*SetSub) String Uses

func (m *SetSub) String() string

func (*SetSub) XXX_DiscardUnknown Uses

func (m *SetSub) XXX_DiscardUnknown()

func (*SetSub) XXX_Marshal Uses

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

func (*SetSub) XXX_Merge Uses

func (dst *SetSub) XXX_Merge(src proto.Message)

func (*SetSub) XXX_Size Uses

func (m *SetSub) XXX_Size() int

func (*SetSub) XXX_Unmarshal Uses

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

type SubscriptionEvent Uses

type SubscriptionEvent struct {
    Action               Crud        `protobuf:"varint,1,opt,name=action,enum=pbx.Crud" json:"action,omitempty"`
    Topic                string      `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    UserId               string      `protobuf:"bytes,3,opt,name=user_id,json=userId" json:"user_id,omitempty"`
    DelId                int32       `protobuf:"varint,4,opt,name=del_id,json=delId" json:"del_id,omitempty"`
    ReadId               int32       `protobuf:"varint,5,opt,name=read_id,json=readId" json:"read_id,omitempty"`
    RecvId               int32       `protobuf:"varint,6,opt,name=recv_id,json=recvId" json:"recv_id,omitempty"`
    Mode                 *AccessMode `protobuf:"bytes,7,opt,name=mode" json:"mode,omitempty"`
    Private              []byte      `protobuf:"bytes,8,opt,name=private,proto3" json:"private,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*SubscriptionEvent) Descriptor Uses

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

func (*SubscriptionEvent) GetAction Uses

func (m *SubscriptionEvent) GetAction() Crud

func (*SubscriptionEvent) GetDelId Uses

func (m *SubscriptionEvent) GetDelId() int32

func (*SubscriptionEvent) GetMode Uses

func (m *SubscriptionEvent) GetMode() *AccessMode

func (*SubscriptionEvent) GetPrivate Uses

func (m *SubscriptionEvent) GetPrivate() []byte

func (*SubscriptionEvent) GetReadId Uses

func (m *SubscriptionEvent) GetReadId() int32

func (*SubscriptionEvent) GetRecvId Uses

func (m *SubscriptionEvent) GetRecvId() int32

func (*SubscriptionEvent) GetTopic Uses

func (m *SubscriptionEvent) GetTopic() string

func (*SubscriptionEvent) GetUserId Uses

func (m *SubscriptionEvent) GetUserId() string

func (*SubscriptionEvent) ProtoMessage Uses

func (*SubscriptionEvent) ProtoMessage()

func (*SubscriptionEvent) Reset Uses

func (m *SubscriptionEvent) Reset()

func (*SubscriptionEvent) String Uses

func (m *SubscriptionEvent) String() string

func (*SubscriptionEvent) XXX_DiscardUnknown Uses

func (m *SubscriptionEvent) XXX_DiscardUnknown()

func (*SubscriptionEvent) XXX_Marshal Uses

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

func (*SubscriptionEvent) XXX_Merge Uses

func (dst *SubscriptionEvent) XXX_Merge(src proto.Message)

func (*SubscriptionEvent) XXX_Size Uses

func (m *SubscriptionEvent) XXX_Size() int

func (*SubscriptionEvent) XXX_Unmarshal Uses

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

type TopicDesc Uses

type TopicDesc struct {
    CreatedAt            int64           `protobuf:"varint,1,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
    UpdatedAt            int64           `protobuf:"varint,2,opt,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
    TouchedAt            int64           `protobuf:"varint,3,opt,name=touched_at,json=touchedAt" json:"touched_at,omitempty"`
    Defacs               *DefaultAcsMode `protobuf:"bytes,4,opt,name=defacs" json:"defacs,omitempty"`
    Acs                  *AccessMode     `protobuf:"bytes,5,opt,name=acs" json:"acs,omitempty"`
    SeqId                int32           `protobuf:"varint,6,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    ReadId               int32           `protobuf:"varint,7,opt,name=read_id,json=readId" json:"read_id,omitempty"`
    RecvId               int32           `protobuf:"varint,8,opt,name=recv_id,json=recvId" json:"recv_id,omitempty"`
    DelId                int32           `protobuf:"varint,9,opt,name=del_id,json=delId" 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"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

Topic description, S2C in Meta message

func (*TopicDesc) Descriptor Uses

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

func (*TopicDesc) GetAcs Uses

func (m *TopicDesc) GetAcs() *AccessMode

func (*TopicDesc) GetCreatedAt Uses

func (m *TopicDesc) GetCreatedAt() int64

func (*TopicDesc) GetDefacs Uses

func (m *TopicDesc) GetDefacs() *DefaultAcsMode

func (*TopicDesc) GetDelId Uses

func (m *TopicDesc) GetDelId() int32

func (*TopicDesc) GetPrivate Uses

func (m *TopicDesc) GetPrivate() []byte

func (*TopicDesc) GetPublic Uses

func (m *TopicDesc) GetPublic() []byte

func (*TopicDesc) GetReadId Uses

func (m *TopicDesc) GetReadId() int32

func (*TopicDesc) GetRecvId Uses

func (m *TopicDesc) GetRecvId() int32

func (*TopicDesc) GetSeqId Uses

func (m *TopicDesc) GetSeqId() int32

func (*TopicDesc) GetTouchedAt Uses

func (m *TopicDesc) GetTouchedAt() int64

func (*TopicDesc) GetUpdatedAt Uses

func (m *TopicDesc) GetUpdatedAt() int64

func (*TopicDesc) ProtoMessage Uses

func (*TopicDesc) ProtoMessage()

func (*TopicDesc) Reset Uses

func (m *TopicDesc) Reset()

func (*TopicDesc) String Uses

func (m *TopicDesc) String() string

func (*TopicDesc) XXX_DiscardUnknown Uses

func (m *TopicDesc) XXX_DiscardUnknown()

func (*TopicDesc) XXX_Marshal Uses

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

func (*TopicDesc) XXX_Merge Uses

func (dst *TopicDesc) XXX_Merge(src proto.Message)

func (*TopicDesc) XXX_Size Uses

func (m *TopicDesc) XXX_Size() int

func (*TopicDesc) XXX_Unmarshal Uses

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

type TopicEvent Uses

type TopicEvent struct {
    Action               Crud       `protobuf:"varint,1,opt,name=action,enum=pbx.Crud" json:"action,omitempty"`
    Name                 string     `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
    Desc                 *TopicDesc `protobuf:"bytes,3,opt,name=desc" json:"desc,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*TopicEvent) Descriptor Uses

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

func (*TopicEvent) GetAction Uses

func (m *TopicEvent) GetAction() Crud

func (*TopicEvent) GetDesc Uses

func (m *TopicEvent) GetDesc() *TopicDesc

func (*TopicEvent) GetName Uses

func (m *TopicEvent) GetName() string

func (*TopicEvent) ProtoMessage Uses

func (*TopicEvent) ProtoMessage()

func (*TopicEvent) Reset Uses

func (m *TopicEvent) Reset()

func (*TopicEvent) String Uses

func (m *TopicEvent) String() string

func (*TopicEvent) XXX_DiscardUnknown Uses

func (m *TopicEvent) XXX_DiscardUnknown()

func (*TopicEvent) XXX_Marshal Uses

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

func (*TopicEvent) XXX_Merge Uses

func (dst *TopicEvent) XXX_Merge(src proto.Message)

func (*TopicEvent) XXX_Size Uses

func (m *TopicEvent) XXX_Size() int

func (*TopicEvent) XXX_Unmarshal Uses

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

type TopicSub Uses

type TopicSub struct {
    UpdatedAt int64       `protobuf:"varint,1,opt,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
    DeletedAt int64       `protobuf:"varint,2,opt,name=deleted_at,json=deletedAt" json:"deleted_at,omitempty"`
    Online    bool        `protobuf:"varint,3,opt,name=online" json:"online,omitempty"`
    Acs       *AccessMode `protobuf:"bytes,4,opt,name=acs" json:"acs,omitempty"`
    ReadId    int32       `protobuf:"varint,5,opt,name=read_id,json=readId" json:"read_id,omitempty"`
    RecvId    int32       `protobuf:"varint,6,opt,name=recv_id,json=recvId" json:"recv_id,omitempty"`
    Public    []byte      `protobuf:"bytes,7,opt,name=public,proto3" json:"public,omitempty"`
    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" json:"user_id,omitempty"`
    // Topic name of this subscription
    Topic     string `protobuf:"bytes,10,opt,name=topic" json:"topic,omitempty"`
    TouchedAt int64  `protobuf:"varint,11,opt,name=touched_at,json=touchedAt" json:"touched_at,omitempty"`
    // ID of the last {data} message in a topic
    SeqId int32 `protobuf:"varint,12,opt,name=seq_id,json=seqId" json:"seq_id,omitempty"`
    // Messages are deleted up to this ID
    DelId int32 `protobuf:"varint,13,opt,name=del_id,json=delId" json:"del_id,omitempty"`
    // Other user's last online timestamp & user agent
    LastSeenTime         int64    `protobuf:"varint,14,opt,name=last_seen_time,json=lastSeenTime" json:"last_seen_time,omitempty"`
    LastSeenUserAgent    string   `protobuf:"bytes,15,opt,name=last_seen_user_agent,json=lastSeenUserAgent" json:"last_seen_user_agent,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

MsgTopicSub: topic subscription details, sent in Meta message

func (*TopicSub) Descriptor Uses

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

func (*TopicSub) GetAcs Uses

func (m *TopicSub) GetAcs() *AccessMode

func (*TopicSub) GetDelId Uses

func (m *TopicSub) GetDelId() int32

func (*TopicSub) GetDeletedAt Uses

func (m *TopicSub) GetDeletedAt() int64

func (*TopicSub) GetLastSeenTime Uses

func (m *TopicSub) GetLastSeenTime() int64

func (*TopicSub) GetLastSeenUserAgent Uses

func (m *TopicSub) GetLastSeenUserAgent() string

func (*TopicSub) GetOnline Uses

func (m *TopicSub) GetOnline() bool

func (*TopicSub) GetPrivate Uses

func (m *TopicSub) GetPrivate() []byte

func (*TopicSub) GetPublic Uses

func (m *TopicSub) GetPublic() []byte

func (*TopicSub) GetReadId Uses

func (m *TopicSub) GetReadId() int32

func (*TopicSub) GetRecvId Uses

func (m *TopicSub) GetRecvId() int32

func (*TopicSub) GetSeqId Uses

func (m *TopicSub) GetSeqId() int32

func (*TopicSub) GetTopic Uses

func (m *TopicSub) GetTopic() string

func (*TopicSub) GetTouchedAt Uses

func (m *TopicSub) GetTouchedAt() int64

func (*TopicSub) GetUpdatedAt Uses

func (m *TopicSub) GetUpdatedAt() int64

func (*TopicSub) GetUserId Uses

func (m *TopicSub) GetUserId() string

func (*TopicSub) ProtoMessage Uses

func (*TopicSub) ProtoMessage()

func (*TopicSub) Reset Uses

func (m *TopicSub) Reset()

func (*TopicSub) String Uses

func (m *TopicSub) String() string

func (*TopicSub) XXX_DiscardUnknown Uses

func (m *TopicSub) XXX_DiscardUnknown()

func (*TopicSub) XXX_Marshal Uses

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

func (*TopicSub) XXX_Merge Uses

func (dst *TopicSub) XXX_Merge(src proto.Message)

func (*TopicSub) XXX_Size Uses

func (m *TopicSub) XXX_Size() int

func (*TopicSub) XXX_Unmarshal Uses

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

type Unused Uses

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

Dummy placeholder message.

func (*Unused) Descriptor Uses

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

func (*Unused) ProtoMessage Uses

func (*Unused) ProtoMessage()

func (*Unused) Reset Uses

func (m *Unused) Reset()

func (*Unused) String Uses

func (m *Unused) String() string

func (*Unused) XXX_DiscardUnknown Uses

func (m *Unused) XXX_DiscardUnknown()

func (*Unused) XXX_Marshal Uses

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

func (*Unused) XXX_Merge Uses

func (dst *Unused) XXX_Merge(src proto.Message)

func (*Unused) XXX_Size Uses

func (m *Unused) XXX_Size() int

func (*Unused) XXX_Unmarshal Uses

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

Package pbx imports 5 packages (graph) and is imported by 3 packages. Updated 2019-08-15. Refresh now. Tools for package owners.