pbx

package

Go to main page

Versions in this module

v0

v0.20.3

Oct 9, 2022

v0.20.2

Oct 9, 2022

v0.20.1

Oct 8, 2022

Changes in this version

+ var File_model_proto protoreflect.FileDescriptor

+ var Node_ServiceDesc = grpc.ServiceDesc

+ var Plugin_ServiceDesc = grpc.ServiceDesc

type AccessMode

+ func (x *AccessMode) ProtoReflect() protoreflect.Message

type AccountEvent

+ func (x *AccountEvent) ProtoReflect() protoreflect.Message

type AuthLevel

+ func (AuthLevel) Descriptor() protoreflect.EnumDescriptor

+ func (AuthLevel) Type() protoreflect.EnumType

+ func (x AuthLevel) Enum() *AuthLevel

+ func (x AuthLevel) Number() protoreflect.EnumNumber

type ClientAcc

+ func (x *ClientAcc) ProtoReflect() protoreflect.Message

type ClientCred

+ func (x *ClientCred) ProtoReflect() protoreflect.Message

type ClientDel

+ func (x *ClientDel) ProtoReflect() protoreflect.Message

type ClientDel_What

+ func (ClientDel_What) Descriptor() protoreflect.EnumDescriptor

+ func (ClientDel_What) Type() protoreflect.EnumType

+ func (x ClientDel_What) Enum() *ClientDel_What

+ func (x ClientDel_What) Number() protoreflect.EnumNumber

+ type ClientExtra struct

+ Attachments []string

+ AuthLevel AuthLevel

+ OnBehalfOf string

+ func (*ClientExtra) Descriptor() ([]byte, []int)

+ func (*ClientExtra) ProtoMessage()

+ func (x *ClientExtra) GetAttachments() []string

+ func (x *ClientExtra) GetAuthLevel() AuthLevel

+ func (x *ClientExtra) GetOnBehalfOf() string

+ func (x *ClientExtra) ProtoReflect() protoreflect.Message

+ func (x *ClientExtra) Reset()

+ func (x *ClientExtra) String() string

type ClientGet

+ func (x *ClientGet) ProtoReflect() protoreflect.Message

type ClientHi

+ Background bool

+ func (x *ClientHi) GetBackground() bool

+ func (x *ClientHi) ProtoReflect() protoreflect.Message

type ClientLeave

+ func (x *ClientLeave) ProtoReflect() protoreflect.Message

type ClientLogin

+ func (x *ClientLogin) ProtoReflect() protoreflect.Message

type ClientMsg

+ Extra *ClientExtra

+ func (x *ClientMsg) GetExtra() *ClientExtra

+ func (x *ClientMsg) ProtoReflect() protoreflect.Message

type ClientNote

+ func (x *ClientNote) ProtoReflect() protoreflect.Message

type ClientPub

+ func (x *ClientPub) ProtoReflect() protoreflect.Message

type ClientReq

+ func (x *ClientReq) ProtoReflect() protoreflect.Message

type ClientSet

+ func (x *ClientSet) ProtoReflect() protoreflect.Message

type ClientSub

+ func (x *ClientSub) ProtoReflect() protoreflect.Message

type Crud

+ func (Crud) Descriptor() protoreflect.EnumDescriptor

+ func (Crud) Type() protoreflect.EnumType

+ func (x Crud) Enum() *Crud

+ func (x Crud) Number() protoreflect.EnumNumber

type DefaultAcsMode

+ func (x *DefaultAcsMode) ProtoReflect() protoreflect.Message

type DelValues

+ func (x *DelValues) ProtoReflect() protoreflect.Message

type GetOpts

+ func (x *GetOpts) ProtoReflect() protoreflect.Message

type GetQuery

+ func (x *GetQuery) ProtoReflect() protoreflect.Message

type InfoNote

+ func (InfoNote) Descriptor() protoreflect.EnumDescriptor

+ func (InfoNote) Type() protoreflect.EnumType

+ func (x InfoNote) Enum() *InfoNote

+ func (x InfoNote) Number() protoreflect.EnumNumber

type MessageEvent

+ func (x *MessageEvent) ProtoReflect() protoreflect.Message

type RespCode

+ func (RespCode) Descriptor() protoreflect.EnumDescriptor

+ func (RespCode) Type() protoreflect.EnumType

+ func (x RespCode) Enum() *RespCode

+ func (x RespCode) Number() protoreflect.EnumNumber

type SearchFound

+ func (x *SearchFound) ProtoReflect() protoreflect.Message

type SearchQuery

+ func (x *SearchQuery) ProtoReflect() protoreflect.Message

type SeqRange

+ func (x *SeqRange) ProtoReflect() protoreflect.Message

type ServerCred

+ func (x *ServerCred) ProtoReflect() protoreflect.Message

type ServerCtrl

+ func (x *ServerCtrl) ProtoReflect() protoreflect.Message

type ServerData

+ func (x *ServerData) ProtoReflect() protoreflect.Message

type ServerInfo

+ Src string

+ func (x *ServerInfo) GetSrc() string

+ func (x *ServerInfo) ProtoReflect() protoreflect.Message

type ServerMeta

+ func (x *ServerMeta) ProtoReflect() protoreflect.Message

type ServerMsg

+ func (x *ServerMsg) ProtoReflect() protoreflect.Message

type ServerPres

+ func (x *ServerPres) ProtoReflect() protoreflect.Message

type ServerPres_What

+ func (ServerPres_What) Descriptor() protoreflect.EnumDescriptor

