pbx

package
v0.17.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2021 License: GPL-3.0 Imports: 5 Imported by: 5

README

Protocol Buffer and gRPC definitions

Definitions for Tinode gRPC client and plugins.

Tinode gRPC clients must implement rpc service Node, Tinode plugins Plugin.

Generated Go and Python code is included. For a sample Python implementation of a command line client see tn-cli. For a partial plugin implementation see chatbot.

If you want to make changes, you have to install protobuffers tool chain and gRPC:

$ python -m pip install grpcio grpcio-tools googleapis-common-protos

To generate Go bindings add the following comment to your code and run go generate (your actual path to /pbx may be different):

//go:generate protoc --proto_path=../pbx --go_out=plugins=grpc:../pbx ../pbx/model.proto

To generate Python bindings:

python -m grpc_tools.protoc -I../pbx --python_out=. --grpc_python_out=. ../pbx/model.proto

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuthLevel_name = map[int32]string{
	0:  "NONE",
	10: "ANON",
	20: "AUTH",
	30: "ROOT",
}
View Source 
var AuthLevel_value = map[string]int32{
	"NONE": 0,
	"ANON": 10,
	"AUTH": 20,
	"ROOT": 30,
}
View Source 
var ClientDel_What_name = map[int32]string{
	0: "MSG",
	1: "TOPIC",
	2: "SUB",
	3: "USER",
	4: "CRED",
}
View Source 
var ClientDel_What_value = map[string]int32{
	"MSG":   0,
	"TOPIC": 1,
	"SUB":   2,
	"USER":  3,
	"CRED":  4,
}
View Source 
var Crud_name = map[int32]string{
	0: "CREATE",
	1: "UPDATE",
	2: "DELETE",
}
View Source 
var Crud_value = map[string]int32{
	"CREATE": 0,
	"UPDATE": 1,
	"DELETE": 2,
}
View Source 
var InfoNote_name = map[int32]string{
	0: "READ",
	1: "RECV",
	2: "KP",
}
View Source 
var InfoNote_value = map[string]int32{
	"READ": 0,
	"RECV": 1,
	"KP":   2,
}
View Source 
var RespCode_name = map[int32]string{
	0: "CONTINUE",
	1: "DROP",
	2: "RESPOND",
	3: "REPLACE",
}
View Source 
var RespCode_value = map[string]int32{
	"CONTINUE": 0,
	"DROP":     1,
	"RESPOND":  2,
	"REPLACE":  3,
}
View Source 
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",
}
View Source 
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,
}

Functions

func RegisterNodeServer 

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

func RegisterPluginServer 

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

Types

type AccessMode 

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 

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

func (*AccessMode) GetGiven 

func (m *AccessMode) GetGiven() string

func (*AccessMode) GetWant 

func (m *AccessMode) GetWant() string

func (*AccessMode) ProtoMessage 

func (*AccessMode) ProtoMessage()

func (*AccessMode) Reset 

func (m *AccessMode) Reset()

func (*AccessMode) String 

func (m *AccessMode) String() string

func (*AccessMode) XXX_DiscardUnknown added in v0.15.0 

func (m *AccessMode) XXX_DiscardUnknown()

func (*AccessMode) XXX_Marshal added in v0.15.0 

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

func (*AccessMode) XXX_Merge added in v0.15.0 

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

func (*AccessMode) XXX_Size added in v0.15.0 

func (m *AccessMode) XXX_Size() int

func (*AccessMode) XXX_Unmarshal added in v0.15.0 

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

type AccountEvent 

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 

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

func (*AccountEvent) GetAction 

func (m *AccountEvent) GetAction() Crud

func (*AccountEvent) GetDefaultAcs 

func (m *AccountEvent) GetDefaultAcs() *DefaultAcsMode

func (*AccountEvent) GetPublic 

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

func (*AccountEvent) GetTags 

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

func (*AccountEvent) GetUserId 

func (m *AccountEvent) GetUserId() string

func (*AccountEvent) ProtoMessage 

func (*AccountEvent) ProtoMessage()

func (*AccountEvent) Reset 

func (m *AccountEvent) Reset()

func (*AccountEvent) String 

func (m *AccountEvent) String() string

func (*AccountEvent) XXX_DiscardUnknown added in v0.15.0 

func (m *AccountEvent) XXX_DiscardUnknown()

func (*AccountEvent) XXX_Marshal added in v0.15.0 

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

func (*AccountEvent) XXX_Merge added in v0.15.0 

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

func (*AccountEvent) XXX_Size added in v0.15.0 

func (m *AccountEvent) XXX_Size() int

func (*AccountEvent) XXX_Unmarshal added in v0.15.0 

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

type AuthLevel added in v0.15.7 

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 added in v0.15.7 

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

func (AuthLevel) String added in v0.15.7 

func (x AuthLevel) String() string

type ClientAcc 

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"`
	// Account state: normal ("ok"), suspended
	State                string   `protobuf:"bytes,10,opt,name=state" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User creation message {acc}

func (*ClientAcc) Descriptor 

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

func (*ClientAcc) GetCred added in v0.14.4 

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

func (*ClientAcc) GetDesc 

func (m *ClientAcc) GetDesc() *SetDesc

func (*ClientAcc) GetId 

func (m *ClientAcc) GetId() string

func (*ClientAcc) GetLogin 

func (m *ClientAcc) GetLogin() bool

func (*ClientAcc) GetScheme 

func (m *ClientAcc) GetScheme() string

func (*ClientAcc) GetSecret 

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

func (*ClientAcc) GetState added in v0.16.4 

func (m *ClientAcc) GetState() string

func (*ClientAcc) GetTags 

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

func (*ClientAcc) GetToken added in v0.15.7 

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

func (*ClientAcc) GetUserId 

func (m *ClientAcc) GetUserId() string

func (*ClientAcc) ProtoMessage 

func (*ClientAcc) ProtoMessage()

func (*ClientAcc) Reset 

func (m *ClientAcc) Reset()

func (*ClientAcc) String 

func (m *ClientAcc) String() string

func (*ClientAcc) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientAcc) XXX_DiscardUnknown()

func (*ClientAcc) XXX_Marshal added in v0.15.0 

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

func (*ClientAcc) XXX_Merge added in v0.15.0 

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

func (*ClientAcc) XXX_Size added in v0.15.0 

func (m *ClientAcc) XXX_Size() int

func (*ClientAcc) XXX_Unmarshal added in v0.15.0 

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

type ClientCred added in v0.16.0 

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 or country code.
	Params               map[string][]byte `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Credentials such as email or phone number

