model.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: model.proto

package pbx

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"

import (
	context "golang.org/x/net/context"
	grpc "google.golang.org/grpc"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package

type InfoNote int32

const (
	InfoNote_READ InfoNote = 0
	InfoNote_RECV InfoNote = 1
	InfoNote_KP   InfoNote = 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,
}

func (x InfoNote) String() string {
	return proto.EnumName(InfoNote_name, int32(x))
}
func (InfoNote) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{0}
}

// Plugin response codes
type RespCode int32

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
)

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

func (x RespCode) String() string {
	return proto.EnumName(RespCode_name, int32(x))
}
func (RespCode) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{1}
}

type Crud int32

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

var Crud_name = map[int32]string{
	0: "CREATE",
	1: "UPDATE",
	2: "DELETE",
}
var Crud_value = map[string]int32{
	"CREATE": 0,
	"UPDATE": 1,
	"DELETE": 2,
}

func (x Crud) String() string {
	return proto.EnumName(Crud_name, int32(x))
}
func (Crud) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{2}
}

// What to delete, either "msg" to delete messages (default) or "topic" to delete the topic or "sub"
// to delete a subscription to topic.
type ClientDel_What int32

const (
	ClientDel_MSG   ClientDel_What = 0
	ClientDel_TOPIC ClientDel_What = 1
	ClientDel_SUB   ClientDel_What = 2
)

var ClientDel_What_name = map[int32]string{
	0: "MSG",
	1: "TOPIC",
	2: "SUB",
}
var ClientDel_What_value = map[string]int32{
	"MSG":   0,
	"TOPIC": 1,
	"SUB":   2,
}

func (x ClientDel_What) String() string {
	return proto.EnumName(ClientDel_What_name, int32(x))
}
func (ClientDel_What) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{18, 0}
}

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
)

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

func (x ServerPres_What) String() string {
	return proto.EnumName(ServerPres_What_name, int32(x))
}
func (ServerPres_What) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{26, 0}
}

type Session_AuthLevel int32

const (
	Session_NONE Session_AuthLevel = 0
	Session_ANON Session_AuthLevel = 10
	Session_AUTH Session_AuthLevel = 20
	Session_ROOT Session_AuthLevel = 30
)

var Session_AuthLevel_name = map[int32]string{
	0:  "NONE",
	10: "ANON",
	20: "AUTH",
	30: "ROOT",
}
var Session_AuthLevel_value = map[string]int32{
	"NONE": 0,
	"ANON": 10,
	"AUTH": 20,
	"ROOT": 30,
}

func (x Session_AuthLevel) String() string {
	return proto.EnumName(Session_AuthLevel_name, int32(x))
}
func (Session_AuthLevel) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{31, 0}
}

// Dummy placeholder message.
type Unused struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Unused) Reset()         { *m = Unused{} }
func (m *Unused) String() string { return proto.CompactTextString(m) }
func (*Unused) ProtoMessage()    {}
func (*Unused) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{0}
}
func (m *Unused) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Unused.Unmarshal(m, b)
}
func (m *Unused) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Unused.Marshal(b, m, deterministic)
}
func (dst *Unused) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Unused.Merge(dst, src)
}
func (m *Unused) XXX_Size() int {
	return xxx_messageInfo_Unused.Size(m)
}
func (m *Unused) XXX_DiscardUnknown() {
	xxx_messageInfo_Unused.DiscardUnknown(m)
}

var xxx_messageInfo_Unused proto.InternalMessageInfo

// Topic default access mode
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:"-"`
}

func (m *DefaultAcsMode) Reset()         { *m = DefaultAcsMode{} }
func (m *DefaultAcsMode) String() string { return proto.CompactTextString(m) }
func (*DefaultAcsMode) ProtoMessage()    {}
func (*DefaultAcsMode) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{1}
}
func (m *DefaultAcsMode) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DefaultAcsMode.Unmarshal(m, b)
}
func (m *DefaultAcsMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DefaultAcsMode.Marshal(b, m, deterministic)
}
func (dst *DefaultAcsMode) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DefaultAcsMode.Merge(dst, src)
}
func (m *DefaultAcsMode) XXX_Size() int {
	return xxx_messageInfo_DefaultAcsMode.Size(m)
}
func (m *DefaultAcsMode) XXX_DiscardUnknown() {
	xxx_messageInfo_DefaultAcsMode.DiscardUnknown(m)
}

var xxx_messageInfo_DefaultAcsMode proto.InternalMessageInfo

func (m *DefaultAcsMode) GetAuth() string {
	if m != nil {
		return m.Auth
	}
	return ""
}

func (m *DefaultAcsMode) GetAnon() string {
	if m != nil {
		return m.Anon
	}
	return ""
}

// Actual access mode
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:"-"`
}

func (m *AccessMode) Reset()         { *m = AccessMode{} }
func (m *AccessMode) String() string { return proto.CompactTextString(m) }
func (*AccessMode) ProtoMessage()    {}
func (*AccessMode) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{2}
}
func (m *AccessMode) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AccessMode.Unmarshal(m, b)
}
func (m *AccessMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AccessMode.Marshal(b, m, deterministic)
}
func (dst *AccessMode) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AccessMode.Merge(dst, src)
}
func (m *AccessMode) XXX_Size() int {
	return xxx_messageInfo_AccessMode.Size(m)
}
func (m *AccessMode) XXX_DiscardUnknown() {
	xxx_messageInfo_AccessMode.DiscardUnknown(m)
}

var xxx_messageInfo_AccessMode proto.InternalMessageInfo

func (m *AccessMode) GetWant() string {
	if m != nil {
		return m.Want
	}
	return ""
}

func (m *AccessMode) GetGiven() string {
	if m != nil {
		return m.Given
	}
	return ""
}

// SetSub: payload in set.sub request to update current subscription or invite another user, {sub.what} == "sub"
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:"-"`
}

func (m *SetSub) Reset()         { *m = SetSub{} }
func (m *SetSub) String() string { return proto.CompactTextString(m) }
func (*SetSub) ProtoMessage()    {}
func (*SetSub) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{3}
}
func (m *SetSub) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetSub.Unmarshal(m, b)
}
func (m *SetSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetSub.Marshal(b, m, deterministic)
}
func (dst *SetSub) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetSub.Merge(dst, src)
}
func (m *SetSub) XXX_Size() int {
	return xxx_messageInfo_SetSub.Size(m)
}
func (m *SetSub) XXX_DiscardUnknown() {
	xxx_messageInfo_SetSub.DiscardUnknown(m)
}

var xxx_messageInfo_SetSub proto.InternalMessageInfo

func (m *SetSub) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *SetSub) GetMode() string {
	if m != nil {
		return m.Mode
	}
	return ""
}

// SetDesc: C2S in set.what == "desc" and sub.init message
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:"-"`
}

func (m *SetDesc) Reset()         { *m = SetDesc{} }
func (m *SetDesc) String() string { return proto.CompactTextString(m) }
func (*SetDesc) ProtoMessage()    {}
func (*SetDesc) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{4}
}
func (m *SetDesc) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetDesc.Unmarshal(m, b)
}
func (m *SetDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetDesc.Marshal(b, m, deterministic)
}
func (dst *SetDesc) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetDesc.Merge(dst, src)
}
func (m *SetDesc) XXX_Size() int {
	return xxx_messageInfo_SetDesc.Size(m)
}
func (m *SetDesc) XXX_DiscardUnknown() {
	xxx_messageInfo_SetDesc.DiscardUnknown(m)
}

var xxx_messageInfo_SetDesc proto.InternalMessageInfo

func (m *SetDesc) GetDefaultAcs() *DefaultAcsMode {
	if m != nil {
		return m.DefaultAcs
	}
	return nil
}

func (m *SetDesc) GetPublic() []byte {
	if m != nil {
		return m.Public
	}
	return nil
}

func (m *SetDesc) GetPrivate() []byte {
	if m != nil {
		return m.Private
	}
	return nil
}

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 (m *GetOpts) Reset()         { *m = GetOpts{} }
func (m *GetOpts) String() string { return proto.CompactTextString(m) }
func (*GetOpts) ProtoMessage()    {}
func (*GetOpts) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{5}
}
func (m *GetOpts) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetOpts.Unmarshal(m, b)
}
func (m *GetOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetOpts.Marshal(b, m, deterministic)
}
func (dst *GetOpts) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetOpts.Merge(dst, src)
}
func (m *GetOpts) XXX_Size() int {
	return xxx_messageInfo_GetOpts.Size(m)
}
func (m *GetOpts) XXX_DiscardUnknown() {
	xxx_messageInfo_GetOpts.DiscardUnknown(m)
}

var xxx_messageInfo_GetOpts proto.InternalMessageInfo

func (m *GetOpts) GetIfModifiedSince() int64 {
	if m != nil {
		return m.IfModifiedSince
	}
	return 0
}

func (m *GetOpts) GetUser() string {
	if m != nil {
		return m.User
	}
	return ""
}

func (m *GetOpts) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *GetOpts) GetSinceId() int32 {
	if m != nil {
		return m.SinceId
	}
	return 0
}

func (m *GetOpts) GetBeforeId() int32 {
	if m != nil {
		return m.BeforeId
	}
	return 0
}

func (m *GetOpts) GetLimit() int32 {
	if m != nil {
		return m.Limit
	}
	return 0
}

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 (m *GetQuery) Reset()         { *m = GetQuery{} }
func (m *GetQuery) String() string { return proto.CompactTextString(m) }
func (*GetQuery) ProtoMessage()    {}
func (*GetQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{6}
}
func (m *GetQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetQuery.Unmarshal(m, b)
}
func (m *GetQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetQuery.Marshal(b, m, deterministic)
}
func (dst *GetQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetQuery.Merge(dst, src)
}
func (m *GetQuery) XXX_Size() int {
	return xxx_messageInfo_GetQuery.Size(m)
}
func (m *GetQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_GetQuery.DiscardUnknown(m)
}

var xxx_messageInfo_GetQuery proto.InternalMessageInfo

func (m *GetQuery) GetWhat() string {
	if m != nil {
		return m.What
	}
	return ""
}

func (m *GetQuery) GetDesc() *GetOpts {
	if m != nil {
		return m.Desc
	}
	return nil
}

func (m *GetQuery) GetSub() *GetOpts {
	if m != nil {
		return m.Sub
	}
	return nil
}

func (m *GetQuery) GetData() *GetOpts {
	if m != nil {
		return m.Data
	}
	return nil
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetQuery) Reset()         { *m = SetQuery{} }
func (m *SetQuery) String() string { return proto.CompactTextString(m) }
func (*SetQuery) ProtoMessage()    {}
func (*SetQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{7}
}
func (m *SetQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetQuery.Unmarshal(m, b)
}
func (m *SetQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetQuery.Marshal(b, m, deterministic)
}
func (dst *SetQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetQuery.Merge(dst, src)
}
func (m *SetQuery) XXX_Size() int {
	return xxx_messageInfo_SetQuery.Size(m)
}
func (m *SetQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_SetQuery.DiscardUnknown(m)
}

var xxx_messageInfo_SetQuery proto.InternalMessageInfo

func (m *SetQuery) GetDesc() *SetDesc {
	if m != nil {
		return m.Desc
	}
	return nil
}

func (m *SetQuery) GetSub() *SetSub {
	if m != nil {
		return m.Sub
	}
	return nil
}

func (m *SetQuery) GetTags() []string {
	if m != nil {
		return m.Tags
	}
	return nil
}

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 (m *SeqRange) Reset()         { *m = SeqRange{} }
func (m *SeqRange) String() string { return proto.CompactTextString(m) }
func (*SeqRange) ProtoMessage()    {}
func (*SeqRange) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{8}
}
func (m *SeqRange) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SeqRange.Unmarshal(m, b)
}
func (m *SeqRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SeqRange.Marshal(b, m, deterministic)
}
func (dst *SeqRange) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SeqRange.Merge(dst, src)
}
func (m *SeqRange) XXX_Size() int {
	return xxx_messageInfo_SeqRange.Size(m)
}
func (m *SeqRange) XXX_DiscardUnknown() {
	xxx_messageInfo_SeqRange.DiscardUnknown(m)
}

var xxx_messageInfo_SeqRange proto.InternalMessageInfo

func (m *SeqRange) GetLow() int32 {
	if m != nil {
		return m.Low
	}
	return 0
}

func (m *SeqRange) GetHi() int32 {
	if m != nil {
		return m.Hi
	}
	return 0
}