+ func (ServerPres_What) Type() protoreflect.EnumType

+ func (x ServerPres_What) Enum() *ServerPres_What

+ func (x ServerPres_What) Number() protoreflect.EnumNumber

type ServerResp

+ func (x *ServerResp) ProtoReflect() protoreflect.Message

type Session

+ func (x *Session) ProtoReflect() protoreflect.Message

type SetDesc

+ Trusted []byte

+ func (x *SetDesc) GetTrusted() []byte

+ func (x *SetDesc) ProtoReflect() protoreflect.Message

type SetQuery

+ func (x *SetQuery) ProtoReflect() protoreflect.Message

type SetSub

+ func (x *SetSub) ProtoReflect() protoreflect.Message

type SubscriptionEvent

+ func (x *SubscriptionEvent) ProtoReflect() protoreflect.Message

type TopicDesc

+ IsChan bool

+ LastSeenTime int64

+ LastSeenUserAgent string

+ Trusted []byte

+ func (x *TopicDesc) GetIsChan() bool

+ func (x *TopicDesc) GetLastSeenTime() int64

+ func (x *TopicDesc) GetLastSeenUserAgent() string

+ func (x *TopicDesc) GetTrusted() []byte

+ func (x *TopicDesc) ProtoReflect() protoreflect.Message

type TopicEvent

+ func (x *TopicEvent) ProtoReflect() protoreflect.Message

type TopicSub

+ Trusted []byte

+ func (x *TopicSub) GetTrusted() []byte

+ func (x *TopicSub) ProtoReflect() protoreflect.Message

+ type UnimplementedNodeServer struct

+ func (UnimplementedNodeServer) MessageLoop(Node_MessageLoopServer) error

+ type UnimplementedPluginServer struct

+ func (UnimplementedPluginServer) Account(context.Context, *AccountEvent) (*Unused, error)

+ func (UnimplementedPluginServer) Find(context.Context, *SearchQuery) (*SearchFound, error)

+ func (UnimplementedPluginServer) FireHose(context.Context, *ClientReq) (*ServerResp, error)

+ func (UnimplementedPluginServer) Message(context.Context, *MessageEvent) (*Unused, error)

+ func (UnimplementedPluginServer) Subscription(context.Context, *SubscriptionEvent) (*Unused, error)

+ func (UnimplementedPluginServer) Topic(context.Context, *TopicEvent) (*Unused, error)

+ type UnsafeNodeServer interface

+ type UnsafePluginServer interface

type Unused

+ func (x *Unused) ProtoReflect() protoreflect.Message

v0.16.4

Mar 13, 2020

Changes in this version

type ClientAcc

+ State string

+ func (m *ClientAcc) GetState() string

type TopicDesc

+ State string

+ StateAt int64

+ func (m *TopicDesc) GetState() string

+ func (m *TopicDesc) GetStateAt() int64

v0.16.3

Jan 21, 2020

Changes in this version

type ClientSub

+ Background bool

+ func (m *ClientSub) GetBackground() bool

v0.16.2

Nov 18, 2019

v0.16.1

Sep 20, 2019

v0.16.0

Aug 14, 2019

Changes in this version

+ type ClientCred struct

+ Method string

+ Params []byte

+ Response string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ClientCred) ProtoMessage()

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

+ func (m *ClientCred) GetMethod() string

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

+ func (m *ClientCred) GetResponse() string

+ func (m *ClientCred) GetValue() string

+ func (m *ClientCred) Reset()

+ func (m *ClientCred) String() string

+ func (m *ClientCred) XXX_DiscardUnknown()

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

+ func (m *ClientCred) XXX_Size() int

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

type ClientDel

+ Cred *ClientCred

+ func (m *ClientDel) GetCred() *ClientCred

type ClientDel_What

+ const ClientDel_CRED

+ type ServerCred struct

+ Done bool

+ Method string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ServerCred) ProtoMessage()

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

+ func (m *ServerCred) GetDone() bool

+ func (m *ServerCred) GetMethod() string

+ func (m *ServerCred) GetValue() string

+ func (m *ServerCred) Reset()

+ func (m *ServerCred) String() string

+ func (m *ServerCred) XXX_DiscardUnknown()

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

+ func (m *ServerCred) XXX_Size() int

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

type ServerMeta

+ Cred []*ServerCred

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

type ServerPres_What

+ const ServerPres_TAGS

type SetQuery

+ Cred *ClientCred

+ func (m *SetQuery) GetCred() *ClientCred

v0.15.14

Apr 10, 2019

v0.15.13

Mar 21, 2019

v0.15.12

Jan 29, 2019

Changes in this version

type ServerMeta

+ Tags []string

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

v0.15.11

Jan 6, 2019

Changes in this version

type ClientDel_What

+ const ClientDel_USER

v0.15.10

Dec 1, 2018

Changes in this version

type ServerData

+ Timestamp int64

+ func (m *ServerData) GetTimestamp() int64

v0.15.9

Nov 13, 2018

Changes in this version

type ClientHi

+ Platform string

+ func (m *ClientHi) GetPlatform() string

v0.15.8

Oct 26, 2018

v0.15.7

Oct 15, 2018

Changes in this version

+ var AuthLevel_name = map[int32]string

+ var AuthLevel_value = map[string]int32

+ type AuthLevel int32

+ const AuthLevel_ANON

+ const AuthLevel_AUTH

+ const AuthLevel_NONE

+ const AuthLevel_ROOT

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