func (*ClientCred) Descriptor added in v0.16.0 

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

func (*ClientCred) GetMethod added in v0.16.0 

func (m *ClientCred) GetMethod() string

func (*ClientCred) GetParams added in v0.16.0 

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

func (*ClientCred) GetResponse added in v0.16.0 

func (m *ClientCred) GetResponse() string

func (*ClientCred) GetValue added in v0.16.0 

func (m *ClientCred) GetValue() string

func (*ClientCred) ProtoMessage added in v0.16.0 

func (*ClientCred) ProtoMessage()

func (*ClientCred) Reset added in v0.16.0 

func (m *ClientCred) Reset()

func (*ClientCred) String added in v0.16.0 

func (m *ClientCred) String() string

func (*ClientCred) XXX_DiscardUnknown added in v0.16.0 

func (m *ClientCred) XXX_DiscardUnknown()

func (*ClientCred) XXX_Marshal added in v0.16.0 

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

func (*ClientCred) XXX_Merge added in v0.16.0 

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

func (*ClientCred) XXX_Size added in v0.16.0 

func (m *ClientCred) XXX_Size() int

func (*ClientCred) XXX_Unmarshal added in v0.16.0 

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

type ClientDel 

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 

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

func (*ClientDel) GetCred added in v0.16.0 

func (m *ClientDel) GetCred() *ClientCred

func (*ClientDel) GetDelSeq added in v0.14.2 

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

func (*ClientDel) GetHard 

func (m *ClientDel) GetHard() bool

func (*ClientDel) GetId 

func (m *ClientDel) GetId() string

func (*ClientDel) GetTopic 

func (m *ClientDel) GetTopic() string

func (*ClientDel) GetUserId 

func (m *ClientDel) GetUserId() string

func (*ClientDel) GetWhat 

func (m *ClientDel) GetWhat() ClientDel_What

func (*ClientDel) ProtoMessage 

func (*ClientDel) ProtoMessage()

func (*ClientDel) Reset 

func (m *ClientDel) Reset()

func (*ClientDel) String 

func (m *ClientDel) String() string

func (*ClientDel) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientDel) XXX_DiscardUnknown()

func (*ClientDel) XXX_Marshal added in v0.15.0 

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

func (*ClientDel) XXX_Merge added in v0.15.0 

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

func (*ClientDel) XXX_Size added in v0.15.0 

func (m *ClientDel) XXX_Size() int

func (*ClientDel) XXX_Unmarshal added in v0.15.0 

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

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 (
	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 

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

func (ClientDel_What) String 

func (x ClientDel_What) String() string

type ClientGet 

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 

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

func (*ClientGet) GetId 

func (m *ClientGet) GetId() string

func (*ClientGet) GetQuery 

func (m *ClientGet) GetQuery() *GetQuery

func (*ClientGet) GetTopic 

func (m *ClientGet) GetTopic() string

func (*ClientGet) ProtoMessage 

func (*ClientGet) ProtoMessage()

func (*ClientGet) Reset 

func (m *ClientGet) Reset()

func (*ClientGet) String 

func (m *ClientGet) String() string

func (*ClientGet) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientGet) XXX_DiscardUnknown()

func (*ClientGet) XXX_Marshal added in v0.15.0 

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

func (*ClientGet) XXX_Merge added in v0.15.0 

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

func (*ClientGet) XXX_Size added in v0.15.0 

func (m *ClientGet) XXX_Size() int

func (*ClientGet) XXX_Unmarshal added in v0.15.0 

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