type Credential 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:"-"`
}

func (m *Credential) Reset()         { *m = Credential{} }
func (m *Credential) String() string { return proto.CompactTextString(m) }
func (*Credential) ProtoMessage()    {}
func (*Credential) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{9}
}
func (m *Credential) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Credential.Unmarshal(m, b)
}
func (m *Credential) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Credential.Marshal(b, m, deterministic)
}
func (dst *Credential) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Credential.Merge(dst, src)
}
func (m *Credential) XXX_Size() int {
	return xxx_messageInfo_Credential.Size(m)
}
func (m *Credential) XXX_DiscardUnknown() {
	xxx_messageInfo_Credential.DiscardUnknown(m)
}

var xxx_messageInfo_Credential proto.InternalMessageInfo

func (m *Credential) GetMethod() string {
	if m != nil {
		return m.Method
	}
	return ""
}

func (m *Credential) GetValue() string {
	if m != nil {
		return m.Value
	}
	return ""
}

func (m *Credential) GetResponse() string {
	if m != nil {
		return m.Response
	}
	return ""
}

func (m *Credential) GetParams() []byte {
	if m != nil {
		return m.Params
	}
	return nil
}

// Client handshake
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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ClientHi) Reset()         { *m = ClientHi{} }
func (m *ClientHi) String() string { return proto.CompactTextString(m) }
func (*ClientHi) ProtoMessage()    {}
func (*ClientHi) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{10}
}
func (m *ClientHi) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientHi.Unmarshal(m, b)
}
func (m *ClientHi) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientHi.Marshal(b, m, deterministic)
}
func (dst *ClientHi) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientHi.Merge(dst, src)
}
func (m *ClientHi) XXX_Size() int {
	return xxx_messageInfo_ClientHi.Size(m)
}
func (m *ClientHi) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientHi.DiscardUnknown(m)
}

var xxx_messageInfo_ClientHi proto.InternalMessageInfo

func (m *ClientHi) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientHi) GetUserAgent() string {
	if m != nil {
		return m.UserAgent
	}
	return ""
}

func (m *ClientHi) GetVer() string {
	if m != nil {
		return m.Ver
	}
	return ""
}

func (m *ClientHi) GetDeviceId() string {
	if m != nil {
		return m.DeviceId
	}
	return ""
}

func (m *ClientHi) GetLang() string {
	if m != nil {
		return m.Lang
	}
	return ""
}

// User creation message {acc}
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                 []*Credential `protobuf:"bytes,8,rep,name=cred" json:"cred,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (m *ClientAcc) Reset()         { *m = ClientAcc{} }
func (m *ClientAcc) String() string { return proto.CompactTextString(m) }
func (*ClientAcc) ProtoMessage()    {}
func (*ClientAcc) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{11}
}
func (m *ClientAcc) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientAcc.Unmarshal(m, b)
}
func (m *ClientAcc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientAcc.Marshal(b, m, deterministic)
}
func (dst *ClientAcc) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientAcc.Merge(dst, src)
}
func (m *ClientAcc) XXX_Size() int {
	return xxx_messageInfo_ClientAcc.Size(m)
}
func (m *ClientAcc) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientAcc.DiscardUnknown(m)
}

var xxx_messageInfo_ClientAcc proto.InternalMessageInfo

func (m *ClientAcc) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientAcc) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *ClientAcc) GetScheme() string {
	if m != nil {
		return m.Scheme
	}
	return ""
}

func (m *ClientAcc) GetSecret() []byte {
	if m != nil {
		return m.Secret
	}
	return nil
}

func (m *ClientAcc) GetLogin() bool {
	if m != nil {
		return m.Login
	}
	return false
}

func (m *ClientAcc) GetTags() []string {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *ClientAcc) GetDesc() *SetDesc {
	if m != nil {
		return m.Desc
	}
	return nil
}

func (m *ClientAcc) GetCred() []*Credential {
	if m != nil {
		return m.Cred
	}
	return nil
}

// Login {login} message
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                 []*Credential `protobuf:"bytes,4,rep,name=cred" json:"cred,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (m *ClientLogin) Reset()         { *m = ClientLogin{} }
func (m *ClientLogin) String() string { return proto.CompactTextString(m) }
func (*ClientLogin) ProtoMessage()    {}
func (*ClientLogin) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{12}
}
func (m *ClientLogin) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientLogin.Unmarshal(m, b)
}
func (m *ClientLogin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientLogin.Marshal(b, m, deterministic)
}
func (dst *ClientLogin) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientLogin.Merge(dst, src)
}
func (m *ClientLogin) XXX_Size() int {
	return xxx_messageInfo_ClientLogin.Size(m)
}
func (m *ClientLogin) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientLogin.DiscardUnknown(m)
}

var xxx_messageInfo_ClientLogin proto.InternalMessageInfo

func (m *ClientLogin) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientLogin) GetScheme() string {
	if m != nil {
		return m.Scheme
	}
	return ""
}

func (m *ClientLogin) GetSecret() []byte {
	if m != nil {
		return m.Secret
	}
	return nil
}

func (m *ClientLogin) GetCred() []*Credential {
	if m != nil {
		return m.Cred
	}
	return nil
}

// Subscription request {sub} message
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:"-"`
}

func (m *ClientSub) Reset()         { *m = ClientSub{} }
func (m *ClientSub) String() string { return proto.CompactTextString(m) }
func (*ClientSub) ProtoMessage()    {}
func (*ClientSub) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{13}
}
func (m *ClientSub) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientSub.Unmarshal(m, b)
}
func (m *ClientSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientSub.Marshal(b, m, deterministic)
}
func (dst *ClientSub) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientSub.Merge(dst, src)
}
func (m *ClientSub) XXX_Size() int {
	return xxx_messageInfo_ClientSub.Size(m)
}
func (m *ClientSub) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientSub.DiscardUnknown(m)
}

var xxx_messageInfo_ClientSub proto.InternalMessageInfo

func (m *ClientSub) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientSub) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientSub) GetSetQuery() *SetQuery {
	if m != nil {
		return m.SetQuery
	}
	return nil
}

func (m *ClientSub) GetGetQuery() *GetQuery {
	if m != nil {
		return m.GetQuery
	}
	return nil
}

// Unsubscribe {leave} request message
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:"-"`
}

func (m *ClientLeave) Reset()         { *m = ClientLeave{} }
func (m *ClientLeave) String() string { return proto.CompactTextString(m) }
func (*ClientLeave) ProtoMessage()    {}
func (*ClientLeave) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{14}
}
func (m *ClientLeave) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientLeave.Unmarshal(m, b)
}
func (m *ClientLeave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientLeave.Marshal(b, m, deterministic)
}
func (dst *ClientLeave) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientLeave.Merge(dst, src)
}
func (m *ClientLeave) XXX_Size() int {
	return xxx_messageInfo_ClientLeave.Size(m)
}
func (m *ClientLeave) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientLeave.DiscardUnknown(m)
}

var xxx_messageInfo_ClientLeave proto.InternalMessageInfo

func (m *ClientLeave) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientLeave) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientLeave) GetUnsub() bool {
	if m != nil {
		return m.Unsub
	}
	return false
}

// ClientPub is client's request to publish data to topic subscribers {pub}
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:"-"`
}

func (m *ClientPub) Reset()         { *m = ClientPub{} }
func (m *ClientPub) String() string { return proto.CompactTextString(m) }
func (*ClientPub) ProtoMessage()    {}
func (*ClientPub) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{15}
}
func (m *ClientPub) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientPub.Unmarshal(m, b)
}
func (m *ClientPub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientPub.Marshal(b, m, deterministic)
}
func (dst *ClientPub) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientPub.Merge(dst, src)
}
func (m *ClientPub) XXX_Size() int {
	return xxx_messageInfo_ClientPub.Size(m)
}
func (m *ClientPub) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientPub.DiscardUnknown(m)
}

var xxx_messageInfo_ClientPub proto.InternalMessageInfo

func (m *ClientPub) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientPub) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientPub) GetNoEcho() bool {
	if m != nil {
		return m.NoEcho
	}
	return false
}

func (m *ClientPub) GetHead() map[string][]byte {
	if m != nil {
		return m.Head
	}
	return nil
}

func (m *ClientPub) GetContent() []byte {
	if m != nil {
		return m.Content
	}
	return nil
}

// Query topic state {get}
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:"-"`
}

func (m *ClientGet) Reset()         { *m = ClientGet{} }
func (m *ClientGet) String() string { return proto.CompactTextString(m) }
func (*ClientGet) ProtoMessage()    {}
func (*ClientGet) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{16}
}
func (m *ClientGet) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientGet.Unmarshal(m, b)
}
func (m *ClientGet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientGet.Marshal(b, m, deterministic)
}
func (dst *ClientGet) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientGet.Merge(dst, src)
}
func (m *ClientGet) XXX_Size() int {
	return xxx_messageInfo_ClientGet.Size(m)
}
func (m *ClientGet) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientGet.DiscardUnknown(m)
}

var xxx_messageInfo_ClientGet proto.InternalMessageInfo

func (m *ClientGet) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientGet) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientGet) GetQuery() *GetQuery {
	if m != nil {
		return m.Query
	}
	return nil
}

// Update topic state {set}
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:"-"`
}

func (m *ClientSet) Reset()         { *m = ClientSet{} }
func (m *ClientSet) String() string { return proto.CompactTextString(m) }
func (*ClientSet) ProtoMessage()    {}
func (*ClientSet) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{17}
}
func (m *ClientSet) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientSet.Unmarshal(m, b)
}
func (m *ClientSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientSet.Marshal(b, m, deterministic)
}
func (dst *ClientSet) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientSet.Merge(dst, src)
}
func (m *ClientSet) XXX_Size() int {
	return xxx_messageInfo_ClientSet.Size(m)
}
func (m *ClientSet) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientSet.DiscardUnknown(m)
}

var xxx_messageInfo_ClientSet proto.InternalMessageInfo

func (m *ClientSet) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientSet) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientSet) GetQuery() *SetQuery {
	if m != nil {
		return m.Query
	}
	return nil
}

// ClientDel delete messages or topic
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"`
	// Request to hard-delete messages for all users, if such option is available.
	Hard                 bool     `protobuf:"varint,6,opt,name=hard" json:"hard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ClientDel) Reset()         { *m = ClientDel{} }
func (m *ClientDel) String() string { return proto.CompactTextString(m) }
func (*ClientDel) ProtoMessage()    {}
func (*ClientDel) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{18}
}
func (m *ClientDel) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientDel.Unmarshal(m, b)
}
func (m *ClientDel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientDel.Marshal(b, m, deterministic)
}
func (dst *ClientDel) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientDel.Merge(dst, src)
}
func (m *ClientDel) XXX_Size() int {
	return xxx_messageInfo_ClientDel.Size(m)
}
func (m *ClientDel) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientDel.DiscardUnknown(m)
}

var xxx_messageInfo_ClientDel proto.InternalMessageInfo

func (m *ClientDel) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ClientDel) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientDel) GetWhat() ClientDel_What {
	if m != nil {
		return m.What
	}
	return ClientDel_MSG
}

func (m *ClientDel) GetDelSeq() []*SeqRange {
	if m != nil {
		return m.DelSeq
	}
	return nil
}

func (m *ClientDel) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *ClientDel) GetHard() bool {
	if m != nil {
		return m.Hard
	}
	return false
}

// ClientNote is a client-generated notification for topic subscribers
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:"-"`
}

func (m *ClientNote) Reset()         { *m = ClientNote{} }
func (m *ClientNote) String() string { return proto.CompactTextString(m) }
func (*ClientNote) ProtoMessage()    {}
func (*ClientNote) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{19}
}
func (m *ClientNote) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientNote.Unmarshal(m, b)
}
func (m *ClientNote) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientNote.Marshal(b, m, deterministic)
}
func (dst *ClientNote) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientNote.Merge(dst, src)
}
func (m *ClientNote) XXX_Size() int {
	return xxx_messageInfo_ClientNote.Size(m)
}
func (m *ClientNote) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientNote.DiscardUnknown(m)
}

var xxx_messageInfo_ClientNote proto.InternalMessageInfo

func (m *ClientNote) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ClientNote) GetWhat() InfoNote {
	if m != nil {
		return m.What
	}
	return InfoNote_READ
}

func (m *ClientNote) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *ClientMsg) Reset()         { *m = ClientMsg{} }
func (m *ClientMsg) String() string { return proto.CompactTextString(m) }
func (*ClientMsg) ProtoMessage()    {}
func (*ClientMsg) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{20}
}
func (m *ClientMsg) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientMsg.Unmarshal(m, b)
}
func (m *ClientMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientMsg.Marshal(b, m, deterministic)
}
func (dst *ClientMsg) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientMsg.Merge(dst, src)
}
func (m *ClientMsg) XXX_Size() int {
	return xxx_messageInfo_ClientMsg.Size(m)
}
func (m *ClientMsg) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientMsg.DiscardUnknown(m)
}

var xxx_messageInfo_ClientMsg proto.InternalMessageInfo

type isClientMsg_Message interface {
	isClientMsg_Message()
}

type ClientMsg_Hi struct {
	Hi *ClientHi `protobuf:"bytes,1,opt,name=hi,oneof"`
}
type ClientMsg_Acc struct {
	Acc *ClientAcc `protobuf:"bytes,2,opt,name=acc,oneof"`
}
type ClientMsg_Login struct {
	Login *ClientLogin `protobuf:"bytes,3,opt,name=login,oneof"`
}
type ClientMsg_Sub struct {
	Sub *ClientSub `protobuf:"bytes,4,opt,name=sub,oneof"`
}
type ClientMsg_Leave struct {
	Leave *ClientLeave `protobuf:"bytes,5,opt,name=leave,oneof"`
}
type ClientMsg_Pub struct {
	Pub *ClientPub `protobuf:"bytes,6,opt,name=pub,oneof"`
}
type ClientMsg_Get struct {
	Get *ClientGet `protobuf:"bytes,7,opt,name=get,oneof"`
}
type ClientMsg_Set struct {
	Set *ClientSet `protobuf:"bytes,8,opt,name=set,oneof"`
}
type ClientMsg_Del struct {
	Del *ClientDel `protobuf:"bytes,9,opt,name=del,oneof"`
}
type ClientMsg_Note struct {
	Note *ClientNote `protobuf:"bytes,10,opt,name=note,oneof"`
}