+ func (x AuthLevel) String() string

type ClientAcc

+ Token []byte

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

type ClientMsg

+ AuthLevel AuthLevel

+ OnBehalfOf string

+ func (m *ClientMsg) GetAuthLevel() AuthLevel

+ func (m *ClientMsg) GetOnBehalfOf() string

type ServerMsg

+ Topic string

+ func (m *ServerMsg) GetTopic() string

v0.15.6

Sep 22, 2018

v0.15.5

Sep 3, 2018

v0.15.4

Aug 12, 2018

v0.15.3

Aug 1, 2018

v0.15.2

Jul 7, 2018

v0.15.1

Jun 6, 2018

v0.15.0

May 22, 2018

Changes in this version

type AccessMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AccessMode) XXX_DiscardUnknown()

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

+ func (m *AccessMode) XXX_Size() int

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

type AccountEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *AccountEvent) XXX_DiscardUnknown()

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

+ func (m *AccountEvent) XXX_Size() int

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

type ClientAcc

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientAcc) XXX_DiscardUnknown()

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

+ func (m *ClientAcc) XXX_Size() int

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

type ClientDel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientDel) XXX_DiscardUnknown()

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

+ func (m *ClientDel) XXX_Size() int

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

type ClientGet

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientGet) XXX_DiscardUnknown()

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

+ func (m *ClientGet) XXX_Size() int

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

type ClientHi

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientHi) XXX_DiscardUnknown()

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

+ func (m *ClientHi) XXX_Size() int

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

type ClientLeave

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientLeave) XXX_DiscardUnknown()

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

+ func (m *ClientLeave) XXX_Size() int

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

type ClientLogin

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientLogin) XXX_DiscardUnknown()

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

+ func (m *ClientLogin) XXX_Size() int

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

type ClientMsg

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientMsg) XXX_DiscardUnknown()

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

+ func (m *ClientMsg) XXX_Size() int

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

type ClientNote

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientNote) XXX_DiscardUnknown()

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

+ func (m *ClientNote) XXX_Size() int

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

type ClientPub

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientPub) XXX_DiscardUnknown()

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

+ func (m *ClientPub) XXX_Size() int

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

type ClientReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientReq) XXX_DiscardUnknown()

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

+ func (m *ClientReq) XXX_Size() int

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

type ClientSet

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientSet) XXX_DiscardUnknown()

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

+ func (m *ClientSet) XXX_Size() int

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

type ClientSub

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ClientSub) XXX_DiscardUnknown()

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

+ func (m *ClientSub) XXX_Size() int

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

type Credential

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Credential) XXX_Merge(src proto.Message)

+ func (m *Credential) XXX_DiscardUnknown()

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

+ func (m *Credential) XXX_Size() int

+ func (m *Credential) XXX_Unmarshal(b []byte) error

type DefaultAcsMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DefaultAcsMode) XXX_DiscardUnknown()

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

+ func (m *DefaultAcsMode) XXX_Size() int

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

type DelValues

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *DelValues) XXX_DiscardUnknown()

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

+ func (m *DelValues) XXX_Size() int

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

type GetOpts

+ BeforeId int32

+ SinceId int32

+ Topic string

+ User string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *GetOpts) GetBeforeId() int32

+ func (m *GetOpts) GetSinceId() int32

+ func (m *GetOpts) GetTopic() string

+ func (m *GetOpts) GetUser() string

+ func (m *GetOpts) XXX_DiscardUnknown()

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

+ func (m *GetOpts) XXX_Size() int

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

type GetQuery

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *GetQuery) XXX_DiscardUnknown()

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

+ func (m *GetQuery) XXX_Size() int

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

type MessageEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *MessageEvent) XXX_DiscardUnknown()

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

+ func (m *MessageEvent) XXX_Size() int

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

type SearchFound

+ Query string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SearchFound) GetQuery() string

+ func (m *SearchFound) XXX_DiscardUnknown()

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

+ func (m *SearchFound) XXX_Size() int

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

type SearchQuery

+ Query string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SearchQuery) GetQuery() string

+ func (m *SearchQuery) XXX_DiscardUnknown()

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

+ func (m *SearchQuery) XXX_Size() int

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

type SeqRange

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SeqRange) XXX_DiscardUnknown()

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

+ func (m *SeqRange) XXX_Size() int

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

type ServerCtrl

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerCtrl) XXX_DiscardUnknown()

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

+ func (m *ServerCtrl) XXX_Size() int

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

type ServerData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerData) XXX_DiscardUnknown()

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

+ func (m *ServerData) XXX_Size() int

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

type ServerInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerInfo) XXX_DiscardUnknown()

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

+ func (m *ServerInfo) XXX_Size() int

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

type ServerMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerMeta) XXX_DiscardUnknown()

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

+ func (m *ServerMeta) XXX_Size() int

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

type ServerMsg

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerMsg) XXX_DiscardUnknown()

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

+ func (m *ServerMsg) XXX_Size() int

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

type ServerPres

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerPres) XXX_DiscardUnknown()

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

+ func (m *ServerPres) XXX_Size() int

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

type ServerResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *ServerResp) XXX_DiscardUnknown()

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

+ func (m *ServerResp) XXX_Size() int

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

type Session

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *Session) XXX_DiscardUnknown()

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

+ func (m *Session) XXX_Size() int

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

type SetDesc

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SetDesc) XXX_DiscardUnknown()

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

+ func (m *SetDesc) XXX_Size() int

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

type SetQuery