type ClientHi 

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"`
	Background           bool     `protobuf:"varint,7,opt,name=background" json:"background,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Client handshake

func (*ClientHi) Descriptor 

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

func (*ClientHi) GetBackground added in v0.16.6 

func (m *ClientHi) GetBackground() bool

func (*ClientHi) GetDeviceId 

func (m *ClientHi) GetDeviceId() string

func (*ClientHi) GetId 

func (m *ClientHi) GetId() string

func (*ClientHi) GetLang 

func (m *ClientHi) GetLang() string

func (*ClientHi) GetPlatform added in v0.15.9 

func (m *ClientHi) GetPlatform() string

func (*ClientHi) GetUserAgent 

func (m *ClientHi) GetUserAgent() string

func (*ClientHi) GetVer 

func (m *ClientHi) GetVer() string

func (*ClientHi) ProtoMessage 

func (*ClientHi) ProtoMessage()

func (*ClientHi) Reset 

func (m *ClientHi) Reset()

func (*ClientHi) String 

func (m *ClientHi) String() string

func (*ClientHi) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientHi) XXX_DiscardUnknown()

func (*ClientHi) XXX_Marshal added in v0.15.0 

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

func (*ClientHi) XXX_Merge added in v0.15.0 

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

func (*ClientHi) XXX_Size added in v0.15.0 

func (m *ClientHi) XXX_Size() int

func (*ClientHi) XXX_Unmarshal added in v0.15.0 

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

type ClientLeave 

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 

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

func (*ClientLeave) GetId 

func (m *ClientLeave) GetId() string

func (*ClientLeave) GetTopic 

func (m *ClientLeave) GetTopic() string

func (*ClientLeave) GetUnsub 

func (m *ClientLeave) GetUnsub() bool

func (*ClientLeave) ProtoMessage 

func (*ClientLeave) ProtoMessage()

func (*ClientLeave) Reset 

func (m *ClientLeave) Reset()

func (*ClientLeave) String 

func (m *ClientLeave) String() string

func (*ClientLeave) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientLeave) XXX_DiscardUnknown()

func (*ClientLeave) XXX_Marshal added in v0.15.0 

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

func (*ClientLeave) XXX_Merge added in v0.15.0 

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

func (*ClientLeave) XXX_Size added in v0.15.0 

func (m *ClientLeave) XXX_Size() int

func (*ClientLeave) XXX_Unmarshal added in v0.15.0 

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

type ClientLogin 

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 

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

func (*ClientLogin) GetCred added in v0.14.4 

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

func (*ClientLogin) GetId 

func (m *ClientLogin) GetId() string

func (*ClientLogin) GetScheme 

func (m *ClientLogin) GetScheme() string

func (*ClientLogin) GetSecret 

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

func (*ClientLogin) ProtoMessage 

func (*ClientLogin) ProtoMessage()

func (*ClientLogin) Reset 

func (m *ClientLogin) Reset()

func (*ClientLogin) String 

func (m *ClientLogin) String() string

func (*ClientLogin) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientLogin) XXX_DiscardUnknown()

func (*ClientLogin) XXX_Marshal added in v0.15.0 

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

func (*ClientLogin) XXX_Merge added in v0.15.0 

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

func (*ClientLogin) XXX_Size added in v0.15.0 

func (m *ClientLogin) XXX_Size() int

func (*ClientLogin) XXX_Unmarshal added in v0.15.0 

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

type ClientMsg 

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 

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

func (*ClientMsg) GetAcc 

func (m *ClientMsg) GetAcc() *ClientAcc

func (*ClientMsg) GetAuthLevel added in v0.15.7 

func (m *ClientMsg) GetAuthLevel() AuthLevel

func (*ClientMsg) GetDel 

func (m *ClientMsg) GetDel() *ClientDel

func (*ClientMsg) GetGet 

func (m *ClientMsg) GetGet() *ClientGet

func (*ClientMsg) GetHi 

func (m *ClientMsg) GetHi() *ClientHi

func (*ClientMsg) GetLeave 

func (m *ClientMsg) GetLeave() *ClientLeave

func (*ClientMsg) GetLogin 

func (m *ClientMsg) GetLogin() *ClientLogin

func (*ClientMsg) GetMessage 

func (m *ClientMsg) GetMessage() isClientMsg_Message

func (*ClientMsg) GetNote 

func (m *ClientMsg) GetNote() *ClientNote

func (*ClientMsg) GetOnBehalfOf added in v0.15.7 

func (m *ClientMsg) GetOnBehalfOf() string

func (*ClientMsg) GetPub 

func (m *ClientMsg) GetPub() *ClientPub

func (*ClientMsg) GetSet 

func (m *ClientMsg) GetSet() *ClientSet

func (*ClientMsg) GetSub 

func (m *ClientMsg) GetSub() *ClientSub

func (*ClientMsg) ProtoMessage 

func (*ClientMsg) ProtoMessage()

func (*ClientMsg) Reset 

func (m *ClientMsg) Reset()

func (*ClientMsg) String 

func (m *ClientMsg) String() string

func (*ClientMsg) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientMsg) XXX_DiscardUnknown()

func (*ClientMsg) XXX_Marshal added in v0.15.0 

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

func (*ClientMsg) XXX_Merge added in v0.15.0 

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

func (*ClientMsg) XXX_OneofFuncs 

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 added in v0.15.0 

func (m *ClientMsg) XXX_Size() int

func (*ClientMsg) XXX_Unmarshal added in v0.15.0 

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

type ClientMsg_Acc 

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

type ClientMsg_Del 

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

type ClientMsg_Get 

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

type ClientMsg_Hi 

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

type ClientMsg_Leave 

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

type ClientMsg_Login 

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

type ClientMsg_Note 

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

type ClientMsg_Pub 

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

type ClientMsg_Set 

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

type ClientMsg_Sub 

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

type ClientNote 

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 

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

func (*ClientNote) GetSeqId 

func (m *ClientNote) GetSeqId() int32

func (*ClientNote) GetTopic 

func (m *ClientNote) GetTopic() string

func (*ClientNote) GetWhat 

func (m *ClientNote) GetWhat() InfoNote

func (*ClientNote) ProtoMessage 

func (*ClientNote) ProtoMessage()

func (*ClientNote) Reset 

func (m *ClientNote) Reset()

func (*ClientNote) String 

func (m *ClientNote) String() string

func (*ClientNote) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientNote) XXX_DiscardUnknown()

func (*ClientNote) XXX_Marshal added in v0.15.0 

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

func (*ClientNote) XXX_Merge added in v0.15.0 

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

func (*ClientNote) XXX_Size added in v0.15.0 

func (m *ClientNote) XXX_Size() int

func (*ClientNote) XXX_Unmarshal added in v0.15.0 

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

type ClientPub 

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 `` /* 135-byte string literal not displayed */
	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 

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

func (*ClientPub) GetContent 

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

func (*ClientPub) GetHead 

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

func (*ClientPub) GetId 

func (m *ClientPub) GetId() string

func (*ClientPub) GetNoEcho 

func (m *ClientPub) GetNoEcho() bool

func (*ClientPub) GetTopic 

func (m *ClientPub) GetTopic() string

func (*ClientPub) ProtoMessage 

func (*ClientPub) ProtoMessage()

func (*ClientPub) Reset 

func (m *ClientPub) Reset()

func (*ClientPub) String 

func (m *ClientPub) String() string

func (*ClientPub) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientPub) XXX_DiscardUnknown()

func (*ClientPub) XXX_Marshal added in v0.15.0 

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

func (*ClientPub) XXX_Merge added in v0.15.0 

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

func (*ClientPub) XXX_Size added in v0.15.0 

func (m *ClientPub) XXX_Size() int

func (*ClientPub) XXX_Unmarshal added in v0.15.0 

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

type ClientReq 

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 

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

func (*ClientReq) GetMsg 

func (m *ClientReq) GetMsg() *ClientMsg

func (*ClientReq) GetSess 

func (m *ClientReq) GetSess() *Session

func (*ClientReq) ProtoMessage 

func (*ClientReq) ProtoMessage()

func (*ClientReq) Reset 

func (m *ClientReq) Reset()

func (*ClientReq) String 

func (m *ClientReq) String() string

func (*ClientReq) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientReq) XXX_DiscardUnknown()

func (*ClientReq) XXX_Marshal added in v0.15.0 

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

func (*ClientReq) XXX_Merge added in v0.15.0 

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

func (*ClientReq) XXX_Size added in v0.15.0 

func (m *ClientReq) XXX_Size() int

func (*ClientReq) XXX_Unmarshal added in v0.15.0 

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

type ClientSet 

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 

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

func (*ClientSet) GetId 

func (m *ClientSet) GetId() string

func (*ClientSet) GetQuery 

func (m *ClientSet) GetQuery() *SetQuery

func (*ClientSet) GetTopic 

func (m *ClientSet) GetTopic() string

func (*ClientSet) ProtoMessage 

func (*ClientSet) ProtoMessage()

func (*ClientSet) Reset 

func (m *ClientSet) Reset()

func (*ClientSet) String 

func (m *ClientSet) String() string

func (*ClientSet) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientSet) XXX_DiscardUnknown()

func (*ClientSet) XXX_Marshal added in v0.15.0 

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

func (*ClientSet) XXX_Merge added in v0.15.0 

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

func (*ClientSet) XXX_Size added in v0.15.0 

func (m *ClientSet) XXX_Size() int

func (*ClientSet) XXX_Unmarshal added in v0.15.0 

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

type ClientSub 

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 

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

func (*ClientSub) GetGetQuery 

func (m *ClientSub) GetGetQuery() *GetQuery

func (*ClientSub) GetId 

func (m *ClientSub) GetId() string

func (*ClientSub) GetSetQuery 

func (m *ClientSub) GetSetQuery() *SetQuery

func (*ClientSub) GetTopic 

func (m *ClientSub) GetTopic() string

func (*ClientSub) ProtoMessage 

func (*ClientSub) ProtoMessage()

func (*ClientSub) Reset 

func (m *ClientSub) Reset()

func (*ClientSub) String 

func (m *ClientSub) String() string

func (*ClientSub) XXX_DiscardUnknown added in v0.15.0 

func (m *ClientSub) XXX_DiscardUnknown()

func (*ClientSub) XXX_Marshal added in v0.15.0 

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

func (*ClientSub) XXX_Merge added in v0.15.0 

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

func (*ClientSub) XXX_Size added in v0.15.0 

func (m *ClientSub) XXX_Size() int

func (*ClientSub) XXX_Unmarshal added in v0.15.0 

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

type Crud 

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

func (Crud) EnumDescriptor 

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

func (Crud) String 

func (x Crud) String() string

type DefaultAcsMode 

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 

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

func (*DefaultAcsMode) GetAnon 

func (m *DefaultAcsMode) GetAnon() string

func (*DefaultAcsMode) GetAuth 

func (m *DefaultAcsMode) GetAuth() string

func (*DefaultAcsMode) ProtoMessage 

func (*DefaultAcsMode) ProtoMessage()

func (*DefaultAcsMode) Reset 

func (m *DefaultAcsMode) Reset()

func (*DefaultAcsMode) String 

func (m *DefaultAcsMode) String() string

func (*DefaultAcsMode) XXX_DiscardUnknown added in v0.15.0 

func (m *DefaultAcsMode) XXX_DiscardUnknown()

func (*DefaultAcsMode) XXX_Marshal added in v0.15.0 

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

func (*DefaultAcsMode) XXX_Merge added in v0.15.0 

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

func (*DefaultAcsMode) XXX_Size added in v0.15.0 

func (m *DefaultAcsMode) XXX_Size() int

func (*DefaultAcsMode) XXX_Unmarshal added in v0.15.0 

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

type DelValues added in v0.14.2 

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 added in v0.14.2 

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

func (*DelValues) GetDelId added in v0.14.2 

func (m *DelValues) GetDelId() int32

func (*DelValues) GetDelSeq added in v0.14.2 

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

func (*DelValues) ProtoMessage added in v0.14.2 

func (*DelValues) ProtoMessage()

func (*DelValues) Reset added in v0.14.2 

func (m *DelValues) Reset()

func (*DelValues) String added in v0.14.2 

func (m *DelValues) String() string

func (*DelValues) XXX_DiscardUnknown added in v0.15.0 

func (m *DelValues) XXX_DiscardUnknown()

func (*DelValues) XXX_Marshal added in v0.15.0 

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

func (*DelValues) XXX_Merge added in v0.15.0 

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

func (*DelValues) XXX_Size added in v0.15.0 

func (m *DelValues) XXX_Size() int

func (*DelValues) XXX_Unmarshal added in v0.15.0 

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

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" 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 

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

func (*GetOpts) GetBeforeId added in v0.15.0 

func (m *GetOpts) GetBeforeId() int32

func (*GetOpts) GetIfModifiedSince 

func (m *GetOpts) GetIfModifiedSince() int64

func (*GetOpts) GetLimit 

func (m *GetOpts) GetLimit() int32

func (*GetOpts) GetSinceId added in v0.15.0 

func (m *GetOpts) GetSinceId() int32

func (*GetOpts) GetTopic added in v0.15.0 

func (m *GetOpts) GetTopic() string

func (*GetOpts) GetUser added in v0.15.0 

func (m *GetOpts) GetUser() string

func (*GetOpts) ProtoMessage 

func (*GetOpts) ProtoMessage()

func (*GetOpts) Reset 

func (m *GetOpts) Reset()

func (*GetOpts) String 

func (m *GetOpts) String() string

func (*GetOpts) XXX_DiscardUnknown added in v0.15.0 

func (m *GetOpts) XXX_DiscardUnknown()

func (*GetOpts) XXX_Marshal added in v0.15.0 

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

func (*GetOpts) XXX_Merge added in v0.15.0 

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

func (*GetOpts) XXX_Size added in v0.15.0 

func (m *GetOpts) XXX_Size() int

func (*GetOpts) XXX_Unmarshal added in v0.15.0 

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

type GetQuery 

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 

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

func (*GetQuery) GetData 

func (m *GetQuery) GetData() *GetOpts

func (*GetQuery) GetDesc 

func (m *GetQuery) GetDesc() *GetOpts

func (*GetQuery) GetSub 

func (m *GetQuery) GetSub() *GetOpts

func (*GetQuery) GetWhat 

func (m *GetQuery) GetWhat() string

func (*GetQuery) ProtoMessage 

func (*GetQuery) ProtoMessage()

func (*GetQuery) Reset 

func (m *GetQuery) Reset()

func (*GetQuery) String 

func (m *GetQuery) String() string

func (*GetQuery) XXX_DiscardUnknown added in v0.15.0 

func (m *GetQuery) XXX_DiscardUnknown()

func (*GetQuery) XXX_Marshal added in v0.15.0 

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

func (*GetQuery) XXX_Merge added in v0.15.0 

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

func (*GetQuery) XXX_Size added in v0.15.0 

func (m *GetQuery) XXX_Size() int

func (*GetQuery) XXX_Unmarshal added in v0.15.0 

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

type InfoNote 

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

func (InfoNote) EnumDescriptor 

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

func (InfoNote) String 

func (x InfoNote) String() string

type MessageEvent 

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 

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

func (*MessageEvent) GetAction 

func (m *MessageEvent) GetAction() Crud

func (*MessageEvent) GetMsg added in v0.14.2 

func (m *MessageEvent) GetMsg() *ServerData

func (*MessageEvent) ProtoMessage 

func (*MessageEvent) ProtoMessage()

func (*MessageEvent) Reset 

func (m *MessageEvent) Reset()

func (*MessageEvent) String 

func (m *MessageEvent) String() string

func (*MessageEvent) XXX_DiscardUnknown added in v0.15.0 

func (m *MessageEvent) XXX_DiscardUnknown()

func (*MessageEvent) XXX_Marshal added in v0.15.0 

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

func (*MessageEvent) XXX_Merge added in v0.15.0 

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

func (*MessageEvent) XXX_Size added in v0.15.0 

func (m *MessageEvent) XXX_Size() int

func (*MessageEvent) XXX_Unmarshal added in v0.15.0 

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

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

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeServer 

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

type Node_MessageLoopClient 

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

type Node_MessageLoopServer 

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

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

func NewPluginClient 

func NewPluginClient(cc *grpc.ClientConn) 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)
}

type RespCode added in v0.14.2 

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 added in v0.14.2 

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

func (RespCode) String added in v0.14.2 

func (x RespCode) String() string

type SearchFound added in v0.14.2 

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 added in v0.14.2 

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

func (*SearchFound) GetQuery added in v0.15.0 

func (m *SearchFound) GetQuery() string

func (*SearchFound) GetResult added in v0.14.2 

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

func (*SearchFound) GetStatus added in v0.14.2 

func (m *SearchFound) GetStatus() RespCode

func (*SearchFound) ProtoMessage added in v0.14.2 

func (*SearchFound) ProtoMessage()

func (*SearchFound) Reset added in v0.14.2 

func (m *SearchFound) Reset()

func (*SearchFound) String added in v0.14.2 

func (m *SearchFound) String() string

func (*SearchFound) XXX_DiscardUnknown added in v0.15.0 

func (m *SearchFound) XXX_DiscardUnknown()

func (*SearchFound) XXX_Marshal added in v0.15.0 

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

func (*SearchFound) XXX_Merge added in v0.15.0 

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

func (*SearchFound) XXX_Size added in v0.15.0 

func (m *SearchFound) XXX_Size() int

func (*SearchFound) XXX_Unmarshal added in v0.15.0 

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

type SearchQuery added in v0.14.2 

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 added in v0.14.2 

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

func (*SearchQuery) GetQuery added in v0.15.0 

func (m *SearchQuery) GetQuery() string

func (*SearchQuery) GetUserId added in v0.14.2 

func (m *SearchQuery) GetUserId() string

func (*SearchQuery) ProtoMessage added in v0.14.2 

func (*SearchQuery) ProtoMessage()

func (*SearchQuery) Reset added in v0.14.2 

func (m *SearchQuery) Reset()

func (*SearchQuery) String added in v0.14.2 

func (m *SearchQuery) String() string

func (*SearchQuery) XXX_DiscardUnknown added in v0.15.0 

func (m *SearchQuery) XXX_DiscardUnknown()

func (*SearchQuery) XXX_Marshal added in v0.15.0 

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

func (*SearchQuery) XXX_Merge added in v0.15.0 

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

func (*SearchQuery) XXX_Size added in v0.15.0 

func (m *SearchQuery) XXX_Size() int

func (*SearchQuery) XXX_Unmarshal added in v0.15.0 

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

type SeqRange added in v0.14.2 

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 added in v0.14.2 

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

func (*SeqRange) GetHi added in v0.14.2 

func (m *SeqRange) GetHi() int32

func (*SeqRange) GetLow added in v0.14.2 

func (m *SeqRange) GetLow() int32

func (*SeqRange) ProtoMessage added in v0.14.2 

func (*SeqRange) ProtoMessage()

func (*SeqRange) Reset added in v0.14.2 

func (m *SeqRange) Reset()

func (*SeqRange) String added in v0.14.2 

func (m *SeqRange) String() string

func (*SeqRange) XXX_DiscardUnknown added in v0.15.0 

func (m *SeqRange) XXX_DiscardUnknown()

func (*SeqRange) XXX_Marshal added in v0.15.0 

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

func (*SeqRange) XXX_Merge added in v0.15.0 

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

func (*SeqRange) XXX_Size added in v0.15.0 

func (m *SeqRange) XXX_Size() int

func (*SeqRange) XXX_Unmarshal added in v0.15.0 

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

type ServerCred added in v0.16.0 

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 added in v0.16.0 

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

func (*ServerCred) GetDone added in v0.16.0 

func (m *ServerCred) GetDone() bool

func (*ServerCred) GetMethod added in v0.16.0 

func (m *ServerCred) GetMethod() string

func (*ServerCred) GetValue added in v0.16.0 

func (m *ServerCred) GetValue() string

func (*ServerCred) ProtoMessage added in v0.16.0 

func (*ServerCred) ProtoMessage()

func (*ServerCred) Reset added in v0.16.0 

func (m *ServerCred) Reset()

func (*ServerCred) String added in v0.16.0 

func (m *ServerCred) String() string

func (*ServerCred) XXX_DiscardUnknown added in v0.16.0 

func (m *ServerCred) XXX_DiscardUnknown()

func (*ServerCred) XXX_Marshal added in v0.16.0 

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

func (*ServerCred) XXX_Merge added in v0.16.0 

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

func (*ServerCred) XXX_Size added in v0.16.0 

func (m *ServerCred) XXX_Size() int

func (*ServerCred) XXX_Unmarshal added in v0.16.0 

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

type ServerCtrl 

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 `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