func (*ClientMsg_Hi) isClientMsg_Message()    {}
func (*ClientMsg_Acc) isClientMsg_Message()   {}
func (*ClientMsg_Login) isClientMsg_Message() {}
func (*ClientMsg_Sub) isClientMsg_Message()   {}
func (*ClientMsg_Leave) isClientMsg_Message() {}
func (*ClientMsg_Pub) isClientMsg_Message()   {}
func (*ClientMsg_Get) isClientMsg_Message()   {}
func (*ClientMsg_Set) isClientMsg_Message()   {}
func (*ClientMsg_Del) isClientMsg_Message()   {}
func (*ClientMsg_Note) isClientMsg_Message()  {}

func (m *ClientMsg) GetMessage() isClientMsg_Message {
	if m != nil {
		return m.Message
	}
	return nil
}

func (m *ClientMsg) GetHi() *ClientHi {
	if x, ok := m.GetMessage().(*ClientMsg_Hi); ok {
		return x.Hi
	}
	return nil
}

func (m *ClientMsg) GetAcc() *ClientAcc {
	if x, ok := m.GetMessage().(*ClientMsg_Acc); ok {
		return x.Acc
	}
	return nil
}

func (m *ClientMsg) GetLogin() *ClientLogin {
	if x, ok := m.GetMessage().(*ClientMsg_Login); ok {
		return x.Login
	}
	return nil
}

func (m *ClientMsg) GetSub() *ClientSub {
	if x, ok := m.GetMessage().(*ClientMsg_Sub); ok {
		return x.Sub
	}
	return nil
}

func (m *ClientMsg) GetLeave() *ClientLeave {
	if x, ok := m.GetMessage().(*ClientMsg_Leave); ok {
		return x.Leave
	}
	return nil
}

func (m *ClientMsg) GetPub() *ClientPub {
	if x, ok := m.GetMessage().(*ClientMsg_Pub); ok {
		return x.Pub
	}
	return nil
}

func (m *ClientMsg) GetGet() *ClientGet {
	if x, ok := m.GetMessage().(*ClientMsg_Get); ok {
		return x.Get
	}
	return nil
}

func (m *ClientMsg) GetSet() *ClientSet {
	if x, ok := m.GetMessage().(*ClientMsg_Set); ok {
		return x.Set
	}
	return nil
}

func (m *ClientMsg) GetDel() *ClientDel {
	if x, ok := m.GetMessage().(*ClientMsg_Del); ok {
		return x.Del
	}
	return nil
}

func (m *ClientMsg) GetNote() *ClientNote {
	if x, ok := m.GetMessage().(*ClientMsg_Note); ok {
		return x.Note
	}
	return nil
}

// XXX_OneofFuncs is for the internal use of the proto package.
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{}) {
	return _ClientMsg_OneofMarshaler, _ClientMsg_OneofUnmarshaler, _ClientMsg_OneofSizer, []interface{}{
		(*ClientMsg_Hi)(nil),
		(*ClientMsg_Acc)(nil),
		(*ClientMsg_Login)(nil),
		(*ClientMsg_Sub)(nil),
		(*ClientMsg_Leave)(nil),
		(*ClientMsg_Pub)(nil),
		(*ClientMsg_Get)(nil),
		(*ClientMsg_Set)(nil),
		(*ClientMsg_Del)(nil),
		(*ClientMsg_Note)(nil),
	}
}

func _ClientMsg_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
	m := msg.(*ClientMsg)
	// Message
	switch x := m.Message.(type) {
	case *ClientMsg_Hi:
		b.EncodeVarint(1<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Hi); err != nil {
			return err
		}
	case *ClientMsg_Acc:
		b.EncodeVarint(2<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Acc); err != nil {
			return err
		}
	case *ClientMsg_Login:
		b.EncodeVarint(3<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Login); err != nil {
			return err
		}
	case *ClientMsg_Sub:
		b.EncodeVarint(4<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Sub); err != nil {
			return err
		}
	case *ClientMsg_Leave:
		b.EncodeVarint(5<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Leave); err != nil {
			return err
		}
	case *ClientMsg_Pub:
		b.EncodeVarint(6<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Pub); err != nil {
			return err
		}
	case *ClientMsg_Get:
		b.EncodeVarint(7<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Get); err != nil {
			return err
		}
	case *ClientMsg_Set:
		b.EncodeVarint(8<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Set); err != nil {
			return err
		}
	case *ClientMsg_Del:
		b.EncodeVarint(9<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Del); err != nil {
			return err
		}
	case *ClientMsg_Note:
		b.EncodeVarint(10<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Note); err != nil {
			return err
		}
	case nil:
	default:
		return fmt.Errorf("ClientMsg.Message has unexpected type %T", x)
	}
	return nil
}

func _ClientMsg_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
	m := msg.(*ClientMsg)
	switch tag {
	case 1: // Message.hi
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientHi)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Hi{msg}
		return true, err
	case 2: // Message.acc
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientAcc)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Acc{msg}
		return true, err
	case 3: // Message.login
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientLogin)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Login{msg}
		return true, err
	case 4: // Message.sub
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientSub)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Sub{msg}
		return true, err
	case 5: // Message.leave
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientLeave)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Leave{msg}
		return true, err
	case 6: // Message.pub
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientPub)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Pub{msg}
		return true, err
	case 7: // Message.get
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientGet)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Get{msg}
		return true, err
	case 8: // Message.set
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientSet)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Set{msg}
		return true, err
	case 9: // Message.del
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientDel)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Del{msg}
		return true, err
	case 10: // Message.note
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ClientNote)
		err := b.DecodeMessage(msg)
		m.Message = &ClientMsg_Note{msg}
		return true, err
	default:
		return false, nil
	}
}

func _ClientMsg_OneofSizer(msg proto.Message) (n int) {
	m := msg.(*ClientMsg)
	// Message
	switch x := m.Message.(type) {
	case *ClientMsg_Hi:
		s := proto.Size(x.Hi)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Acc:
		s := proto.Size(x.Acc)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Login:
		s := proto.Size(x.Login)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Sub:
		s := proto.Size(x.Sub)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Leave:
		s := proto.Size(x.Leave)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Pub:
		s := proto.Size(x.Pub)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Get:
		s := proto.Size(x.Get)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Set:
		s := proto.Size(x.Set)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Del:
		s := proto.Size(x.Del)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ClientMsg_Note:
		s := proto.Size(x.Note)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case nil:
	default:
		panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
	}
	return n
}

// Topic description, S2C in Meta message
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:"-"`
}

func (m *TopicDesc) Reset()         { *m = TopicDesc{} }
func (m *TopicDesc) String() string { return proto.CompactTextString(m) }
func (*TopicDesc) ProtoMessage()    {}
func (*TopicDesc) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{21}
}
func (m *TopicDesc) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_TopicDesc.Unmarshal(m, b)
}
func (m *TopicDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_TopicDesc.Marshal(b, m, deterministic)
}
func (dst *TopicDesc) XXX_Merge(src proto.Message) {
	xxx_messageInfo_TopicDesc.Merge(dst, src)
}
func (m *TopicDesc) XXX_Size() int {
	return xxx_messageInfo_TopicDesc.Size(m)
}
func (m *TopicDesc) XXX_DiscardUnknown() {
	xxx_messageInfo_TopicDesc.DiscardUnknown(m)
}

var xxx_messageInfo_TopicDesc proto.InternalMessageInfo

func (m *TopicDesc) GetCreatedAt() int64 {
	if m != nil {
		return m.CreatedAt
	}
	return 0
}

func (m *TopicDesc) GetUpdatedAt() int64 {
	if m != nil {
		return m.UpdatedAt
	}
	return 0
}

func (m *TopicDesc) GetTouchedAt() int64 {
	if m != nil {
		return m.TouchedAt
	}
	return 0
}

func (m *TopicDesc) GetDefacs() *DefaultAcsMode {
	if m != nil {
		return m.Defacs
	}
	return nil
}

func (m *TopicDesc) GetAcs() *AccessMode {
	if m != nil {
		return m.Acs
	}
	return nil
}

func (m *TopicDesc) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

func (m *TopicDesc) GetReadId() int32 {
	if m != nil {
		return m.ReadId
	}
	return 0
}

func (m *TopicDesc) GetRecvId() int32 {
	if m != nil {
		return m.RecvId
	}
	return 0
}

func (m *TopicDesc) GetDelId() int32 {
	if m != nil {
		return m.DelId
	}
	return 0
}

func (m *TopicDesc) GetPublic() []byte {
	if m != nil {
		return m.Public
	}
	return nil
}

func (m *TopicDesc) GetPrivate() []byte {
	if m != nil {
		return m.Private
	}
	return nil
}

// MsgTopicSub: topic subscription details, sent in Meta message
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:"-"`
}

func (m *TopicSub) Reset()         { *m = TopicSub{} }
func (m *TopicSub) String() string { return proto.CompactTextString(m) }
func (*TopicSub) ProtoMessage()    {}
func (*TopicSub) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{22}
}
func (m *TopicSub) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_TopicSub.Unmarshal(m, b)
}
func (m *TopicSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_TopicSub.Marshal(b, m, deterministic)
}
func (dst *TopicSub) XXX_Merge(src proto.Message) {
	xxx_messageInfo_TopicSub.Merge(dst, src)
}
func (m *TopicSub) XXX_Size() int {
	return xxx_messageInfo_TopicSub.Size(m)
}
func (m *TopicSub) XXX_DiscardUnknown() {
	xxx_messageInfo_TopicSub.DiscardUnknown(m)
}

var xxx_messageInfo_TopicSub proto.InternalMessageInfo

func (m *TopicSub) GetUpdatedAt() int64 {
	if m != nil {
		return m.UpdatedAt
	}
	return 0
}

func (m *TopicSub) GetDeletedAt() int64 {
	if m != nil {
		return m.DeletedAt
	}
	return 0
}

func (m *TopicSub) GetOnline() bool {
	if m != nil {
		return m.Online
	}
	return false
}

func (m *TopicSub) GetAcs() *AccessMode {
	if m != nil {
		return m.Acs
	}
	return nil
}

func (m *TopicSub) GetReadId() int32 {
	if m != nil {
		return m.ReadId
	}
	return 0
}

func (m *TopicSub) GetRecvId() int32 {
	if m != nil {
		return m.RecvId
	}
	return 0
}

func (m *TopicSub) GetPublic() []byte {
	if m != nil {
		return m.Public
	}
	return nil
}

func (m *TopicSub) GetPrivate() []byte {
	if m != nil {
		return m.Private
	}
	return nil
}

func (m *TopicSub) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *TopicSub) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *TopicSub) GetTouchedAt() int64 {
	if m != nil {
		return m.TouchedAt
	}
	return 0
}

func (m *TopicSub) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

func (m *TopicSub) GetDelId() int32 {
	if m != nil {
		return m.DelId
	}
	return 0
}

func (m *TopicSub) GetLastSeenTime() int64 {
	if m != nil {
		return m.LastSeenTime
	}
	return 0
}

func (m *TopicSub) GetLastSeenUserAgent() string {
	if m != nil {
		return m.LastSeenUserAgent
	}
	return ""
}

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 (m *DelValues) Reset()         { *m = DelValues{} }
func (m *DelValues) String() string { return proto.CompactTextString(m) }
func (*DelValues) ProtoMessage()    {}
func (*DelValues) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{23}
}
func (m *DelValues) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DelValues.Unmarshal(m, b)
}
func (m *DelValues) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DelValues.Marshal(b, m, deterministic)
}
func (dst *DelValues) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DelValues.Merge(dst, src)
}
func (m *DelValues) XXX_Size() int {
	return xxx_messageInfo_DelValues.Size(m)
}
func (m *DelValues) XXX_DiscardUnknown() {
	xxx_messageInfo_DelValues.DiscardUnknown(m)
}

var xxx_messageInfo_DelValues proto.InternalMessageInfo

func (m *DelValues) GetDelId() int32 {
	if m != nil {
		return m.DelId
	}
	return 0
}

func (m *DelValues) GetDelSeq() []*SeqRange {
	if m != nil {
		return m.DelSeq
	}
	return nil
}