+ Tags []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

+ func (m *SetQuery) XXX_DiscardUnknown()

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

+ func (m *SetQuery) XXX_Size() int

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

type SetSub

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SetSub) XXX_DiscardUnknown()

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

+ func (m *SetSub) XXX_Size() int

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

type SubscriptionEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *SubscriptionEvent) XXX_DiscardUnknown()

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

+ func (m *SubscriptionEvent) XXX_Size() int

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

type TopicDesc

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TopicDesc) XXX_DiscardUnknown()

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

+ func (m *TopicDesc) XXX_Size() int

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

type TopicEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TopicEvent) XXX_DiscardUnknown()

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

+ func (m *TopicEvent) XXX_Size() int

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

type TopicSub

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TopicSub) XXX_DiscardUnknown()

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

+ func (m *TopicSub) XXX_Size() int

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

type Unused

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *Unused) XXX_DiscardUnknown()

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

+ func (m *Unused) XXX_Size() int

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

v0.14.6

Apr 27, 2018

Changes in this version

type TopicDesc

+ TouchedAt int64

+ func (m *TopicDesc) GetTouchedAt() int64

type TopicSub

+ TouchedAt int64

+ func (m *TopicSub) GetTouchedAt() int64

v0.14.5

Apr 19, 2018

v0.14.4

Apr 16, 2018

Changes in this version

type ClientAcc

+ Cred []*Credential

+ func (m *ClientAcc) GetCred() []*Credential

type ClientLogin

+ Cred []*Credential

+ func (m *ClientLogin) GetCred() []*Credential

+ type Credential struct

+ Method string

+ Params []byte

+ Response string

+ Value string

+ func (*Credential) Descriptor() ([]byte, []int)

+ func (*Credential) ProtoMessage()

+ func (m *Credential) GetMethod() string

+ func (m *Credential) GetParams() []byte

+ func (m *Credential) GetResponse() string

+ func (m *Credential) GetValue() string

+ func (m *Credential) Reset()

+ func (m *Credential) String() string

v0.14.2

Feb 27, 2018

Changes in this version

+ var RespCode_name = map[int32]string

+ var RespCode_value = map[string]int32

type ClientDel

+ DelSeq []*SeqRange

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

+ type DelValues struct

+ DelId int32

+ DelSeq []*SeqRange

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

+ func (*DelValues) ProtoMessage()

+ func (m *DelValues) GetDelId() int32

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

+ func (m *DelValues) Reset()

+ func (m *DelValues) String() string

type MessageEvent

+ Msg *ServerData

+ func (m *MessageEvent) GetMsg() *ServerData

type PluginClient

+ Find func(ctx context.Context, in *SearchQuery, opts ...grpc.CallOption) (*SearchFound, error)

type PluginServer

+ Find func(context.Context, *SearchQuery) (*SearchFound, error)

+ type RespCode int32

+ const RespCode_CONTINUE

+ const RespCode_DROP

+ const RespCode_REPLACE

+ const RespCode_RESPOND

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

+ func (x RespCode) String() string

+ type SearchFound struct

+ Result []*TopicSub

+ Status RespCode

+ Terms []string

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

+ func (*SearchFound) ProtoMessage()

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

+ func (m *SearchFound) GetStatus() RespCode

+ func (m *SearchFound) GetTerms() []string

+ func (m *SearchFound) Reset()

+ func (m *SearchFound) String() string

+ type SearchQuery struct

+ Terms []string

+ UserId string

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

+ func (*SearchQuery) ProtoMessage()

+ func (m *SearchQuery) GetTerms() []string

+ func (m *SearchQuery) GetUserId() string

+ func (m *SearchQuery) Reset()

+ func (m *SearchQuery) String() string

+ type SeqRange struct

+ Hi int32

+ Low int32

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

+ func (*SeqRange) ProtoMessage()

+ func (m *SeqRange) GetHi() int32

+ func (m *SeqRange) GetLow() int32

+ func (m *SeqRange) Reset()

+ func (m *SeqRange) String() string

type ServerMeta

+ Del *DelValues

+ func (m *ServerMeta) GetDel() *DelValues

type ServerPres

+ DelId int32

+ DelSeq []*SeqRange

+ func (m *ServerPres) GetDelId() int32

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

type SubscriptionEvent

+ DelId int32

+ Mode *AccessMode

+ Private []byte

+ ReadId int32

+ RecvId int32

+ Topic string

+ UserId string

+ func (m *SubscriptionEvent) GetDelId() int32

+ func (m *SubscriptionEvent) GetMode() *AccessMode

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

+ func (m *SubscriptionEvent) GetReadId() int32

+ func (m *SubscriptionEvent) GetRecvId() int32

+ func (m *SubscriptionEvent) GetTopic() string

+ func (m *SubscriptionEvent) GetUserId() string

type TopicDesc

+ DelId int32

+ func (m *TopicDesc) GetDelId() int32

type TopicSub

+ DelId int32

+ func (m *TopicSub) GetDelId() int32

v0.13.1

Nov 28, 2017

Changes in this version

+ var ClientDel_What_name = map[int32]string

+ var ClientDel_What_value = map[string]int32

+ var Crud_name = map[int32]string

+ var Crud_value = map[string]int32

+ var InfoNote_name = map[int32]string

+ var InfoNote_value = map[string]int32

+ var ServerPres_What_name = map[int32]string

+ var ServerPres_What_value = map[string]int32

+ var ServerResp_RespCode_name = map[int32]string