{ctrl} message

func (*ServerCtrl) Descriptor 

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

func (*ServerCtrl) GetCode 

func (m *ServerCtrl) GetCode() int32

func (*ServerCtrl) GetId 

func (m *ServerCtrl) GetId() string

func (*ServerCtrl) GetParams 

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

func (*ServerCtrl) GetText 

func (m *ServerCtrl) GetText() string

func (*ServerCtrl) GetTopic 

func (m *ServerCtrl) GetTopic() string

func (*ServerCtrl) ProtoMessage 

func (*ServerCtrl) ProtoMessage()

func (*ServerCtrl) Reset 

func (m *ServerCtrl) Reset()

func (*ServerCtrl) String 

func (m *ServerCtrl) String() string

func (*ServerCtrl) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerCtrl) XXX_DiscardUnknown()

func (*ServerCtrl) XXX_Marshal added in v0.15.0 

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

func (*ServerCtrl) XXX_Merge added in v0.15.0 

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

func (*ServerCtrl) XXX_Size added in v0.15.0 

func (m *ServerCtrl) XXX_Size() int

func (*ServerCtrl) XXX_Unmarshal added in v0.15.0 

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

type ServerData 

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 `` /* 135-byte string literal not displayed */
	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 

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

func (*ServerData) GetContent 

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