// {ctrl} message
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:"-"`
}

func (m *ServerCtrl) Reset()         { *m = ServerCtrl{} }
func (m *ServerCtrl) String() string { return proto.CompactTextString(m) }
func (*ServerCtrl) ProtoMessage()    {}
func (*ServerCtrl) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{24}
}
func (m *ServerCtrl) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerCtrl.Unmarshal(m, b)
}
func (m *ServerCtrl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerCtrl.Marshal(b, m, deterministic)
}
func (dst *ServerCtrl) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerCtrl.Merge(dst, src)
}
func (m *ServerCtrl) XXX_Size() int {
	return xxx_messageInfo_ServerCtrl.Size(m)
}
func (m *ServerCtrl) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerCtrl.DiscardUnknown(m)
}

var xxx_messageInfo_ServerCtrl proto.InternalMessageInfo

func (m *ServerCtrl) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ServerCtrl) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ServerCtrl) GetCode() int32 {
	if m != nil {
		return m.Code
	}
	return 0
}

func (m *ServerCtrl) GetText() string {
	if m != nil {
		return m.Text
	}
	return ""
}

func (m *ServerCtrl) GetParams() map[string][]byte {
	if m != nil {
		return m.Params
	}
	return nil
}

// {data} message
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 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:"-"`
}

func (m *ServerData) Reset()         { *m = ServerData{} }
func (m *ServerData) String() string { return proto.CompactTextString(m) }
func (*ServerData) ProtoMessage()    {}
func (*ServerData) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{25}
}
func (m *ServerData) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerData.Unmarshal(m, b)
}
func (m *ServerData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerData.Marshal(b, m, deterministic)
}
func (dst *ServerData) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerData.Merge(dst, src)
}
func (m *ServerData) XXX_Size() int {
	return xxx_messageInfo_ServerData.Size(m)
}
func (m *ServerData) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerData.DiscardUnknown(m)
}

var xxx_messageInfo_ServerData proto.InternalMessageInfo

func (m *ServerData) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ServerData) GetFromUserId() string {
	if m != nil {
		return m.FromUserId
	}
	return ""
}

func (m *ServerData) GetDeletedAt() int64 {
	if m != nil {
		return m.DeletedAt
	}
	return 0
}

func (m *ServerData) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

func (m *ServerData) GetHead() map[string][]byte {
	if m != nil {
		return m.Head
	}
	return nil
}

func (m *ServerData) GetContent() []byte {
	if m != nil {
		return m.Content
	}
	return nil
}

// {pres} message
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:"-"`
}

func (m *ServerPres) Reset()         { *m = ServerPres{} }
func (m *ServerPres) String() string { return proto.CompactTextString(m) }
func (*ServerPres) ProtoMessage()    {}
func (*ServerPres) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{26}
}
func (m *ServerPres) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerPres.Unmarshal(m, b)
}
func (m *ServerPres) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerPres.Marshal(b, m, deterministic)
}
func (dst *ServerPres) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerPres.Merge(dst, src)
}
func (m *ServerPres) XXX_Size() int {
	return xxx_messageInfo_ServerPres.Size(m)
}
func (m *ServerPres) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerPres.DiscardUnknown(m)
}

var xxx_messageInfo_ServerPres proto.InternalMessageInfo

func (m *ServerPres) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ServerPres) GetSrc() string {
	if m != nil {
		return m.Src
	}
	return ""
}

func (m *ServerPres) GetWhat() ServerPres_What {
	if m != nil {
		return m.What
	}
	return ServerPres_ON
}

func (m *ServerPres) GetUserAgent() string {
	if m != nil {
		return m.UserAgent
	}
	return ""
}

func (m *ServerPres) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

func (m *ServerPres) GetDelId() int32 {
	if m != nil {
		return m.DelId
	}
	return 0
}

func (m *ServerPres) GetDelSeq() []*SeqRange {
	if m != nil {
		return m.DelSeq
	}
	return nil
}

func (m *ServerPres) GetTargetUserId() string {
	if m != nil {
		return m.TargetUserId
	}
	return ""
}

func (m *ServerPres) GetActorUserId() string {
	if m != nil {
		return m.ActorUserId
	}
	return ""
}

func (m *ServerPres) GetAcs() *AccessMode {
	if m != nil {
		return m.Acs
	}
	return nil
}

// {meta} message
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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (m *ServerMeta) Reset()         { *m = ServerMeta{} }
func (m *ServerMeta) String() string { return proto.CompactTextString(m) }
func (*ServerMeta) ProtoMessage()    {}
func (*ServerMeta) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{27}
}
func (m *ServerMeta) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerMeta.Unmarshal(m, b)
}
func (m *ServerMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerMeta.Marshal(b, m, deterministic)
}
func (dst *ServerMeta) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerMeta.Merge(dst, src)
}
func (m *ServerMeta) XXX_Size() int {
	return xxx_messageInfo_ServerMeta.Size(m)
}
func (m *ServerMeta) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerMeta.DiscardUnknown(m)
}

var xxx_messageInfo_ServerMeta proto.InternalMessageInfo

func (m *ServerMeta) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *ServerMeta) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ServerMeta) GetDesc() *TopicDesc {
	if m != nil {
		return m.Desc
	}
	return nil
}

func (m *ServerMeta) GetSub() []*TopicSub {
	if m != nil {
		return m.Sub
	}
	return nil
}

func (m *ServerMeta) GetDel() *DelValues {
	if m != nil {
		return m.Del
	}
	return nil
}

// {info} message: server-side copy of ClientNote with From added
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:"-"`
}

func (m *ServerInfo) Reset()         { *m = ServerInfo{} }
func (m *ServerInfo) String() string { return proto.CompactTextString(m) }
func (*ServerInfo) ProtoMessage()    {}
func (*ServerInfo) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{28}
}
func (m *ServerInfo) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerInfo.Unmarshal(m, b)
}
func (m *ServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerInfo.Marshal(b, m, deterministic)
}
func (dst *ServerInfo) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerInfo.Merge(dst, src)
}
func (m *ServerInfo) XXX_Size() int {
	return xxx_messageInfo_ServerInfo.Size(m)
}
func (m *ServerInfo) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerInfo.DiscardUnknown(m)
}

var xxx_messageInfo_ServerInfo proto.InternalMessageInfo

func (m *ServerInfo) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *ServerInfo) GetFromUserId() string {
	if m != nil {
		return m.FromUserId
	}
	return ""
}

func (m *ServerInfo) GetWhat() InfoNote {
	if m != nil {
		return m.What
	}
	return InfoNote_READ
}

func (m *ServerInfo) GetSeqId() int32 {
	if m != nil {
		return m.SeqId
	}
	return 0
}

// Cumulative message
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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *ServerMsg) Reset()         { *m = ServerMsg{} }
func (m *ServerMsg) String() string { return proto.CompactTextString(m) }
func (*ServerMsg) ProtoMessage()    {}
func (*ServerMsg) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{29}
}
func (m *ServerMsg) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerMsg.Unmarshal(m, b)
}
func (m *ServerMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerMsg.Marshal(b, m, deterministic)
}
func (dst *ServerMsg) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerMsg.Merge(dst, src)
}
func (m *ServerMsg) XXX_Size() int {
	return xxx_messageInfo_ServerMsg.Size(m)
}
func (m *ServerMsg) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerMsg.DiscardUnknown(m)
}

var xxx_messageInfo_ServerMsg proto.InternalMessageInfo

type isServerMsg_Message interface {
	isServerMsg_Message()
}

type ServerMsg_Ctrl struct {
	Ctrl *ServerCtrl `protobuf:"bytes,1,opt,name=ctrl,oneof"`
}
type ServerMsg_Data struct {
	Data *ServerData `protobuf:"bytes,2,opt,name=data,oneof"`
}
type ServerMsg_Pres struct {
	Pres *ServerPres `protobuf:"bytes,3,opt,name=pres,oneof"`
}
type ServerMsg_Meta struct {
	Meta *ServerMeta `protobuf:"bytes,4,opt,name=meta,oneof"`
}
type ServerMsg_Info struct {
	Info *ServerInfo `protobuf:"bytes,5,opt,name=info,oneof"`
}

func (*ServerMsg_Ctrl) isServerMsg_Message() {}
func (*ServerMsg_Data) isServerMsg_Message() {}
func (*ServerMsg_Pres) isServerMsg_Message() {}
func (*ServerMsg_Meta) isServerMsg_Message() {}
func (*ServerMsg_Info) isServerMsg_Message() {}

func (m *ServerMsg) GetMessage() isServerMsg_Message {
	if m != nil {
		return m.Message
	}
	return nil
}

func (m *ServerMsg) GetCtrl() *ServerCtrl {
	if x, ok := m.GetMessage().(*ServerMsg_Ctrl); ok {
		return x.Ctrl
	}
	return nil
}

func (m *ServerMsg) GetData() *ServerData {
	if x, ok := m.GetMessage().(*ServerMsg_Data); ok {
		return x.Data
	}
	return nil
}

func (m *ServerMsg) GetPres() *ServerPres {
	if x, ok := m.GetMessage().(*ServerMsg_Pres); ok {
		return x.Pres
	}
	return nil
}

func (m *ServerMsg) GetMeta() *ServerMeta {
	if x, ok := m.GetMessage().(*ServerMsg_Meta); ok {
		return x.Meta
	}
	return nil
}

func (m *ServerMsg) GetInfo() *ServerInfo {
	if x, ok := m.GetMessage().(*ServerMsg_Info); ok {
		return x.Info
	}
	return nil
}

// XXX_OneofFuncs is for the internal use of the proto package.
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{}) {
	return _ServerMsg_OneofMarshaler, _ServerMsg_OneofUnmarshaler, _ServerMsg_OneofSizer, []interface{}{
		(*ServerMsg_Ctrl)(nil),
		(*ServerMsg_Data)(nil),
		(*ServerMsg_Pres)(nil),
		(*ServerMsg_Meta)(nil),
		(*ServerMsg_Info)(nil),
	}
}

func _ServerMsg_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
	m := msg.(*ServerMsg)
	// Message
	switch x := m.Message.(type) {
	case *ServerMsg_Ctrl:
		b.EncodeVarint(1<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Ctrl); err != nil {
			return err
		}
	case *ServerMsg_Data:
		b.EncodeVarint(2<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Data); err != nil {
			return err
		}
	case *ServerMsg_Pres:
		b.EncodeVarint(3<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Pres); err != nil {
			return err
		}
	case *ServerMsg_Meta:
		b.EncodeVarint(4<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Meta); err != nil {
			return err
		}
	case *ServerMsg_Info:
		b.EncodeVarint(5<<3 | proto.WireBytes)
		if err := b.EncodeMessage(x.Info); err != nil {
			return err
		}
	case nil:
	default:
		return fmt.Errorf("ServerMsg.Message has unexpected type %T", x)
	}
	return nil
}

func _ServerMsg_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
	m := msg.(*ServerMsg)
	switch tag {
	case 1: // Message.ctrl
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ServerCtrl)
		err := b.DecodeMessage(msg)
		m.Message = &ServerMsg_Ctrl{msg}
		return true, err
	case 2: // Message.data
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ServerData)
		err := b.DecodeMessage(msg)
		m.Message = &ServerMsg_Data{msg}
		return true, err
	case 3: // Message.pres
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ServerPres)
		err := b.DecodeMessage(msg)
		m.Message = &ServerMsg_Pres{msg}
		return true, err
	case 4: // Message.meta
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ServerMeta)
		err := b.DecodeMessage(msg)
		m.Message = &ServerMsg_Meta{msg}
		return true, err
	case 5: // Message.info
		if wire != proto.WireBytes {
			return true, proto.ErrInternalBadWireType
		}
		msg := new(ServerInfo)
		err := b.DecodeMessage(msg)
		m.Message = &ServerMsg_Info{msg}
		return true, err
	default:
		return false, nil
	}
}

func _ServerMsg_OneofSizer(msg proto.Message) (n int) {
	m := msg.(*ServerMsg)
	// Message
	switch x := m.Message.(type) {
	case *ServerMsg_Ctrl:
		s := proto.Size(x.Ctrl)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ServerMsg_Data:
		s := proto.Size(x.Data)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ServerMsg_Pres:
		s := proto.Size(x.Pres)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ServerMsg_Meta:
		s := proto.Size(x.Meta)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case *ServerMsg_Info:
		s := proto.Size(x.Info)
		n += 1 // tag and wire
		n += proto.SizeVarint(uint64(s))
		n += s
	case nil:
	default:
		panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
	}
	return n
}

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 (m *ServerResp) Reset()         { *m = ServerResp{} }
func (m *ServerResp) String() string { return proto.CompactTextString(m) }
func (*ServerResp) ProtoMessage()    {}
func (*ServerResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{30}
}
func (m *ServerResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ServerResp.Unmarshal(m, b)
}
func (m *ServerResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ServerResp.Marshal(b, m, deterministic)
}
func (dst *ServerResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ServerResp.Merge(dst, src)
}
func (m *ServerResp) XXX_Size() int {
	return xxx_messageInfo_ServerResp.Size(m)
}
func (m *ServerResp) XXX_DiscardUnknown() {
	xxx_messageInfo_ServerResp.DiscardUnknown(m)
}

var xxx_messageInfo_ServerResp proto.InternalMessageInfo

func (m *ServerResp) GetStatus() RespCode {
	if m != nil {
		return m.Status
	}
	return RespCode_CONTINUE
}

func (m *ServerResp) GetSrvmsg() *ServerMsg {
	if m != nil {
		return m.Srvmsg
	}
	return nil
}

func (m *ServerResp) GetClmsg() *ClientMsg {
	if m != nil {
		return m.Clmsg
	}
	return nil
}

// Context message
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            Session_AuthLevel `protobuf:"varint,3,opt,name=auth_level,json=authLevel,enum=pbx.Session_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:"-"`
}