+ var ServerResp_RespCode_value = map[string]int32

+ var Session_AuthLevel_name = map[int32]string

+ var Session_AuthLevel_value = map[string]int32

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

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

+ type AccessMode struct

+ Given string

+ Want string

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

+ func (*AccessMode) ProtoMessage()

+ func (m *AccessMode) GetGiven() string

+ func (m *AccessMode) GetWant() string

+ func (m *AccessMode) Reset()

+ func (m *AccessMode) String() string

+ type AccountEvent struct

+ Action Crud

+ DefaultAcs *DefaultAcsMode

+ Public []byte

+ Tags []string

+ UserId string

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

+ func (*AccountEvent) ProtoMessage()

+ func (m *AccountEvent) GetAction() Crud

+ func (m *AccountEvent) GetDefaultAcs() *DefaultAcsMode

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

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

+ func (m *AccountEvent) GetUserId() string

+ func (m *AccountEvent) Reset()

+ func (m *AccountEvent) String() string

+ type BrowseOpts struct

+ BeforeId int32

+ BeforeTs int64

+ Limit int32

+ SinceId int32

+ SinceTs int64

+ func (*BrowseOpts) Descriptor() ([]byte, []int)

+ func (*BrowseOpts) ProtoMessage()

+ func (m *BrowseOpts) GetBeforeId() int32

+ func (m *BrowseOpts) GetBeforeTs() int64

+ func (m *BrowseOpts) GetLimit() int32

+ func (m *BrowseOpts) GetSinceId() int32

+ func (m *BrowseOpts) GetSinceTs() int64

+ func (m *BrowseOpts) Reset()

+ func (m *BrowseOpts) String() string

+ type ClientAcc struct

+ Desc *SetDesc

+ Id string

+ Login bool

+ Scheme string

+ Secret []byte

+ Tags []string

+ UserId string

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

+ func (*ClientAcc) ProtoMessage()

+ func (m *ClientAcc) GetDesc() *SetDesc

+ func (m *ClientAcc) GetId() string

+ func (m *ClientAcc) GetLogin() bool

+ func (m *ClientAcc) GetScheme() string

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

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

+ func (m *ClientAcc) GetUserId() string

+ func (m *ClientAcc) Reset()

+ func (m *ClientAcc) String() string

+ type ClientDel struct

+ Before int32

+ Hard bool

+ Id string

+ SeqList []int32

+ Topic string

+ UserId string

+ What ClientDel_What

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

+ func (*ClientDel) ProtoMessage()

+ func (m *ClientDel) GetBefore() int32

+ func (m *ClientDel) GetHard() bool

+ func (m *ClientDel) GetId() string

+ func (m *ClientDel) GetSeqList() []int32

+ func (m *ClientDel) GetTopic() string

+ func (m *ClientDel) GetUserId() string

+ func (m *ClientDel) GetWhat() ClientDel_What

+ func (m *ClientDel) Reset()

+ func (m *ClientDel) String() string

+ type ClientDel_What int32

+ const ClientDel_MSG

+ const ClientDel_SUB

+ const ClientDel_TOPIC

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

+ func (x ClientDel_What) String() string

+ type ClientGet struct

+ Id string

+ Query *GetQuery

+ Topic string

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

+ func (*ClientGet) ProtoMessage()

+ func (m *ClientGet) GetId() string

+ func (m *ClientGet) GetQuery() *GetQuery

+ func (m *ClientGet) GetTopic() string

+ func (m *ClientGet) Reset()

+ func (m *ClientGet) String() string

+ type ClientHi struct

+ DeviceId string

+ Id string

+ Lang string

+ UserAgent string

+ Ver int32

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

+ func (*ClientHi) ProtoMessage()

+ func (m *ClientHi) GetDeviceId() string

+ func (m *ClientHi) GetId() string

+ func (m *ClientHi) GetLang() string

+ func (m *ClientHi) GetUserAgent() string

+ func (m *ClientHi) GetVer() int32

+ func (m *ClientHi) Reset()

+ func (m *ClientHi) String() string

+ type ClientLeave struct

+ Id string

+ Topic string

+ Unsub bool

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

+ func (*ClientLeave) ProtoMessage()

+ func (m *ClientLeave) GetId() string

+ func (m *ClientLeave) GetTopic() string

+ func (m *ClientLeave) GetUnsub() bool

+ func (m *ClientLeave) Reset()

+ func (m *ClientLeave) String() string

+ type ClientLogin struct

+ Id string

+ Scheme string

+ Secret []byte

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

+ func (*ClientLogin) ProtoMessage()

+ func (m *ClientLogin) GetId() string

+ func (m *ClientLogin) GetScheme() string

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

+ func (m *ClientLogin) Reset()

+ func (m *ClientLogin) String() string

+ type ClientMsg struct

+ Message isClientMsg_Message

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

+ func (*ClientMsg) ProtoMessage()

+ func (*ClientMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ClientMsg) GetAcc() *ClientAcc

+ func (m *ClientMsg) GetDel() *ClientDel

+ func (m *ClientMsg) GetGet() *ClientGet

+ func (m *ClientMsg) GetHi() *ClientHi

+ func (m *ClientMsg) GetLeave() *ClientLeave

+ func (m *ClientMsg) GetLogin() *ClientLogin

+ func (m *ClientMsg) GetMessage() isClientMsg_Message

+ func (m *ClientMsg) GetNote() *ClientNote

+ func (m *ClientMsg) GetPub() *ClientPub

+ func (m *ClientMsg) GetSet() *ClientSet