func (*ServerData) GetDeletedAt 

func (m *ServerData) GetDeletedAt() int64

func (*ServerData) GetFromUserId 

func (m *ServerData) GetFromUserId() string

func (*ServerData) GetHead 

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

func (*ServerData) GetSeqId 

func (m *ServerData) GetSeqId() int32

func (*ServerData) GetTimestamp added in v0.15.10 

func (m *ServerData) GetTimestamp() int64

func (*ServerData) GetTopic 

func (m *ServerData) GetTopic() string

func (*ServerData) ProtoMessage 

func (*ServerData) ProtoMessage()

func (*ServerData) Reset 

func (m *ServerData) Reset()

func (*ServerData) String 

func (m *ServerData) String() string

func (*ServerData) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerData) XXX_DiscardUnknown()

func (*ServerData) XXX_Marshal added in v0.15.0 

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

func (*ServerData) XXX_Merge added in v0.15.0 

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

func (*ServerData) XXX_Size added in v0.15.0 

func (m *ServerData) XXX_Size() int

func (*ServerData) XXX_Unmarshal added in v0.15.0 

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

type ServerInfo 

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"`
	Src                  string   `protobuf:"bytes,5,opt,name=src" json:"src,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

{info} message: server-side copy of ClientNote with From and optional Src added.

func (*ServerInfo) Descriptor 

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

func (*ServerInfo) GetFromUserId 

func (m *ServerInfo) GetFromUserId() string

func (*ServerInfo) GetSeqId 

func (m *ServerInfo) GetSeqId() int32

func (*ServerInfo) GetSrc added in v0.16.10 

func (m *ServerInfo) GetSrc() string

func (*ServerInfo) GetTopic 

func (m *ServerInfo) GetTopic() string

func (*ServerInfo) GetWhat 

func (m *ServerInfo) GetWhat() InfoNote

func (*ServerInfo) ProtoMessage 

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) Reset 

func (m *ServerInfo) Reset()

func (*ServerInfo) String 

func (m *ServerInfo) String() string

func (*ServerInfo) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerInfo) XXX_DiscardUnknown()

func (*ServerInfo) XXX_Marshal added in v0.15.0 

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

func (*ServerInfo) XXX_Merge added in v0.15.0 

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

func (*ServerInfo) XXX_Size added in v0.15.0 

func (m *ServerInfo) XXX_Size() int

func (*ServerInfo) XXX_Unmarshal added in v0.15.0 

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

type ServerMeta 

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 

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

func (*ServerMeta) GetCred added in v0.16.0 

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

func (*ServerMeta) GetDel added in v0.14.2 

func (m *ServerMeta) GetDel() *DelValues

func (*ServerMeta) GetDesc 

func (m *ServerMeta) GetDesc() *TopicDesc

func (*ServerMeta) GetId 

func (m *ServerMeta) GetId() string

func (*ServerMeta) GetSub 

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

func (*ServerMeta) GetTags added in v0.15.12 

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

func (*ServerMeta) GetTopic 

func (m *ServerMeta) GetTopic() string

func (*ServerMeta) ProtoMessage 

func (*ServerMeta) ProtoMessage()

func (*ServerMeta) Reset 

func (m *ServerMeta) Reset()

func (*ServerMeta) String 

func (m *ServerMeta) String() string

func (*ServerMeta) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerMeta) XXX_DiscardUnknown()

func (*ServerMeta) XXX_Marshal added in v0.15.0 

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

func (*ServerMeta) XXX_Merge added in v0.15.0 

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

func (*ServerMeta) XXX_Size added in v0.15.0 

func (m *ServerMeta) XXX_Size() int

func (*ServerMeta) XXX_Unmarshal added in v0.15.0 

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

type ServerMsg 

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 

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

func (*ServerMsg) GetCtrl 

func (m *ServerMsg) GetCtrl() *ServerCtrl

func (*ServerMsg) GetData 

func (m *ServerMsg) GetData() *ServerData

func (*ServerMsg) GetInfo 

func (m *ServerMsg) GetInfo() *ServerInfo

func (*ServerMsg) GetMessage 

func (m *ServerMsg) GetMessage() isServerMsg_Message

func (*ServerMsg) GetMeta 

func (m *ServerMsg) GetMeta() *ServerMeta

func (*ServerMsg) GetPres 

func (m *ServerMsg) GetPres() *ServerPres

func (*ServerMsg) GetTopic added in v0.15.7 

func (m *ServerMsg) GetTopic() string

func (*ServerMsg) ProtoMessage 

func (*ServerMsg) ProtoMessage()

func (*ServerMsg) Reset 

func (m *ServerMsg) Reset()

func (*ServerMsg) String 

func (m *ServerMsg) String() string

func (*ServerMsg) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerMsg) XXX_DiscardUnknown()

func (*ServerMsg) XXX_Marshal added in v0.15.0 

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

func (*ServerMsg) XXX_Merge added in v0.15.0 

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

func (*ServerMsg) XXX_OneofFuncs 

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 added in v0.15.0 

func (m *ServerMsg) XXX_Size() int

func (*ServerMsg) XXX_Unmarshal added in v0.15.0 

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

type ServerMsg_Ctrl 

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

type ServerMsg_Data 

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

type ServerMsg_Info 

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

type ServerMsg_Meta 

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

type ServerMsg_Pres 

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

type ServerPres 

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 

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

func (*ServerPres) GetAcs 

func (m *ServerPres) GetAcs() *AccessMode

func (*ServerPres) GetActorUserId 

func (m *ServerPres) GetActorUserId() string

func (*ServerPres) GetDelId added in v0.14.2 

func (m *ServerPres) GetDelId() int32

func (*ServerPres) GetDelSeq added in v0.14.2 

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

func (*ServerPres) GetSeqId 

func (m *ServerPres) GetSeqId() int32

func (*ServerPres) GetSrc 

func (m *ServerPres) GetSrc() string

func (*ServerPres) GetTargetUserId 

func (m *ServerPres) GetTargetUserId() string

func (*ServerPres) GetTopic 

func (m *ServerPres) GetTopic() string

func (*ServerPres) GetUserAgent 

func (m *ServerPres) GetUserAgent() string

func (*ServerPres) GetWhat 

func (m *ServerPres) GetWhat() ServerPres_What

func (*ServerPres) ProtoMessage 

func (*ServerPres) ProtoMessage()

func (*ServerPres) Reset 

func (m *ServerPres) Reset()

func (*ServerPres) String 

func (m *ServerPres) String() string

func (*ServerPres) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerPres) XXX_DiscardUnknown()

func (*ServerPres) XXX_Marshal added in v0.15.0 

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

func (*ServerPres) XXX_Merge added in v0.15.0 

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

func (*ServerPres) XXX_Size added in v0.15.0 

func (m *ServerPres) XXX_Size() int

func (*ServerPres) XXX_Unmarshal added in v0.15.0 

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

type ServerPres_What 

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 

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

func (ServerPres_What) String 

func (x ServerPres_What) String() string

type ServerResp 

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 

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

func (*ServerResp) GetClmsg 

func (m *ServerResp) GetClmsg() *ClientMsg

func (*ServerResp) GetSrvmsg 

func (m *ServerResp) GetSrvmsg() *ServerMsg

func (*ServerResp) GetStatus 

func (m *ServerResp) GetStatus() RespCode

func (*ServerResp) ProtoMessage 

func (*ServerResp) ProtoMessage()

func (*ServerResp) Reset 

func (m *ServerResp) Reset()

func (*ServerResp) String 

func (m *ServerResp) String() string

func (*ServerResp) XXX_DiscardUnknown added in v0.15.0 

func (m *ServerResp) XXX_DiscardUnknown()

func (*ServerResp) XXX_Marshal added in v0.15.0 

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

func (*ServerResp) XXX_Merge added in v0.15.0 

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

func (*ServerResp) XXX_Size added in v0.15.0 

func (m *ServerResp) XXX_Size() int

func (*ServerResp) XXX_Unmarshal added in v0.15.0 

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

type Session 

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 

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

func (*Session) GetAuthLevel 

func (m *Session) GetAuthLevel() AuthLevel

func (*Session) GetDeviceId 

func (m *Session) GetDeviceId() string

func (*Session) GetLanguage 

func (m *Session) GetLanguage() string

func (*Session) GetRemoteAddr 

func (m *Session) GetRemoteAddr() string

func (*Session) GetSessionId 

func (m *Session) GetSessionId() string

func (*Session) GetUserAgent 

func (m *Session) GetUserAgent() string

func (*Session) GetUserId 

func (m *Session) GetUserId() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown added in v0.15.0 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal added in v0.15.0 

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

func (*Session) XXX_Merge added in v0.15.0 

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

func (*Session) XXX_Size added in v0.15.0 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal added in v0.15.0 

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

type SetDesc 

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 

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

func (*SetDesc) GetDefaultAcs 

func (m *SetDesc) GetDefaultAcs() *DefaultAcsMode

func (*SetDesc) GetPrivate 

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

func (*SetDesc) GetPublic 

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

func (*SetDesc) ProtoMessage 

func (*SetDesc) ProtoMessage()

func (*SetDesc) Reset 

func (m *SetDesc) Reset()

func (*SetDesc) String 

func (m *SetDesc) String() string

func (*SetDesc) XXX_DiscardUnknown added in v0.15.0 

func (m *SetDesc) XXX_DiscardUnknown()

func (*SetDesc) XXX_Marshal added in v0.15.0 

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

func (*SetDesc) XXX_Merge added in v0.15.0 

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

func (*SetDesc) XXX_Size added in v0.15.0 

func (m *SetDesc) XXX_Size() int

func (*SetDesc) XXX_Unmarshal added in v0.15.0 

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

type SetQuery 

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 

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

func (*SetQuery) GetCred added in v0.16.0 

func (m *SetQuery) GetCred() *ClientCred

func (*SetQuery) GetDesc 

func (m *SetQuery) GetDesc() *SetDesc

func (*SetQuery) GetSub 

func (m *SetQuery) GetSub() *SetSub

func (*SetQuery) GetTags added in v0.15.0 

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

func (*SetQuery) ProtoMessage 

func (*SetQuery) ProtoMessage()

func (*SetQuery) Reset 

func (m *SetQuery) Reset()

func (*SetQuery) String 

func (m *SetQuery) String() string

func (*SetQuery) XXX_DiscardUnknown added in v0.15.0 

func (m *SetQuery) XXX_DiscardUnknown()

func (*SetQuery) XXX_Marshal added in v0.15.0 

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

func (*SetQuery) XXX_Merge added in v0.15.0 

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

func (*SetQuery) XXX_Size added in v0.15.0 

func (m *SetQuery) XXX_Size() int

func (*SetQuery) XXX_Unmarshal added in v0.15.0 

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

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" 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 

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

func (*SetSub) GetMode 

func (m *SetSub) GetMode() string

func (*SetSub) GetUserId 

func (m *SetSub) GetUserId() string

func (*SetSub) ProtoMessage 

func (*SetSub) ProtoMessage()

func (*SetSub) Reset 

func (m *SetSub) Reset()

func (*SetSub) String 

func (m *SetSub) String() string

func (*SetSub) XXX_DiscardUnknown added in v0.15.0 

func (m *SetSub) XXX_DiscardUnknown()

func (*SetSub) XXX_Marshal added in v0.15.0 

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

func (*SetSub) XXX_Merge added in v0.15.0 

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

func (*SetSub) XXX_Size added in v0.15.0 

func (m *SetSub) XXX_Size() int

func (*SetSub) XXX_Unmarshal added in v0.15.0 

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

type SubscriptionEvent 

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 

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

func (*SubscriptionEvent) GetAction 

func (m *SubscriptionEvent) GetAction() Crud

func (*SubscriptionEvent) GetDelId added in v0.14.2 

func (m *SubscriptionEvent) GetDelId() int32

func (*SubscriptionEvent) GetMode added in v0.14.2 

func (m *SubscriptionEvent) GetMode() *AccessMode

func (*SubscriptionEvent) GetPrivate added in v0.14.2 

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

func (*SubscriptionEvent) GetReadId added in v0.14.2 

func (m *SubscriptionEvent) GetReadId() int32

func (*SubscriptionEvent) GetRecvId added in v0.14.2 

func (m *SubscriptionEvent) GetRecvId() int32

func (*SubscriptionEvent) GetTopic added in v0.14.2 

func (m *SubscriptionEvent) GetTopic() string

func (*SubscriptionEvent) GetUserId added in v0.14.2 

func (m *SubscriptionEvent) GetUserId() string

func (*SubscriptionEvent) ProtoMessage 

func (*SubscriptionEvent) ProtoMessage()

func (*SubscriptionEvent) Reset 

func (m *SubscriptionEvent) Reset()

func (*SubscriptionEvent) String 

func (m *SubscriptionEvent) String() string

func (*SubscriptionEvent) XXX_DiscardUnknown added in v0.15.0 

func (m *SubscriptionEvent) XXX_DiscardUnknown()

func (*SubscriptionEvent) XXX_Marshal added in v0.15.0 

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

func (*SubscriptionEvent) XXX_Merge added in v0.15.0 

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

func (*SubscriptionEvent) XXX_Size added in v0.15.0 

func (m *SubscriptionEvent) XXX_Size() int

func (*SubscriptionEvent) XXX_Unmarshal added in v0.15.0 

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

type TopicDesc 

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"`
	State     string          `protobuf:"bytes,12,opt,name=state" json:"state,omitempty"`
	StateAt   int64           `protobuf:"varint,13,opt,name=state_at,json=stateAt" json:"state_at,omitempty"`
	// P2P only: other user's last online timestamp & user agent
	LastSeenTime         int64    `protobuf:"varint,15,opt,name=last_seen_time,json=lastSeenTime" json:"last_seen_time,omitempty"`
	LastSeenUserAgent    string   `protobuf:"bytes,16,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:"-"`
}