func (m *Session) Reset()         { *m = Session{} }
func (m *Session) String() string { return proto.CompactTextString(m) }
func (*Session) ProtoMessage()    {}
func (*Session) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{31}
}
func (m *Session) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Session.Unmarshal(m, b)
}
func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Session.Marshal(b, m, deterministic)
}
func (dst *Session) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Session.Merge(dst, src)
}
func (m *Session) XXX_Size() int {
	return xxx_messageInfo_Session.Size(m)
}
func (m *Session) XXX_DiscardUnknown() {
	xxx_messageInfo_Session.DiscardUnknown(m)
}

var xxx_messageInfo_Session proto.InternalMessageInfo

func (m *Session) GetSessionId() string {
	if m != nil {
		return m.SessionId
	}
	return ""
}

func (m *Session) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *Session) GetAuthLevel() Session_AuthLevel {
	if m != nil {
		return m.AuthLevel
	}
	return Session_NONE
}

func (m *Session) GetRemoteAddr() string {
	if m != nil {
		return m.RemoteAddr
	}
	return ""
}

func (m *Session) GetUserAgent() string {
	if m != nil {
		return m.UserAgent
	}
	return ""
}

func (m *Session) GetDeviceId() string {
	if m != nil {
		return m.DeviceId
	}
	return ""
}

func (m *Session) GetLanguage() string {
	if m != nil {
		return m.Language
	}
	return ""
}

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 (m *ClientReq) Reset()         { *m = ClientReq{} }
func (m *ClientReq) String() string { return proto.CompactTextString(m) }
func (*ClientReq) ProtoMessage()    {}
func (*ClientReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{32}
}
func (m *ClientReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ClientReq.Unmarshal(m, b)
}
func (m *ClientReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ClientReq.Marshal(b, m, deterministic)
}
func (dst *ClientReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ClientReq.Merge(dst, src)
}
func (m *ClientReq) XXX_Size() int {
	return xxx_messageInfo_ClientReq.Size(m)
}
func (m *ClientReq) XXX_DiscardUnknown() {
	xxx_messageInfo_ClientReq.DiscardUnknown(m)
}

var xxx_messageInfo_ClientReq proto.InternalMessageInfo

func (m *ClientReq) GetMsg() *ClientMsg {
	if m != nil {
		return m.Msg
	}
	return nil
}

func (m *ClientReq) GetSess() *Session {
	if m != nil {
		return m.Sess
	}
	return nil
}

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 (m *SearchQuery) Reset()         { *m = SearchQuery{} }
func (m *SearchQuery) String() string { return proto.CompactTextString(m) }
func (*SearchQuery) ProtoMessage()    {}
func (*SearchQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{33}
}
func (m *SearchQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SearchQuery.Unmarshal(m, b)
}
func (m *SearchQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SearchQuery.Marshal(b, m, deterministic)
}
func (dst *SearchQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SearchQuery.Merge(dst, src)
}
func (m *SearchQuery) XXX_Size() int {
	return xxx_messageInfo_SearchQuery.Size(m)
}
func (m *SearchQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_SearchQuery.DiscardUnknown(m)
}

var xxx_messageInfo_SearchQuery proto.InternalMessageInfo

func (m *SearchQuery) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *SearchQuery) GetQuery() string {
	if m != nil {
		return m.Query
	}
	return ""
}

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 (m *SearchFound) Reset()         { *m = SearchFound{} }
func (m *SearchFound) String() string { return proto.CompactTextString(m) }
func (*SearchFound) ProtoMessage()    {}
func (*SearchFound) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{34}
}
func (m *SearchFound) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SearchFound.Unmarshal(m, b)
}
func (m *SearchFound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SearchFound.Marshal(b, m, deterministic)
}
func (dst *SearchFound) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SearchFound.Merge(dst, src)
}
func (m *SearchFound) XXX_Size() int {
	return xxx_messageInfo_SearchFound.Size(m)
}
func (m *SearchFound) XXX_DiscardUnknown() {
	xxx_messageInfo_SearchFound.DiscardUnknown(m)
}

var xxx_messageInfo_SearchFound proto.InternalMessageInfo

func (m *SearchFound) GetStatus() RespCode {
	if m != nil {
		return m.Status
	}
	return RespCode_CONTINUE
}

func (m *SearchFound) GetQuery() string {
	if m != nil {
		return m.Query
	}
	return ""
}

func (m *SearchFound) GetResult() []*TopicSub {
	if m != nil {
		return m.Result
	}
	return nil
}

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 (m *TopicEvent) Reset()         { *m = TopicEvent{} }
func (m *TopicEvent) String() string { return proto.CompactTextString(m) }
func (*TopicEvent) ProtoMessage()    {}
func (*TopicEvent) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{35}
}
func (m *TopicEvent) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_TopicEvent.Unmarshal(m, b)
}
func (m *TopicEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_TopicEvent.Marshal(b, m, deterministic)
}
func (dst *TopicEvent) XXX_Merge(src proto.Message) {
	xxx_messageInfo_TopicEvent.Merge(dst, src)
}
func (m *TopicEvent) XXX_Size() int {
	return xxx_messageInfo_TopicEvent.Size(m)
}
func (m *TopicEvent) XXX_DiscardUnknown() {
	xxx_messageInfo_TopicEvent.DiscardUnknown(m)
}

var xxx_messageInfo_TopicEvent proto.InternalMessageInfo

func (m *TopicEvent) GetAction() Crud {
	if m != nil {
		return m.Action
	}
	return Crud_CREATE
}

func (m *TopicEvent) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *TopicEvent) GetDesc() *TopicDesc {
	if m != nil {
		return m.Desc
	}
	return nil
}

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 (m *AccountEvent) Reset()         { *m = AccountEvent{} }
func (m *AccountEvent) String() string { return proto.CompactTextString(m) }
func (*AccountEvent) ProtoMessage()    {}
func (*AccountEvent) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{36}
}
func (m *AccountEvent) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AccountEvent.Unmarshal(m, b)
}
func (m *AccountEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AccountEvent.Marshal(b, m, deterministic)
}
func (dst *AccountEvent) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AccountEvent.Merge(dst, src)
}
func (m *AccountEvent) XXX_Size() int {
	return xxx_messageInfo_AccountEvent.Size(m)
}
func (m *AccountEvent) XXX_DiscardUnknown() {
	xxx_messageInfo_AccountEvent.DiscardUnknown(m)
}

var xxx_messageInfo_AccountEvent proto.InternalMessageInfo

func (m *AccountEvent) GetAction() Crud {
	if m != nil {
		return m.Action
	}
	return Crud_CREATE
}

func (m *AccountEvent) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *AccountEvent) GetDefaultAcs() *DefaultAcsMode {
	if m != nil {
		return m.DefaultAcs
	}
	return nil
}

func (m *AccountEvent) GetPublic() []byte {
	if m != nil {
		return m.Public
	}
	return nil
}

func (m *AccountEvent) GetTags() []string {
	if m != nil {
		return m.Tags
	}
	return nil
}

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 (m *SubscriptionEvent) Reset()         { *m = SubscriptionEvent{} }
func (m *SubscriptionEvent) String() string { return proto.CompactTextString(m) }
func (*SubscriptionEvent) ProtoMessage()    {}
func (*SubscriptionEvent) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{37}
}
func (m *SubscriptionEvent) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SubscriptionEvent.Unmarshal(m, b)
}
func (m *SubscriptionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SubscriptionEvent.Marshal(b, m, deterministic)
}
func (dst *SubscriptionEvent) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SubscriptionEvent.Merge(dst, src)
}
func (m *SubscriptionEvent) XXX_Size() int {
	return xxx_messageInfo_SubscriptionEvent.Size(m)
}
func (m *SubscriptionEvent) XXX_DiscardUnknown() {
	xxx_messageInfo_SubscriptionEvent.DiscardUnknown(m)
}

var xxx_messageInfo_SubscriptionEvent proto.InternalMessageInfo

func (m *SubscriptionEvent) GetAction() Crud {
	if m != nil {
		return m.Action
	}
	return Crud_CREATE
}

func (m *SubscriptionEvent) GetTopic() string {
	if m != nil {
		return m.Topic
	}
	return ""
}

func (m *SubscriptionEvent) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *SubscriptionEvent) GetDelId() int32 {
	if m != nil {
		return m.DelId
	}
	return 0
}

func (m *SubscriptionEvent) GetReadId() int32 {
	if m != nil {
		return m.ReadId
	}
	return 0
}

func (m *SubscriptionEvent) GetRecvId() int32 {
	if m != nil {
		return m.RecvId
	}
	return 0
}

func (m *SubscriptionEvent) GetMode() *AccessMode {
	if m != nil {
		return m.Mode
	}
	return nil
}

func (m *SubscriptionEvent) GetPrivate() []byte {
	if m != nil {
		return m.Private
	}
	return nil
}

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 (m *MessageEvent) Reset()         { *m = MessageEvent{} }
func (m *MessageEvent) String() string { return proto.CompactTextString(m) }
func (*MessageEvent) ProtoMessage()    {}
func (*MessageEvent) Descriptor() ([]byte, []int) {
	return fileDescriptor_model_be39e3c871441b6d, []int{38}
}
func (m *MessageEvent) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MessageEvent.Unmarshal(m, b)
}
func (m *MessageEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MessageEvent.Marshal(b, m, deterministic)
}
func (dst *MessageEvent) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MessageEvent.Merge(dst, src)
}
func (m *MessageEvent) XXX_Size() int {
	return xxx_messageInfo_MessageEvent.Size(m)
}
func (m *MessageEvent) XXX_DiscardUnknown() {
	xxx_messageInfo_MessageEvent.DiscardUnknown(m)
}

var xxx_messageInfo_MessageEvent proto.InternalMessageInfo

func (m *MessageEvent) GetAction() Crud {
	if m != nil {
		return m.Action
	}
	return Crud_CREATE
}

func (m *MessageEvent) GetMsg() *ServerData {
	if m != nil {
		return m.Msg
	}
	return nil
}

func init() {
	proto.RegisterType((*Unused)(nil), "pbx.Unused")
	proto.RegisterType((*DefaultAcsMode)(nil), "pbx.DefaultAcsMode")
	proto.RegisterType((*AccessMode)(nil), "pbx.AccessMode")
	proto.RegisterType((*SetSub)(nil), "pbx.SetSub")
	proto.RegisterType((*SetDesc)(nil), "pbx.SetDesc")
	proto.RegisterType((*GetOpts)(nil), "pbx.GetOpts")
	proto.RegisterType((*GetQuery)(nil), "pbx.GetQuery")
	proto.RegisterType((*SetQuery)(nil), "pbx.SetQuery")
	proto.RegisterType((*SeqRange)(nil), "pbx.SeqRange")
	proto.RegisterType((*Credential)(nil), "pbx.Credential")
	proto.RegisterType((*ClientHi)(nil), "pbx.ClientHi")
	proto.RegisterType((*ClientAcc)(nil), "pbx.ClientAcc")
	proto.RegisterType((*ClientLogin)(nil), "pbx.ClientLogin")
	proto.RegisterType((*ClientSub)(nil), "pbx.ClientSub")
	proto.RegisterType((*ClientLeave)(nil), "pbx.ClientLeave")
	proto.RegisterType((*ClientPub)(nil), "pbx.ClientPub")
	proto.RegisterMapType((map[string][]byte)(nil), "pbx.ClientPub.HeadEntry")
	proto.RegisterType((*ClientGet)(nil), "pbx.ClientGet")
	proto.RegisterType((*ClientSet)(nil), "pbx.ClientSet")
	proto.RegisterType((*ClientDel)(nil), "pbx.ClientDel")
	proto.RegisterType((*ClientNote)(nil), "pbx.ClientNote")
	proto.RegisterType((*ClientMsg)(nil), "pbx.ClientMsg")
	proto.RegisterType((*TopicDesc)(nil), "pbx.TopicDesc")
	proto.RegisterType((*TopicSub)(nil), "pbx.TopicSub")
	proto.RegisterType((*DelValues)(nil), "pbx.DelValues")
	proto.RegisterType((*ServerCtrl)(nil), "pbx.ServerCtrl")
	proto.RegisterMapType((map[string][]byte)(nil), "pbx.ServerCtrl.ParamsEntry")
	proto.RegisterType((*ServerData)(nil), "pbx.ServerData")
	proto.RegisterMapType((map[string][]byte)(nil), "pbx.ServerData.HeadEntry")
	proto.RegisterType((*ServerPres)(nil), "pbx.ServerPres")
	proto.RegisterType((*ServerMeta)(nil), "pbx.ServerMeta")
	proto.RegisterType((*ServerInfo)(nil), "pbx.ServerInfo")
	proto.RegisterType((*ServerMsg)(nil), "pbx.ServerMsg")
	proto.RegisterType((*ServerResp)(nil), "pbx.ServerResp")
	proto.RegisterType((*Session)(nil), "pbx.Session")
	proto.RegisterType((*ClientReq)(nil), "pbx.ClientReq")
	proto.RegisterType((*SearchQuery)(nil), "pbx.SearchQuery")
	proto.RegisterType((*SearchFound)(nil), "pbx.SearchFound")
	proto.RegisterType((*TopicEvent)(nil), "pbx.TopicEvent")
	proto.RegisterType((*AccountEvent)(nil), "pbx.AccountEvent")
	proto.RegisterType((*SubscriptionEvent)(nil), "pbx.SubscriptionEvent")
	proto.RegisterType((*MessageEvent)(nil), "pbx.MessageEvent")
	proto.RegisterEnum("pbx.InfoNote", InfoNote_name, InfoNote_value)
	proto.RegisterEnum("pbx.RespCode", RespCode_name, RespCode_value)
	proto.RegisterEnum("pbx.Crud", Crud_name, Crud_value)
	proto.RegisterEnum("pbx.ClientDel_What", ClientDel_What_name, ClientDel_What_value)
	proto.RegisterEnum("pbx.ServerPres_What", ServerPres_What_name, ServerPres_What_value)
	proto.RegisterEnum("pbx.Session_AuthLevel", Session_AuthLevel_name, Session_AuthLevel_value)
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// Client API for Node service

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

type nodeClient struct {
	cc *grpc.ClientConn
}

func NewNodeClient(cc *grpc.ClientConn) NodeClient {
	return &nodeClient{cc}
}

func (c *nodeClient) MessageLoop(ctx context.Context, opts ...grpc.CallOption) (Node_MessageLoopClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Node_serviceDesc.Streams[0], c.cc, "/pbx.Node/MessageLoop", opts...)
	if err != nil {
		return nil, err
	}
	x := &nodeMessageLoopClient{stream}
	return x, nil
}

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