+ func (m *ClientMsg) GetSub() *ClientSub

+ func (m *ClientMsg) Reset()

+ func (m *ClientMsg) String() string

+ type ClientMsg_Acc struct

+ Acc *ClientAcc

+ type ClientMsg_Del struct

+ Del *ClientDel

+ type ClientMsg_Get struct

+ Get *ClientGet

+ type ClientMsg_Hi struct

+ Hi *ClientHi

+ type ClientMsg_Leave struct

+ Leave *ClientLeave

+ type ClientMsg_Login struct

+ Login *ClientLogin

+ type ClientMsg_Note struct

+ Note *ClientNote

+ type ClientMsg_Pub struct

+ Pub *ClientPub

+ type ClientMsg_Set struct

+ Set *ClientSet

+ type ClientMsg_Sub struct

+ Sub *ClientSub

+ type ClientNote struct

+ SeqId int32

+ Topic string

+ What InfoNote

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

+ func (*ClientNote) ProtoMessage()

+ func (m *ClientNote) GetSeqId() int32

+ func (m *ClientNote) GetTopic() string

+ func (m *ClientNote) GetWhat() InfoNote

+ func (m *ClientNote) Reset()

+ func (m *ClientNote) String() string

+ type ClientPub struct

+ Content []byte

+ Head map[string]string

+ Id string

+ NoEcho bool

+ Topic string

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

+ func (*ClientPub) ProtoMessage()

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

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

+ func (m *ClientPub) GetId() string

+ func (m *ClientPub) GetNoEcho() bool

+ func (m *ClientPub) GetTopic() string

+ func (m *ClientPub) Reset()

+ func (m *ClientPub) String() string

+ type ClientReq struct

+ Msg *ClientMsg

+ Sess *Session

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

+ func (*ClientReq) ProtoMessage()

+ func (m *ClientReq) GetMsg() *ClientMsg

+ func (m *ClientReq) GetSess() *Session

+ func (m *ClientReq) Reset()

+ func (m *ClientReq) String() string

+ type ClientSet struct

+ Id string

+ Query *SetQuery

+ Topic string

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

+ func (*ClientSet) ProtoMessage()

+ func (m *ClientSet) GetId() string

+ func (m *ClientSet) GetQuery() *SetQuery

+ func (m *ClientSet) GetTopic() string

+ func (m *ClientSet) Reset()

+ func (m *ClientSet) String() string

+ type ClientSub struct

+ GetQuery *GetQuery

+ Id string

+ SetQuery *SetQuery

+ Topic string

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

+ func (*ClientSub) ProtoMessage()

+ func (m *ClientSub) GetGetQuery() *GetQuery

+ func (m *ClientSub) GetId() string

+ func (m *ClientSub) GetSetQuery() *SetQuery

+ func (m *ClientSub) GetTopic() string

+ func (m *ClientSub) Reset()

+ func (m *ClientSub) String() string

+ type Crud int32

+ const Crud_CREATE

+ const Crud_DELETE

+ const Crud_UPDATE

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

+ func (x Crud) String() string

+ type DefaultAcsMode struct

+ Anon string

+ Auth string

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

+ func (*DefaultAcsMode) ProtoMessage()

+ func (m *DefaultAcsMode) GetAnon() string

+ func (m *DefaultAcsMode) GetAuth() string

+ func (m *DefaultAcsMode) Reset()

+ func (m *DefaultAcsMode) String() string

+ type GetOpts struct

+ IfModifiedSince int64

+ Limit int32

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

+ func (*GetOpts) ProtoMessage()

+ func (m *GetOpts) GetIfModifiedSince() int64

+ func (m *GetOpts) GetLimit() int32

+ func (m *GetOpts) Reset()

+ func (m *GetOpts) String() string

+ type GetQuery struct

+ Data *BrowseOpts

+ Desc *GetOpts

+ Sub *GetOpts

+ What string

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

+ func (*GetQuery) ProtoMessage()

+ func (m *GetQuery) GetData() *BrowseOpts

+ func (m *GetQuery) GetDesc() *GetOpts

+ func (m *GetQuery) GetSub() *GetOpts

+ func (m *GetQuery) GetWhat() string

+ func (m *GetQuery) Reset()

+ func (m *GetQuery) String() string

+ type InfoNote int32

+ const InfoNote_KP

+ const InfoNote_READ

+ const InfoNote_RECV

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

+ func (x InfoNote) String() string

+ type MessageEvent struct

+ Action Crud

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

+ func (*MessageEvent) ProtoMessage()

+ func (m *MessageEvent) GetAction() Crud

+ func (m *MessageEvent) Reset()

+ func (m *MessageEvent) String() string

+ type NodeClient interface

+ MessageLoop func(ctx context.Context, opts ...grpc.CallOption) (Node_MessageLoopClient, error)

+ func NewNodeClient(cc *grpc.ClientConn) NodeClient

+ type NodeServer interface

+ MessageLoop func(Node_MessageLoopServer) error

+ type Node_MessageLoopClient interface

+ Recv func() (*ServerMsg, error)

+ Send func(*ClientMsg) error

+ type Node_MessageLoopServer interface

+ Recv func() (*ClientMsg, error)

+ Send func(*ServerMsg) error

+ type PluginClient interface

+ Account func(ctx context.Context, in *AccountEvent, opts ...grpc.CallOption) (*Unused, error)

+ FireHose func(ctx context.Context, in *ClientReq, opts ...grpc.CallOption) (*ServerResp, error)