Topic description, S2C in Meta message

func (*TopicDesc) Descriptor 

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

func (*TopicDesc) GetAcs 

func (m *TopicDesc) GetAcs() *AccessMode

func (*TopicDesc) GetCreatedAt 

func (m *TopicDesc) GetCreatedAt() int64

func (*TopicDesc) GetDefacs 

func (m *TopicDesc) GetDefacs() *DefaultAcsMode

func (*TopicDesc) GetDelId added in v0.14.2 

func (m *TopicDesc) GetDelId() int32

func (*TopicDesc) GetLastSeenTime added in v0.17.8 

func (m *TopicDesc) GetLastSeenTime() int64

func (*TopicDesc) GetLastSeenUserAgent added in v0.17.8 

func (m *TopicDesc) GetLastSeenUserAgent() string

func (*TopicDesc) GetPrivate 

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

func (*TopicDesc) GetPublic 

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

func (*TopicDesc) GetReadId 

func (m *TopicDesc) GetReadId() int32

func (*TopicDesc) GetRecvId 

func (m *TopicDesc) GetRecvId() int32

func (*TopicDesc) GetSeqId 

func (m *TopicDesc) GetSeqId() int32

func (*TopicDesc) GetState added in v0.16.4 

func (m *TopicDesc) GetState() string