type nodeMessageLoopClient struct {
	grpc.ClientStream
}

func (x *nodeMessageLoopClient) Send(m *ClientMsg) error {
	return x.ClientStream.SendMsg(m)
}

func (x *nodeMessageLoopClient) Recv() (*ServerMsg, error) {
	m := new(ServerMsg)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

// Server API for Node service

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

func RegisterNodeServer(s *grpc.Server, srv NodeServer) {
	s.RegisterService(&_Node_serviceDesc, srv)
}

func _Node_MessageLoop_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(NodeServer).MessageLoop(&nodeMessageLoopServer{stream})
}

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

type nodeMessageLoopServer struct {
	grpc.ServerStream
}

func (x *nodeMessageLoopServer) Send(m *ServerMsg) error {
	return x.ServerStream.SendMsg(m)
}

func (x *nodeMessageLoopServer) Recv() (*ClientMsg, error) {
	m := new(ClientMsg)
	if err := x.ServerStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

var _Node_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pbx.Node",
	HandlerType: (*NodeServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MessageLoop",
			Handler:       _Node_MessageLoop_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "model.proto",
}

// Client API for Plugin service

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

type pluginClient struct {
	cc *grpc.ClientConn
}

func NewPluginClient(cc *grpc.ClientConn) PluginClient {
	return &pluginClient{cc}
}

func (c *pluginClient) FireHose(ctx context.Context, in *ClientReq, opts ...grpc.CallOption) (*ServerResp, error) {
	out := new(ServerResp)
	err := grpc.Invoke(ctx, "/pbx.Plugin/FireHose", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pluginClient) Find(ctx context.Context, in *SearchQuery, opts ...grpc.CallOption) (*SearchFound, error) {
	out := new(SearchFound)
	err := grpc.Invoke(ctx, "/pbx.Plugin/Find", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pluginClient) Account(ctx context.Context, in *AccountEvent, opts ...grpc.CallOption) (*Unused, error) {
	out := new(Unused)
	err := grpc.Invoke(ctx, "/pbx.Plugin/Account", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pluginClient) Topic(ctx context.Context, in *TopicEvent, opts ...grpc.CallOption) (*Unused, error) {
	out := new(Unused)
	err := grpc.Invoke(ctx, "/pbx.Plugin/Topic", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pluginClient) Subscription(ctx context.Context, in *SubscriptionEvent, opts ...grpc.CallOption) (*Unused, error) {
	out := new(Unused)
	err := grpc.Invoke(ctx, "/pbx.Plugin/Subscription", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *pluginClient) Message(ctx context.Context, in *MessageEvent, opts ...grpc.CallOption) (*Unused, error) {
	out := new(Unused)
	err := grpc.Invoke(ctx, "/pbx.Plugin/Message", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for Plugin service

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

func RegisterPluginServer(s *grpc.Server, srv PluginServer) {
	s.RegisterService(&_Plugin_serviceDesc, srv)
}

func _Plugin_FireHose_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClientReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).FireHose(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/FireHose",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).FireHose(ctx, req.(*ClientReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _Plugin_Find_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SearchQuery)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).Find(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/Find",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).Find(ctx, req.(*SearchQuery))
	}
	return interceptor(ctx, in, info, handler)
}

func _Plugin_Account_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AccountEvent)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).Account(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/Account",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).Account(ctx, req.(*AccountEvent))
	}
	return interceptor(ctx, in, info, handler)
}

func _Plugin_Topic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TopicEvent)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).Topic(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/Topic",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).Topic(ctx, req.(*TopicEvent))
	}
	return interceptor(ctx, in, info, handler)
}

func _Plugin_Subscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubscriptionEvent)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).Subscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/Subscription",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).Subscription(ctx, req.(*SubscriptionEvent))
	}
	return interceptor(ctx, in, info, handler)
}

func _Plugin_Message_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MessageEvent)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(PluginServer).Message(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pbx.Plugin/Message",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(PluginServer).Message(ctx, req.(*MessageEvent))
	}
	return interceptor(ctx, in, info, handler)
}

var _Plugin_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pbx.Plugin",
	HandlerType: (*PluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FireHose",
			Handler:    _Plugin_FireHose_Handler,
		},
		{
			MethodName: "Find",
			Handler:    _Plugin_Find_Handler,
		},
		{
			MethodName: "Account",
			Handler:    _Plugin_Account_Handler,
		},
		{
			MethodName: "Topic",
			Handler:    _Plugin_Topic_Handler,
		},
		{
			MethodName: "Subscription",
			Handler:    _Plugin_Subscription_Handler,
		},
		{
			MethodName: "Message",
			Handler:    _Plugin_Message_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "model.proto",
}

func init() { proto.RegisterFile("model.proto", fileDescriptor_model_be39e3c871441b6d) }