+ Message func(ctx context.Context, in *MessageEvent, opts ...grpc.CallOption) (*Unused, error)

+ Subscription func(ctx context.Context, in *SubscriptionEvent, opts ...grpc.CallOption) (*Unused, error)

+ Topic func(ctx context.Context, in *TopicEvent, opts ...grpc.CallOption) (*Unused, error)

+ func NewPluginClient(cc *grpc.ClientConn) PluginClient

+ type PluginServer interface

+ Account func(context.Context, *AccountEvent) (*Unused, error)

+ FireHose func(context.Context, *ClientReq) (*ServerResp, error)

+ Message func(context.Context, *MessageEvent) (*Unused, error)

+ Subscription func(context.Context, *SubscriptionEvent) (*Unused, error)

+ Topic func(context.Context, *TopicEvent) (*Unused, error)

+ type ServerCtrl struct

+ Code int32

+ Id string

+ Params map[string][]byte

+ Text string

+ Topic string

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

+ func (*ServerCtrl) ProtoMessage()

+ func (m *ServerCtrl) GetCode() int32

+ func (m *ServerCtrl) GetId() string

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

+ func (m *ServerCtrl) GetText() string

+ func (m *ServerCtrl) GetTopic() string

+ func (m *ServerCtrl) Reset()

+ func (m *ServerCtrl) String() string

+ type ServerData struct

+ Content []byte

+ DeletedAt int64

+ FromUserId string

+ Head map[string]string

+ SeqId int32

+ Topic string

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

+ func (*ServerData) ProtoMessage()

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

+ func (m *ServerData) GetDeletedAt() int64

+ func (m *ServerData) GetFromUserId() string

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

+ func (m *ServerData) GetSeqId() int32

+ func (m *ServerData) GetTopic() string

+ func (m *ServerData) Reset()

+ func (m *ServerData) String() string

+ type ServerInfo struct

+ FromUserId string

+ SeqId int32

+ Topic string

+ What InfoNote

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

+ func (*ServerInfo) ProtoMessage()

+ func (m *ServerInfo) GetFromUserId() string

+ func (m *ServerInfo) GetSeqId() int32

+ func (m *ServerInfo) GetTopic() string

+ func (m *ServerInfo) GetWhat() InfoNote

+ func (m *ServerInfo) Reset()

+ func (m *ServerInfo) String() string

+ type ServerMeta struct

+ Desc *TopicDesc

+ Id string

+ Sub []*TopicSub

+ Topic string

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

+ func (*ServerMeta) ProtoMessage()

+ func (m *ServerMeta) GetDesc() *TopicDesc

+ func (m *ServerMeta) GetId() string

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

+ func (m *ServerMeta) GetTopic() string

+ func (m *ServerMeta) Reset()

+ func (m *ServerMeta) String() string

+ type ServerMsg struct

+ Message isServerMsg_Message

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

+ func (*ServerMsg) ProtoMessage()

+ func (*ServerMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ServerMsg) GetCtrl() *ServerCtrl

+ func (m *ServerMsg) GetData() *ServerData

+ func (m *ServerMsg) GetInfo() *ServerInfo

+ func (m *ServerMsg) GetMessage() isServerMsg_Message

+ func (m *ServerMsg) GetMeta() *ServerMeta

+ func (m *ServerMsg) GetPres() *ServerPres

+ func (m *ServerMsg) Reset()

+ func (m *ServerMsg) String() string

+ type ServerMsg_Ctrl struct

+ Ctrl *ServerCtrl

+ type ServerMsg_Data struct

+ Data *ServerData

+ type ServerMsg_Info struct

+ Info *ServerInfo

+ type ServerMsg_Meta struct

+ Meta *ServerMeta

+ type ServerMsg_Pres struct

+ Pres *ServerPres

+ type ServerPres struct

+ Acs *AccessMode

+ ActorUserId string

+ SeqId int32

+ SeqList []int32

+ Src string

+ TargetUserId string

+ Topic string

+ UserAgent string

+ What ServerPres_What

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

+ func (*ServerPres) ProtoMessage()

+ func (m *ServerPres) GetAcs() *AccessMode

+ func (m *ServerPres) GetActorUserId() string

+ func (m *ServerPres) GetSeqId() int32

+ func (m *ServerPres) GetSeqList() []int32

+ func (m *ServerPres) GetSrc() string

+ func (m *ServerPres) GetTargetUserId() string

+ func (m *ServerPres) GetTopic() string

+ func (m *ServerPres) GetUserAgent() string

+ func (m *ServerPres) GetWhat() ServerPres_What

+ func (m *ServerPres) Reset()

+ func (m *ServerPres) String() string

+ type ServerPres_What int32

+ const ServerPres_ACS

+ const ServerPres_DEL

+ const ServerPres_GONE

+ const ServerPres_MSG

+ const ServerPres_OFF

+ const ServerPres_ON

+ const ServerPres_READ

+ const ServerPres_RECV

+ const ServerPres_TERM

+ const ServerPres_UA

+ const ServerPres_UPD

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

+ func (x ServerPres_What) String() string

+ type ServerResp struct

+ Clmsg *ClientMsg

+ Srvmsg *ServerMsg

+ Status ServerResp_RespCode

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

+ func (*ServerResp) ProtoMessage()

+ func (m *ServerResp) GetClmsg() *ClientMsg

+ func (m *ServerResp) GetSrvmsg() *ServerMsg

+ func (m *ServerResp) GetStatus() ServerResp_RespCode