func (*TopicDesc) GetStateAt added in v0.16.4 

func (m *TopicDesc) GetStateAt() int64

func (*TopicDesc) GetTouchedAt added in v0.14.6 

func (m *TopicDesc) GetTouchedAt() int64

func (*TopicDesc) GetUpdatedAt 

func (m *TopicDesc) GetUpdatedAt() int64

func (*TopicDesc) ProtoMessage 

func (*TopicDesc) ProtoMessage()

func (*TopicDesc) Reset 

func (m *TopicDesc) Reset()

func (*TopicDesc) String 

func (m *TopicDesc) String() string

func (*TopicDesc) XXX_DiscardUnknown added in v0.15.0 

func (m *TopicDesc) XXX_DiscardUnknown()

func (*TopicDesc) XXX_Marshal added in v0.15.0 

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

func (*TopicDesc) XXX_Merge added in v0.15.0 

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

func (*TopicDesc) XXX_Size added in v0.15.0 

func (m *TopicDesc) XXX_Size() int

func (*TopicDesc) XXX_Unmarshal added in v0.15.0 

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

type TopicEvent 

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 

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

func (*TopicEvent) GetAction 

func (m *TopicEvent) GetAction() Crud

func (*TopicEvent) GetDesc 

func (m *TopicEvent) GetDesc() *TopicDesc

func (*TopicEvent) GetName 

func (m *TopicEvent) GetName() string

func (*TopicEvent) ProtoMessage 

func (*TopicEvent) ProtoMessage()

func (*TopicEvent) Reset 

func (m *TopicEvent) Reset()

func (*TopicEvent) String 

func (m *TopicEvent) String() string

func (*TopicEvent) XXX_DiscardUnknown added in v0.15.0 

func (m *TopicEvent) XXX_DiscardUnknown()

func (*TopicEvent) XXX_Marshal added in v0.15.0 

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

func (*TopicEvent) XXX_Merge added in v0.15.0 

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

func (*TopicEvent) XXX_Size added in v0.15.0 

func (m *TopicEvent) XXX_Size() int

func (*TopicEvent) XXX_Unmarshal added in v0.15.0 

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

type TopicSub 

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 

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

func (*TopicSub) GetAcs 

func (m *TopicSub) GetAcs() *AccessMode

func (*TopicSub) GetDelId added in v0.14.2 

func (m *TopicSub) GetDelId() int32

func (*TopicSub) GetDeletedAt 

func (m *TopicSub) GetDeletedAt() int64

func (*TopicSub) GetLastSeenTime 

func (m *TopicSub) GetLastSeenTime() int64

func (*TopicSub) GetLastSeenUserAgent 

func (m *TopicSub) GetLastSeenUserAgent() string

func (*TopicSub) GetOnline 

func (m *TopicSub) GetOnline() bool

func (*TopicSub) GetPrivate 

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

func (*TopicSub) GetPublic 

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

func (*TopicSub) GetReadId 

func (m *TopicSub) GetReadId() int32

func (*TopicSub) GetRecvId 

func (m *TopicSub) GetRecvId() int32

func (*TopicSub) GetSeqId 

func (m *TopicSub) GetSeqId() int32

func (*TopicSub) GetTopic 

func (m *TopicSub) GetTopic() string

func (*TopicSub) GetTouchedAt added in v0.14.6 

func (m *TopicSub) GetTouchedAt() int64

func (*TopicSub) GetUpdatedAt 

func (m *TopicSub) GetUpdatedAt() int64

func (*TopicSub) GetUserId 

func (m *TopicSub) GetUserId() string

func (*TopicSub) ProtoMessage 

func (*TopicSub) ProtoMessage()

func (*TopicSub) Reset 

func (m *TopicSub) Reset()

func (*TopicSub) String 

func (m *TopicSub) String() string

func (*TopicSub) XXX_DiscardUnknown added in v0.15.0 

func (m *TopicSub) XXX_DiscardUnknown()

func (*TopicSub) XXX_Marshal added in v0.15.0 

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

func (*TopicSub) XXX_Merge added in v0.15.0 

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

func (*TopicSub) XXX_Size added in v0.15.0 

func (m *TopicSub) XXX_Size() int

func (*TopicSub) XXX_Unmarshal added in v0.15.0 

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

type Unused 

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

Dummy placeholder message.

func (*Unused) Descriptor 

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

func (*Unused) ProtoMessage 

func (*Unused) ProtoMessage()

func (*Unused) Reset 

func (m *Unused) Reset()

func (*Unused) String 

func (m *Unused) String() string

func (*Unused) XXX_DiscardUnknown added in v0.15.0 

func (m *Unused) XXX_DiscardUnknown()

func (*Unused) XXX_Marshal added in v0.15.0 

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

func (*Unused) XXX_Merge added in v0.15.0 

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

func (*Unused) XXX_Size added in v0.15.0 

func (m *Unused) XXX_Size() int

func (*Unused) XXX_Unmarshal added in v0.15.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.