var fileDescriptor_model_be39e3c871441b6d = []byte{
	// 2432 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x39, 0xcd, 0x72, 0xe3, 0x58,
	0xd5, 0xb6, 0x65, 0xcb, 0xd2, 0x71, 0x26, 0x51, 0xdf, 0x2f, 0xdf, 0x8c, 0x27, 0x53, 0x33, 0x93,
	0x56, 0xcf, 0x4f, 0x2a, 0xdd, 0x13, 0xa8, 0x6e, 0x1a, 0x06, 0x98, 0x8d, 0x27, 0x76, 0x27, 0x81,
	0x24, 0x36, 0x72, 0xd2, 0x6c, 0xa8, 0x72, 0xc9, 0xd2, 0x8d, 0xad, 0x1a, 0x59, 0x72, 0xa4, 0x2b,
	0x4f, 0x77, 0x15, 0x45, 0x15, 0xec, 0xe0, 0x0d, 0x58, 0xb1, 0x63, 0xc5, 0xbc, 0x00, 0x8f, 0x30,
	0x6c, 0x61, 0xc1, 0x43, 0xf0, 0x06, 0x2c, 0xa8, 0x73, 0x7f, 0x64, 0xc9, 0x89, 0x43, 0x1a, 0xd8,
	0xdd, 0x7b, 0xce, 0xf1, 0xf9, 0xff, 0xd3, 0x35, 0xb4, 0x66, 0xb1, 0x4f, 0xc3, 0x83, 0x79, 0x12,
	0xb3, 0x98, 0x68, 0xf3, 0xf1, 0x2b, 0xdb, 0x00, 0xfd, 0x32, 0xca, 0x52, 0xea, 0xdb, 0x9f, 0xc3,
	0x66, 0x97, 0x5e, 0xb9, 0x59, 0xc8, 0x3a, 0x5e, 0x7a, 0x16, 0xfb, 0x94, 0x10, 0xa8, 0xbb, 0x19,
	0x9b, 0xb6, 0xab, 0xbb, 0xd5, 0x3d, 0xd3, 0xe1, 0x67, 0x0e, 0x8b, 0xe2, 0xa8, 0x5d, 0x93, 0xb0,
	0x28, 0x8e, 0xec, 0xef, 0x03, 0x74, 0x3c, 0x8f, 0xa6, 0xf9, 0xaf, 0xbe, 0x76, 0x23, 0xa6, 0x7e,
	0x85, 0x67, 0xb2, 0x0d, 0x8d, 0x49, 0xb0, 0xa0, 0xea, 0x67, 0xe2, 0x62, 0x3f, 0x07, 0x7d, 0x48,
	0xd9, 0x30, 0x1b, 0x93, 0x77, 0xa0, 0x99, 0xa5, 0x34, 0x19, 0x05, 0xbe, 0xfc, 0x99, 0x8e, 0xd7,
	0x13, 0x1f, 0x99, 0xa1, 0xca, 0x4a, 0x1c, 0x9e, 0xed, 0x6b, 0x68, 0x0e, 0x29, 0xeb, 0xd2, 0xd4,
	0x23, 0xdf, 0x83, 0x96, 0x2f, 0x74, 0x1e, 0xb9, 0x5e, 0xca, 0x7f, 0xdb, 0x7a, 0xfa, 0x7f, 0x07,
	0xf3, 0xf1, 0xab, 0x83, 0xb2, 0x2d, 0x0e, 0xf8, 0xf9, 0x9d, 0xbc, 0x0d, 0xfa, 0x3c, 0x1b, 0x87,
	0x81, 0xc7, 0xd9, 0x6e, 0x38, 0xf2, 0x46, 0xda, 0xd0, 0x9c, 0x27, 0xc1, 0xc2, 0x65, 0xb4, 0xad,
	0x71, 0x84, 0xba, 0xda, 0xdf, 0x54, 0xa1, 0x79, 0x44, 0x59, 0x7f, 0xce, 0x52, 0xb2, 0x0f, 0x0f,
	0x82, 0xab, 0xd1, 0x2c, 0xf6, 0x83, 0xab, 0x80, 0xfa, 0xa3, 0x34, 0x88, 0x3c, 0xca, 0x25, 0x6b,
	0xce, 0x56, 0x70, 0x75, 0x26, 0xe1, 0x43, 0x04, 0xa3, 0xfa, 0x68, 0x88, 0x52, 0x1f, 0xcf, 0xe8,
	0x0b, 0x16, 0xcf, 0x03, 0x8f, 0xcb, 0x30, 0x1d, 0x71, 0x21, 0xef, 0x82, 0xc1, 0x39, 0xa1, 0x0b,
	0xea, 0xbb, 0xd5, 0xbd, 0x86, 0xd3, 0xe4, 0xf7, 0x13, 0x9f, 0xbc, 0x07, 0xe6, 0x98, 0x5e, 0xc5,
	0x09, 0xc7, 0x35, 0x38, 0xce, 0x10, 0x80, 0x13, 0x1f, 0xb9, 0x85, 0xc1, 0x2c, 0x60, 0x6d, 0x9d,
	0x23, 0xc4, 0xc5, 0xfe, 0x4d, 0x15, 0x8c, 0x23, 0xca, 0x7e, 0x96, 0xd1, 0xe4, 0x35, 0x0f, 0xc8,
	0xd4, 0x5d, 0x06, 0x64, 0xea, 0x32, 0xb2, 0x0b, 0x75, 0x9f, 0xa6, 0xc2, 0x01, 0xad, 0xa7, 0x1b,
	0xdc, 0x63, 0xd2, 0x40, 0x87, 0x63, 0xc8, 0x07, 0xa0, 0xa5, 0xd9, 0x98, 0x2b, 0xb9, 0x4a, 0x80,
	0x08, 0xce, 0xc1, 0x65, 0x2e, 0x57, 0xf6, 0x26, 0x07, 0x97, 0xb9, 0xf6, 0x08, 0x8c, 0xa1, 0xd2,
	0x41, 0xc9, 0xab, 0x16, 0xa8, 0x65, 0x10, 0xa5, 0xbc, 0xf7, 0x85, 0x3c, 0xa1, 0x50, 0x4b, 0x11,
	0x0c, 0xb3, 0xb1, 0x10, 0x47, 0xa0, 0xce, 0xdc, 0x49, 0xda, 0xd6, 0x76, 0x35, 0x34, 0x02, 0xcf,
	0xf6, 0x13, 0x14, 0x70, 0xed, 0xb8, 0xd1, 0x84, 0x12, 0x0b, 0xb4, 0x30, 0xfe, 0x9a, 0xf3, 0x6f,
	0x38, 0x78, 0x24, 0x9b, 0x50, 0x9b, 0x06, 0x9c, 0x5f, 0xc3, 0xa9, 0x4d, 0x03, 0x3b, 0x02, 0x38,
	0x4c, 0xa8, 0x4f, 0x23, 0x16, 0xb8, 0x21, 0xe6, 0xc0, 0x8c, 0xb2, 0x69, 0x9c, 0x27, 0x9c, 0xb8,
	0xa1, 0x3f, 0x17, 0x6e, 0x98, 0xa9, 0x8c, 0x13, 0x17, 0xb2, 0x03, 0x46, 0x42, 0xd3, 0x79, 0x1c,
	0xa5, 0x54, 0x86, 0x2d, 0xbf, 0xf3, 0x6c, 0x72, 0x13, 0x77, 0x96, 0x72, 0x57, 0x60, 0x36, 0xf1,
	0x9b, 0xfd, 0x4b, 0x30, 0x0e, 0xc3, 0x80, 0x46, 0xec, 0x38, 0x40, 0x5d, 0xf2, 0xd4, 0xae, 0x05,
	0x3e, 0x79, 0x1f, 0x80, 0xe7, 0xbb, 0x3b, 0xa1, 0x11, 0x93, 0xa2, 0x4c, 0x84, 0x74, 0x10, 0x80,
	0xc6, 0x2c, 0x68, 0x22, 0x25, 0xe1, 0x11, 0x73, 0xc0, 0xa7, 0x8b, 0x60, 0x99, 0x1f, 0xa6, 0x63,
	0x08, 0x80, 0x28, 0x92, 0xd0, 0x8d, 0x26, 0x3c, 0x37, 0x4c, 0x87, 0x9f, 0xed, 0xbf, 0x55, 0xc1,
	0x14, 0xe2, 0x3b, 0x9e, 0x77, 0x43, 0x7e, 0xa1, 0xde, 0x6a, 0xa5, 0x7a, 0x7b, 0x1b, 0xf4, 0xd4,
	0x9b, 0xd2, 0x99, 0x32, 0x53, 0xde, 0x38, 0x9c, 0x7a, 0x09, 0x65, 0xca, 0x48, 0x71, 0xe3, 0xe9,
	0x17, 0x4f, 0x82, 0x88, 0xcb, 0x36, 0x1c, 0x71, 0xc9, 0x83, 0xa5, 0x2f, 0x83, 0x95, 0x67, 0x40,
	0x73, 0x6d, 0x06, 0x3c, 0x82, 0xba, 0x97, 0x50, 0xbf, 0x6d, 0xec, 0x6a, 0x7b, 0xad, 0xa7, 0x5b,
	0x9c, 0x62, 0x19, 0x31, 0x87, 0x23, 0xed, 0x04, 0x5a, 0xc2, 0xac, 0x53, 0x2e, 0x69, 0xd5, 0xb0,
	0xa5, 0xfe, 0xb5, 0x35, 0xfa, 0x6b, 0x25, 0xfd, 0x95, 0xcc, 0xfa, 0x5d, 0x32, 0x7f, 0x9b, 0xfb,
	0x12, 0x7b, 0xd5, 0xaa, 0xc8, 0xbc, 0x9e, 0x6b, 0xc5, 0x7a, 0xde, 0x07, 0x33, 0xa5, 0x6c, 0x74,
	0x8d, 0xd9, 0x2f, 0x8b, 0xe8, 0x2d, 0x65, 0x33, 0x2f, 0x09, 0xc7, 0x48, 0x55, 0x71, 0xec, 0x83,
	0x39, 0xc9, 0x69, 0xeb, 0x05, 0xda, 0xa3, 0x9c, 0x76, 0x22, 0x4f, 0xf6, 0x49, 0x6e, 0x3f, 0x75,
	0x17, 0xf4, 0x9e, 0xca, 0x6c, 0x43, 0x23, 0x8b, 0x54, 0x35, 0x1b, 0x8e, 0xb8, 0xd8, 0x7f, 0xc9,
	0xcd, 0x1a, 0xdc, 0xdb, 0xac, 0x77, 0xa0, 0x19, 0xc5, 0x23, 0xea, 0x4d, 0x63, 0xc9, 0x4b, 0x8f,
	0xe2, 0x9e, 0x37, 0x8d, 0xc9, 0x13, 0xa8, 0x4f, 0xa9, 0xab, 0x1c, 0xd9, 0x16, 0x8e, 0x54, 0xcc,
	0x0f, 0x8e, 0xa9, 0xeb, 0xf7, 0x22, 0x96, 0xbc, 0x76, 0x38, 0x15, 0x76, 0x5a, 0x2f, 0x8e, 0x18,
	0x26, 0x7f, 0x43, 0x74, 0x5a, 0x79, 0xdd, 0xf9, 0x01, 0x98, 0x39, 0x31, 0xd6, 0xc1, 0x57, 0xf4,
	0xb5, 0x54, 0x0a, 0x8f, 0xe5, 0xf2, 0xdc, 0x90, 0xe5, 0xf9, 0xa3, 0xda, 0xe7, 0x55, 0xfb, 0xa5,
	0x32, 0xe6, 0x88, 0xb2, 0x7b, 0x1a, 0xf3, 0x08, 0x1a, 0x37, 0xe3, 0x93, 0xfb, 0x5c, 0xe0, 0x96,
	0x7c, 0x87, 0xff, 0x1d, 0xdf, 0xe1, 0x0a, 0xdf, 0xbf, 0xe6, 0xde, 0xef, 0xd2, 0xf0, 0x9e, 0x8c,
	0x3f, 0x95, 0x9d, 0x1c, 0xf9, 0x6e, 0xca, 0x39, 0x97, 0xf3, 0x38, 0xf8, 0xf9, 0xd4, 0x65, 0xb2,
	0xbd, 0x7f, 0x02, 0x4d, 0x9f, 0x86, 0xa3, 0x94, 0x5e, 0xcb, 0x80, 0x28, 0x1d, 0x44, 0xb7, 0x74,
	0x74, 0x9f, 0x86, 0x43, 0x7a, 0x5d, 0xec, 0x03, 0x8d, 0xd5, 0xb9, 0x3b, 0x75, 0x13, 0x9f, 0x4f,
	0x15, 0xc3, 0xe1, 0x67, 0xfb, 0x11, 0xd4, 0x51, 0x04, 0x69, 0x82, 0x76, 0x36, 0x3c, 0xb2, 0x2a,
	0xc4, 0x84, 0xc6, 0x45, 0x7f, 0x70, 0x72, 0x68, 0x55, 0x11, 0x36, 0xbc, 0xfc, 0xd2, 0xaa, 0xd9,
	0xbf, 0x00, 0x10, 0x1a, 0x9d, 0xc7, 0x8c, 0x2e, 0xcd, 0xa8, 0x16, 0xcd, 0x78, 0x28, 0xcd, 0xa8,
	0x71, 0x33, 0x84, 0x6a, 0x27, 0xd1, 0x55, 0x8c, 0x3f, 0x91, 0x06, 0xfc, 0x3f, 0xd6, 0xeb, 0x35,
	0xea, 0xa5, 0x89, 0xb9, 0x96, 0xd2, 0xeb, 0x13, 0xdf, 0xfe, 0x9d, 0xa6, 0x9c, 0x76, 0x96, 0x4e,
	0xc8, 0x87, 0xbc, 0xc3, 0x57, 0x0b, 0x4e, 0x56, 0x0d, 0xf7, 0xb8, 0x82, 0x2d, 0x9f, 0xd8, 0xa0,
	0xb9, 0x9e, 0x1a, 0x72, 0x9b, 0x05, 0x8a, 0x8e, 0xe7, 0x1d, 0x57, 0x1c, 0x44, 0x92, 0x3d, 0xd5,
	0xc1, 0x44, 0xb0, 0xac, 0x02, 0x15, 0x6f, 0x31, 0xc7, 0x15, 0xd5, 0xd5, 0x6c, 0x31, 0xa1, 0xea,
	0x37, 0xb8, 0x0d, 0xb3, 0x31, 0x72, 0xc3, 0x31, 0x85, 0xdc, 0xb0, 0x30, 0xb9, 0x3b, 0x57, 0xb8,
	0x21, 0x9c, 0x73, 0xe3, 0x95, 0x6b, 0x83, 0x36, 0xcf, 0xc6, 0xdc, 0xc1, 0x65, 0x6e, 0x03, 0xc1,
	0x6d, 0x9e, 0x8d, 0x91, 0x66, 0x42, 0x99, 0x6c, 0x99, 0x45, 0x9a, 0x23, 0xca, 0x90, 0x66, 0x42,
	0x19, 0xd7, 0x8a, 0xb2, 0xb6, 0x71, 0x53, 0x2b, 0x41, 0x93, 0x0a, 0x1a, 0x9f, 0x86, 0x6d, 0xf3,
	0x06, 0x4d, 0x97, 0x86, 0x48, 0xe3, 0xd3, 0x90, 0x7c, 0x0c, 0xf5, 0x28, 0x66, 0xb4, 0x0d, 0x9c,
	0x68, 0xab, 0x40, 0x84, 0x61, 0x39, 0xae, 0x38, 0x1c, 0xfd, 0xa5, 0x09, 0xcd, 0x33, 0x9a, 0xa6,
	0xee, 0x84, 0xda, 0xdf, 0xd6, 0xc0, 0xbc, 0xc0, 0x80, 0x76, 0xc5, 0xfc, 0x06, 0x2f, 0xa1, 0x2e,
	0xa3, 0xfe, 0x48, 0xee, 0x1a, 0x9a, 0x63, 0x4a, 0x48, 0x87, 0xf1, 0x89, 0x37, 0xf7, 0x15, 0xba,
	0x26, 0xd0, 0x12, 0x22, 0xd0, 0x2c, 0xce, 0xbc, 0xa9, 0x40, 0x6b, 0x02, 0x2d, 0x21, 0x1d, 0x46,
	0x1e, 0x83, 0x8e, 0xfb, 0x9b, 0x97, 0x4a, 0xef, 0xdf, 0xba, 0xe2, 0x49, 0x12, 0xf2, 0x10, 0xa3,
	0x9e, 0xca, 0x08, 0x08, 0x43, 0x96, 0xeb, 0x29, 0x06, 0x3d, 0x2d, 0xa4, 0x97, 0x5e, 0x48, 0x2f,
	0x2c, 0x87, 0x84, 0xba, 0x3e, 0xc2, 0x9b, 0x1c, 0xae, 0xe3, 0x55, 0x21, 0xbc, 0x05, 0x22, 0x0c,
	0x85, 0xf0, 0x16, 0x27, 0x3e, 0x32, 0xc2, 0x42, 0x0b, 0x7c, 0xee, 0xdc, 0x86, 0xd3, 0xf0, 0x69,
	0x28, 0xc6, 0xa8, 0xdc, 0x30, 0x61, 0xdd, 0x86, 0xd9, 0x2a, 0x6f, 0x98, 0x7f, 0xd6, 0xc0, 0xe0,
	0xce, 0xc4, 0x11, 0x53, 0x76, 0x56, 0xf5, 0x16, 0x67, 0xf9, 0x34, 0xa4, 0x65, 0x5f, 0x4a, 0x48,
	0x87, 0xa1, 0xf0, 0x38, 0x0a, 0x83, 0x88, 0xaa, 0x16, 0x2d, 0x6e, 0xca, 0x2f, 0xf5, 0x3b, 0xfc,
	0x52, 0x70, 0x40, 0x63, 0x9d, 0x03, 0xf4, 0x92, 0x03, 0x96, 0x96, 0x36, 0xd7, 0x59, 0x6a, 0x94,
	0x2c, 0x2d, 0xf6, 0x1c, 0xb3, 0xd4, 0x73, 0xf2, 0x66, 0x01, 0xc5, 0x66, 0x51, 0xce, 0x8c, 0xd6,
	0x6a, 0x66, 0x2c, 0x23, 0xb9, 0x51, 0x8c, 0xe4, 0x32, 0x2e, 0x6f, 0x15, 0xe3, 0xf2, 0x11, 0x6c,
	0x86, 0x6e, 0xca, 0x46, 0x29, 0xa5, 0xd1, 0x88, 0x05, 0x33, 0xda, 0xde, 0xe4, 0x0c, 0x37, 0x10,
	0x3a, 0xa4, 0x34, 0xba, 0x08, 0x66, 0x94, 0x7c, 0x07, 0xb6, 0x97, 0x54, 0x85, 0x3d, 0x6d, 0x8b,
	0xeb, 0xf5, 0x40, 0xd1, 0x5e, 0xaa, 0x7d, 0xcd, 0xfe, 0x09, 0x98, 0x5d, 0x1a, 0xbe, 0xc4, 0x59,
	0x94, 0x16, 0x44, 0x57, 0x8b, 0xa2, 0x0b, 0x2d, 0xb9, 0x76, 0x47, 0x4b, 0xb6, 0xbf, 0xad, 0x02,
	0x0c, 0x69, 0xb2, 0xa0, 0xc9, 0x21, 0x4b, 0xee, 0x3b, 0x18, 0x08, 0xd4, 0x3d, 0xfc, 0x4c, 0x12,
	0xcd, 0x92, 0x9f, 0xf9, 0x12, 0x46, 0x5f, 0x31, 0xb9, 0x2d, 0xf2, 0x33, 0x79, 0x96, 0xef, 0xaa,
	0x0d, 0xae, 0xc3, 0x7b, 0x52, 0x07, 0x25, 0xee, 0x60, 0xc0, 0xb1, 0x62, 0x54, 0x4b, 0xd2, 0x9d,
	0x1f, 0x42, 0xab, 0x00, 0x7e, 0xa3, 0xa1, 0xfc, 0xcf, 0xdc, 0x98, 0xae, 0xcb, 0xdc, 0x35, 0xe3,
	0x60, 0x17, 0x36, 0xae, 0x92, 0x78, 0x36, 0x2a, 0x6f, 0xa4, 0x80, 0xb0, 0x4b, 0x91, 0x19, 0xe5,
	0x84, 0xd7, 0x56, 0x13, 0x7e, 0x99, 0x03, 0xf5, 0x62, 0x0e, 0x7c, 0x26, 0x57, 0x12, 0x61, 0xea,
	0xbb, 0x05, 0x53, 0x51, 0x99, 0xbb, 0x76, 0x12, 0xfd, 0x7f, 0xb4, 0x93, 0x7c, 0xa3, 0x29, 0xf3,
	0x07, 0x09, 0x4d, 0xd7, 0x98, 0x6f, 0x81, 0x96, 0x26, 0x2a, 0x9e, 0x78, 0x24, 0x7b, 0xa5, 0x31,
	0xbf, 0x5d, 0x50, 0x1c, 0xd9, 0x14, 0xe7, 0x7c, 0xf9, 0x3b, 0xa2, 0xbe, 0xfa, 0x1d, 0xb1, 0x74,
	0x4c, 0xe3, 0xf6, 0xe2, 0xd0, 0xd7, 0x64, 0x68, 0xf3, 0xae, 0xa5, 0xe1, 0x23, 0xd8, 0x64, 0x6e,
	0x82, 0x1b, 0xab, 0x8a, 0x98, 0xc1, 0x05, 0x6f, 0x08, 0xa8, 0x8c, 0x99, 0x0d, 0x6f, 0xb9, 0x1e,
	0x8b, 0x93, 0x51, 0xb9, 0xd8, 0x5b, 0x1c, 0x28, 0x69, 0x64, 0x47, 0x82, 0xf5, 0x1d, 0xc9, 0xfe,
	0x4a, 0x2e, 0x1d, 0x3a, 0xd4, 0xfa, 0xe7, 0x56, 0x05, 0x17, 0x8d, 0xfe, 0x8b, 0x17, 0x56, 0x15,
	0x01, 0x97, 0x1d, 0x4b, 0x43, 0xc0, 0xe5, 0xa0, 0x6b, 0xd5, 0x89, 0x01, 0xf5, 0xa3, 0xfe, 0x79,
	0xcf, 0x6a, 0x20, 0xa8, 0x73, 0x38, 0xb4, 0x74, 0x04, 0x5d, 0xf4, 0x9c, 0x33, 0xab, 0xa9, 0x76,
	0x16, 0x03, 0x41, 0x4e, 0xaf, 0xd3, 0xb5, 0x4c, 0x71, 0x3a, 0x7c, 0x69, 0x01, 0x22, 0xbb, 0xbd,
	0x53, 0xab, 0x65, 0xff, 0x3e, 0x4f, 0xd7, 0x33, 0xca, 0xdc, 0x7b, 0xd6, 0x9e, 0x2d, 0x3f, 0x6c,
	0xb4, 0xc2, 0x74, 0xcd, 0xc7, 0xa2, 0xfc, 0xb4, 0xf9, 0x50, 0xad, 0x0e, 0x4b, 0xb7, 0xaa, 0x66,
	0xaf, 0xbe, 0xa6, 0xf9, 0x84, 0x6e, 0x14, 0x78, 0xe4, 0x1d, 0x85, 0xcf, 0x67, 0xfb, 0x57, 0x4a,
	0x35, 0xdc, 0x94, 0xfe, 0xe3, 0x4a, 0x7a, 0x58, 0x4a, 0xad, 0x7f, 0xb3, 0x7a, 0x15, 0xab, 0xc9,
	0xfe, 0x7b, 0x15, 0x4c, 0xe9, 0x9b, 0x74, 0x82, 0xdb, 0x82, 0xc7, 0x92, 0x50, 0x2e, 0x5f, 0x5b,
	0x2b, 0x6d, 0x04, 0xb7, 0x05, 0x44, 0x23, 0x19, 0x7f, 0x24, 0xa8, 0xdd, 0x20, 0xc3, 0x12, 0x44,
	0x32, 0x44, 0x23, 0xd9, 0x3c, 0xa1, 0xa9, 0x74, 0xe1, 0xd6, 0x4a, 0xc2, 0x23, 0x19, 0xa2, 0x91,
	0x6c, 0x46, 0xf3, 0x27, 0x87, 0x22, 0x19, 0x86, 0x0b, 0xc9, 0x10, 0x8d, 0x64, 0x41, 0x74, 0x15,
	0x97, 0x16, 0x80, 0xa5, 0xeb, 0x90, 0x0c, 0xd1, 0xc5, 0x4d, 0xe6, 0xd7, 0x79, 0xdc, 0x1d, 0x9a,
	0xce, 0xc9, 0xc7, 0xa0, 0xa7, 0xcc, 0x65, 0x99, 0x78, 0x50, 0x52, 0x6e, 0x42, 0xd4, 0x21, 0xdf,
	0x33, 0x04, 0x92, 0x7c, 0x02, 0x7a, 0x9a, 0x2c, 0x66, 0xe9, 0xa4, 0xb4, 0x60, 0xe6, 0x3e, 0x72,
	0x24, 0x96, 0x7c, 0x04, 0x0d, 0x2f, 0x44, 0x32, 0xed, 0xc6, 0xfe, 0x85, 0x64, 0x02, 0x69, 0xff,
	0xb1, 0x06, 0xcd, 0x21, 0x4d, 0xd3, 0x20, 0x8e, 0xb0, 0xac, 0x53, 0x71, 0x5c, 0xbe, 0x88, 0x99,
	0x12, 0x72, 0x72, 0xc7, 0xd7, 0xfb, 0x73, 0x00, 0x37, 0x63, 0xd3, 0x51, 0x48, 0x17, 0x34, 0x94,
	0x31, 0x7e, 0x5b, 0x6a, 0xc5, 0x7f, 0x7c, 0xd0, 0xc9, 0xd8, 0xf4, 0x14, 0xb1, 0x8e, 0xe9, 0xaa,
	0x23, 0xf9, 0x10, 0x5a, 0x09, 0x9d, 0xc5, 0x8c, 0x8e, 0x5c, 0xdf, 0x4f, 0x64, 0x1b, 0x01, 0x01,
	0xea, 0xf8, 0x7e, 0xb2, 0xd2, 0x66, 0x1a, 0xab, 0x6d, 0xa6, 0xf4, 0x38, 0xa1, 0xaf, 0x3c, 0x4e,
	0xec, 0x80, 0x11, 0xba, 0xd1, 0x24, 0x73, 0x27, 0x94, 0xaf, 0x08, 0xa6, 0x93, 0xdf, 0xed, 0x67,
	0x60, 0xe6, 0x0a, 0x61, 0x3d, 0x9e, 0x63, 0xfd, 0x56, 0xf0, 0xd4, 0x39, 0xef, 0x9f, 0x5b, 0xc0,
	0x4f, 0x97, 0x17, 0xc7, 0xd6, 0x36, 0xaf, 0xd6, 0x7e, 0xff, 0xc2, 0xfa, 0xc0, 0xee, 0xab, 0x4f,
	0x00, 0x87, 0x5e, 0x63, 0xdd, 0xa0, 0x67, 0xab, 0xb7, 0x7a, 0x16, 0x51, 0x64, 0x17, 0xea, 0xe8,
	0xb9, 0xd2, 0x4b, 0x97, 0xf4, 0x86, 0xc3, 0x31, 0xf6, 0x17, 0xd0, 0x1a, 0x52, 0x37, 0xf1, 0xa6,
	0xe2, 0x6b, 0x7c, 0xed, 0x5b, 0xe4, 0xb6, 0xfa, 0xac, 0x93, 0xe5, 0x2f, 0xbe, 0xe3, 0xae, 0xd5,
	0xaf, 0x5f, 0xc4, 0x59, 0xe4, 0xdf, 0x37, 0x77, 0x6e, 0xe5, 0x85, 0x3f, 0x4e, 0x68, 0x9a, 0x85,
	0x8c, 0x3f, 0x73, 0xdd, 0xe8, 0x14, 0x12, 0x69, 0x4f, 0x00, 0x38, 0xac, 0xb7, 0x40, 0xef, 0x3f,
	0x04, 0xdd, 0xf5, 0x58, 0x10, 0x47, 0x52, 0xa2, 0x29, 0x1f, 0x31, 0x32, 0xdf, 0x91, 0x08, 0x5c,
	0x05, 0x22, 0x37, 0x7f, 0x13, 0xe1, 0xe7, 0xfb, 0xb4, 0x2d, 0xfb, 0x4f, 0x55, 0xd8, 0xe8, 0x78,
	0x5e, 0x9c, 0x45, 0xec, 0xde, 0xb2, 0xd6, 0x26, 0xe7, 0xca, 0x5b, 0xad, 0xf6, 0xa6, 0x6f, 0xb5,
	0xf5, 0xd2, 0x7e, 0xa9, 0x9e, 0x98, 0x8c, 0xc2, 0x7b, 0xe0, 0x3f, 0xaa, 0xf0, 0x60, 0x98, 0x8d,
	0x53, 0x2f, 0x09, 0xe6, 0xa8, 0xcb, 0xbd, 0x75, 0x5e, 0xfb, 0xd6, 0xa1, 0x2c, 0xd1, 0x4a, 0x96,
	0x2c, 0xe7, 0x67, 0xbd, 0x38, 0x3f, 0xdf, 0x7c, 0x79, 0x7e, 0x24, 0x5f, 0xb7, 0x9b, 0xb7, 0x0f,
	0x40, 0x8e, 0x5c, 0xbf, 0x49, 0xdb, 0x17, 0xb0, 0x21, 0x3b, 0xd8, 0xbd, 0x2d, 0x7d, 0x28, 0xea,
	0xe5, 0xf6, 0x7e, 0xcc, 0x0b, 0x66, 0xff, 0x13, 0x30, 0xd4, 0x44, 0xc8, 0xa7, 0x65, 0x25, 0x9f,
	0x96, 0x7c, 0xf0, 0xfe, 0x74, 0x60, 0xd5, 0xf6, 0xbf, 0x00, 0x43, 0xa5, 0x35, 0xd9, 0x00, 0xe3,
	0xb0, 0x7f, 0x7e, 0x71, 0x72, 0x7e, 0x29, 0xeb, 0xb7, 0xeb, 0xf4, 0x07, 0x56, 0x95, 0xb4, 0xa0,
	0xe9, 0xf4, 0x86, 0x83, 0xfe, 0x79, 0xd7, 0xaa, 0x89, 0xcb, 0xe0, 0xb4, 0x73, 0xd8, 0xb3, 0xb4,
	0xfd, 0x7d, 0xa8, 0xa3, 0x62, 0x04, 0x40, 0x3f, 0x74, 0x7a, 0x9d, 0x0b, 0xfc, 0x1d, 0x80, 0x7e,
	0x39, 0xe8, 0xe2, 0xb9, 0x8a, 0xe7, 0x6e, 0xef, 0xb4, 0x77, 0xd1, 0xb3, 0x6a, 0x4f, 0x7f, 0x0c,
	0xf5, 0x73, 0x94, 0xf2, 0x0c, 0x5a, 0xd2, 0xde, 0xd3, 0x38, 0x9e, 0x93, 0x95, 0x72, 0xdf, 0x59,
	0xe9, 0xbf, 0x76, 0x65, 0xaf, 0xfa, 0xdd, 0xea, 0xd3, 0x3f, 0xd4, 0x40, 0x1f, 0x84, 0x19, 0x7e,
	0xc0, 0x7f, 0x06, 0xc6, 0x8b, 0x20, 0xa1, 0xc7, 0x71, 0x4a, 0x4b, 0x3f, 0x76, 0xe8, 0xf5, 0x4e,
	0xd1, 0x17, 0x68, 0x96, 0x5d, 0x21, 0x4f, 0xa0, 0xfe, 0x22, 0x88, 0x7c, 0x62, 0x49, 0x54, 0xde,
	0x22, 0x76, 0x8a, 0x10, 0x5e, 0xf6, 0x76, 0x85, 0x3c, 0x86, 0xa6, 0x2c, 0x15, 0xf2, 0x40, 0x05,
	0x32, 0x2f, 0x9c, 0x1d, 0xf1, 0xa0, 0x2d, 0xff, 0x69, 0xa9, 0x90, 0x4f, 0xa1, 0xc1, 0x6b, 0x8d,
	0x6c, 0x2d, 0xeb, 0xee, 0x56, 0xc2, 0xe7, 0xb0, 0x51, 0xcc, 0x68, 0x22, 0xbb, 0xf9, 0x6a, 0x92,
	0xaf, 0xfe, 0xec, 0x71, 0x3e, 0xdb, 0xa4, 0x32, 0xc5, 0x3c, 0x59, 0x21, 0x1e, 0xeb, 0xfc, 0xef,
	0xa0, 0x67, 0xff, 0x0a, 0x00, 0x00, 0xff, 0xff, 0x37, 0x00, 0xe9, 0xd7, 0x1d, 0x1a, 0x00, 0x00,
}