+ func (m *ServerResp) Reset()

+ func (m *ServerResp) String() string

+ type ServerResp_RespCode int32

+ const ServerResp_CONTINUE

+ const ServerResp_DROP

+ const ServerResp_REPLACE

+ const ServerResp_RESPOND

+ func (ServerResp_RespCode) EnumDescriptor() ([]byte, []int)

+ func (x ServerResp_RespCode) String() string

+ type Session struct

+ AuthLevel Session_AuthLevel

+ DeviceId string

+ Language string

+ RemoteAddr string

+ SessionId string

+ UserAgent string

+ UserId string

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

+ func (*Session) ProtoMessage()

+ func (m *Session) GetAuthLevel() Session_AuthLevel

+ func (m *Session) GetDeviceId() string

+ func (m *Session) GetLanguage() string

+ func (m *Session) GetRemoteAddr() string

+ func (m *Session) GetSessionId() string

+ func (m *Session) GetUserAgent() string

+ func (m *Session) GetUserId() string

+ func (m *Session) Reset()

+ func (m *Session) String() string

+ type Session_AuthLevel int32

+ const Session_ANON

+ const Session_AUTH

+ const Session_NONE

+ const Session_ROOT

+ func (Session_AuthLevel) EnumDescriptor() ([]byte, []int)

+ func (x Session_AuthLevel) String() string

+ type SetDesc struct

+ DefaultAcs *DefaultAcsMode

+ Private []byte

+ Public []byte

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

+ func (*SetDesc) ProtoMessage()

+ func (m *SetDesc) GetDefaultAcs() *DefaultAcsMode

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

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

+ func (m *SetDesc) Reset()

+ func (m *SetDesc) String() string

+ type SetQuery struct

+ Desc *SetDesc

+ Sub *SetSub

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

+ func (*SetQuery) ProtoMessage()

+ func (m *SetQuery) GetDesc() *SetDesc

+ func (m *SetQuery) GetSub() *SetSub

+ func (m *SetQuery) Reset()

+ func (m *SetQuery) String() string

+ type SetSub struct

+ Mode string

+ UserId string

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

+ func (*SetSub) ProtoMessage()

+ func (m *SetSub) GetMode() string

+ func (m *SetSub) GetUserId() string

+ func (m *SetSub) Reset()

+ func (m *SetSub) String() string

+ type SubscriptionEvent struct

+ Action Crud

+ Sub *TopicSub

+ SubId string

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

+ func (*SubscriptionEvent) ProtoMessage()

+ func (m *SubscriptionEvent) GetAction() Crud

+ func (m *SubscriptionEvent) GetSub() *TopicSub

+ func (m *SubscriptionEvent) GetSubId() string

+ func (m *SubscriptionEvent) Reset()

+ func (m *SubscriptionEvent) String() string

+ type TopicDesc struct

+ Acs *AccessMode

+ ClearId int32

+ CreatedAt int64

+ Defacs *DefaultAcsMode

+ Private []byte

+ Public []byte

+ ReadId int32

+ RecvId int32

+ SeqId int32

+ UpdatedAt int64

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

+ func (*TopicDesc) ProtoMessage()

+ func (m *TopicDesc) GetAcs() *AccessMode

+ func (m *TopicDesc) GetClearId() int32

+ func (m *TopicDesc) GetCreatedAt() int64

+ func (m *TopicDesc) GetDefacs() *DefaultAcsMode

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

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

+ func (m *TopicDesc) GetReadId() int32

+ func (m *TopicDesc) GetRecvId() int32

+ func (m *TopicDesc) GetSeqId() int32

+ func (m *TopicDesc) GetUpdatedAt() int64

+ func (m *TopicDesc) Reset()

+ func (m *TopicDesc) String() string

+ type TopicEvent struct

+ Action Crud

+ Desc *TopicDesc

+ Name string

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

+ func (*TopicEvent) ProtoMessage()

+ func (m *TopicEvent) GetAction() Crud

+ func (m *TopicEvent) GetDesc() *TopicDesc

+ func (m *TopicEvent) GetName() string

+ func (m *TopicEvent) Reset()

+ func (m *TopicEvent) String() string

+ type TopicSub struct

+ Acs *AccessMode

+ ClearId int32

+ DeletedAt int64

+ LastSeenTime int64

+ LastSeenUserAgent string

+ Online bool

+ Private []byte

+ Public []byte

+ ReadId int32

+ RecvId int32

+ SeqId int32

+ Topic string

+ UpdatedAt int64

+ UserId string

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

+ func (*TopicSub) ProtoMessage()

+ func (m *TopicSub) GetAcs() *AccessMode

+ func (m *TopicSub) GetClearId() int32

+ func (m *TopicSub) GetDeletedAt() int64

+ func (m *TopicSub) GetLastSeenTime() int64

+ func (m *TopicSub) GetLastSeenUserAgent() string

+ func (m *TopicSub) GetOnline() bool

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

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

+ func (m *TopicSub) GetReadId() int32

+ func (m *TopicSub) GetRecvId() int32

+ func (m *TopicSub) GetSeqId() int32

+ func (m *TopicSub) GetTopic() string

+ func (m *TopicSub) GetUpdatedAt() int64

+ func (m *TopicSub) GetUserId() string

+ func (m *TopicSub) Reset()

+ func (m *TopicSub) String() string

+ type Unused struct

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

+ func (*Unused) ProtoMessage()

+ func (m *Unused) Reset()

+ func (m *Unused) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL