libcentrifugo

Jun 27, 2016

Changes in this version

+ const RedisAPIKeySuffix

+ const RedisAdminChannelSuffix

+ const RedisControlChannelSuffix

+ const RedisJoinChannelPrefix

+ const RedisLeaveChannelPrefix

+ const RedisMessageChannelPrefix

+ var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")

+ type AdminMessage struct

+ Method string

+ Params *github_com_centrifugal_centrifugo_libcentrifugo_raw.Raw

+ UID string

+ func NewPopulatedAdminMessage(r randyMessage, easy bool) *AdminMessage

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

+ func (*AdminMessage) ProtoMessage()

+ func (m *AdminMessage) GetMethod() string

+ func (m *AdminMessage) GetUID() string

+ func (m *AdminMessage) Marshal() (data []byte, err error)

+ func (m *AdminMessage) MarshalTo(data []byte) (int, error)

+ func (m *AdminMessage) Reset()

+ func (m *AdminMessage) Size() (n int)

+ func (m *AdminMessage) String() string

+ func (m *AdminMessage) Unmarshal(data []byte) error

+ func (this *AdminMessage) Equal(that interface{}) bool

type ClientInfo

+ func NewPopulatedClientInfo(r randyMessage, easy bool) *ClientInfo

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

+ func (*ClientInfo) ProtoMessage()

+ func (m *ClientInfo) GetClient() string

+ func (m *ClientInfo) GetUser() string

+ func (m *ClientInfo) Marshal() (data []byte, err error)

+ func (m *ClientInfo) MarshalTo(data []byte) (int, error)

+ func (m *ClientInfo) Reset()

+ func (m *ClientInfo) Size() (n int)

+ func (m *ClientInfo) String() string

+ func (m *ClientInfo) Unmarshal(data []byte) error

+ func (this *ClientInfo) Equal(that interface{}) bool

+ type ControlMessage struct

+ Method string

+ Params *github_com_centrifugal_centrifugo_libcentrifugo_raw.Raw

+ UID string

+ func NewPopulatedControlMessage(r randyMessage, easy bool) *ControlMessage

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

+ func (*ControlMessage) ProtoMessage()

+ func (m *ControlMessage) GetMethod() string

+ func (m *ControlMessage) GetUID() string

+ func (m *ControlMessage) Marshal() (data []byte, err error)

+ func (m *ControlMessage) MarshalTo(data []byte) (int, error)

+ func (m *ControlMessage) Reset()

+ func (m *ControlMessage) Size() (n int)

+ func (m *ControlMessage) String() string

+ func (m *ControlMessage) Unmarshal(data []byte) error

+ func (this *ControlMessage) Equal(that interface{}) bool

+ type JoinMessage struct

+ Channel string

+ Data ClientInfo

+ func NewPopulatedJoinMessage(r randyMessage, easy bool) *JoinMessage

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

+ func (*JoinMessage) ProtoMessage()

+ func (m *JoinMessage) GetChannel() string

+ func (m *JoinMessage) GetData() ClientInfo

+ func (m *JoinMessage) Marshal() (data []byte, err error)

+ func (m *JoinMessage) MarshalTo(data []byte) (int, error)

+ func (m *JoinMessage) Reset()

+ func (m *JoinMessage) Size() (n int)

+ func (m *JoinMessage) String() string

+ func (m *JoinMessage) Unmarshal(data []byte) error

+ func (this *JoinMessage) Equal(that interface{}) bool

+ type LeaveMessage struct

+ Channel string

+ Data ClientInfo

+ func NewPopulatedLeaveMessage(r randyMessage, easy bool) *LeaveMessage

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

+ func (*LeaveMessage) ProtoMessage()

+ func (m *LeaveMessage) GetChannel() string

+ func (m *LeaveMessage) GetData() ClientInfo

+ func (m *LeaveMessage) Marshal() (data []byte, err error)

+ func (m *LeaveMessage) MarshalTo(data []byte) (int, error)

+ func (m *LeaveMessage) Reset()

+ func (m *LeaveMessage) Size() (n int)

+ func (m *LeaveMessage) String() string

+ func (m *LeaveMessage) Unmarshal(data []byte) error

+ func (this *LeaveMessage) Equal(that interface{}) bool

type Message

+ func NewPopulatedMessage(r randyMessage, easy bool) *Message

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

+ func (*Message) ProtoMessage()

+ func (m *Message) GetChannel() string

+ func (m *Message) GetClient() string

+ func (m *Message) GetInfo() *ClientInfo

+ func (m *Message) GetTimestamp() string

+ func (m *Message) GetUID() string

+ func (m *Message) Marshal() (data []byte, err error)

+ func (m *Message) MarshalTo(data []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(data []byte) error

+ func (this *Message) Equal(that interface{}) bool

Mar 27, 2016

Changes in this version

+ const AdminWebsocketReadBufferSize

+ const AdminWebsocketWriteBufferSize

+ const RedisPublishBatchLimit

+ const RedisPublishChannelSize

type Config

+ Admin bool

+ AdminPassword string

+ AdminSecret string

+ InsecureAdmin bool

type MuxOptions

+ Admin bool

type RedisEngineConfig

+ ConnectTimeout time.Duration

+ MasterName string

+ ReadTimeout time.Duration

+ SentinelAddrs []string

+ WriteTimeout time.Duration

Feb 19, 2016

Changes in this version

type Config

+ ClientRequestMaxSize int

type Metrics

+ func (m *Metrics) GetRawCounts() *Metrics

+ func (m *Metrics) UpdateSnapshot()

+ type NodeBody struct

+ Data NodeInfo

Jan 27, 2016

Changes in this version

type Config

+ ClientChannelLimit int

Jan 15, 2016

Changes in this version

type Config

+ ClientQueueInitialCapacity int

+ ClientQueueMaxSize int

Jan 9, 2016

Changes in this version

+ var ErrAlreadySubscribed = errors.New("already subscribed")

Dec 27, 2015

Changes in this version

+ const RedisSubscribeBatchLimit

+ const RedisSubscribeChannelSize

type ChannelOptions

+ HistoryDropInactive bool

type Config

+ InsecureWeb bool

+ Web bool

+ type DisconnectBody struct

+ Reason string

+ Reconnect bool

+ type HandlerFlag int

+ const HandlerAPI

+ const HandlerAdmin

+ const HandlerDebug

+ const HandlerRawWS

+ const HandlerSockJS

+ func (flags HandlerFlag) String() string

type MuxOptions

+ HandlerFlags HandlerFlag

type NodeInfo

+ UID string

+ type RedisEngineConfig struct

+ API bool

+ DB string

+ Host string

+ NumAPIShards int

+ Password string

+ PoolSize int

+ Port string

+ URL string

Dec 6, 2015

Changes in this version

type ChannelOptions

+ Recover bool

+ type MessageID string

type SubscribeBody

+ Last MessageID

+ Messages []Message

+ Recovered bool

type SubscribeClientCommand

+ Last MessageID

+ Recover bool

Nov 5, 2015

Changes in this version

type Config

+ MaxClientQueueSize int

Oct 27, 2015

Changes in this version

type Config

+ ConnLifetime int64

+ InsecureAPI bool

+ Namespaces []Namespace

+ NodeMetricsInterval time.Duration

+ Secret string

+ StaleConnectionCloseDelay time.Duration

+ func (c *Config) Validate() error

+ type ConnectBody struct

+ Client ConnID

+ Expired bool

+ Expires bool

+ TTL int64

+ Version string

+ type ConnectClientCommand struct

+ Info string

+ Timestamp string

+ Token string

+ User UserID

+ type HistoryClientCommand struct

+ Channel Channel

+ type JoinLeaveBody struct

+ Channel Channel

+ Data ClientInfo

+ type Metrics struct

+ BytesClientIn int64

+ BytesClientOut int64

+ CPU int64

+ MemSys int64

+ NumAPIRequests int64

+ NumClientRequests int64

+ NumMsgPublished int64

+ NumMsgQueued int64

+ NumMsgSent int64

+ TimeAPIMax int64

+ TimeAPIMean int64

+ TimeClientMax int64

+ TimeClientMean int64

type MuxOptions

+ Web bool

+ WebFS http.FileSystem

+ WebPath string

+ type NodeInfo struct

+ Channels int

+ Clients int

+ Gomaxprocs int

+ Goroutines int

+ Name string

+ NumCPU int

+ Started int64

+ Uid string

+ Unique int

+ type PingBody struct

+ Data string

+ type PingClientCommand struct

+ Data string

+ type PresenceClientCommand struct

+ Channel Channel

+ type PublishBody struct

+ Channel Channel

+ Status bool

+ type PublishClientCommand struct

+ Channel Channel

+ Data json.RawMessage

+ type RefreshClientCommand struct

+ Info string

+ Timestamp string

+ Token string

+ User UserID

+ type Stats struct

+ MetricsInterval int64

+ Nodes []NodeInfo

+ type StatsBody struct

+ Data Stats

+ type SubscribeBody struct

+ Channel Channel

+ Status bool

+ type SubscribeClientCommand struct

+ Channel Channel

+ Client ConnID

+ Info string

+ Sign string

+ type UnsubscribeBody struct

+ Channel Channel

+ Status bool

+ type UnsubscribeClientCommand struct

+ Channel Channel

Sep 20, 2015

Changes in this version

+ var DefaultMuxOptions = MuxOptions

+ type ChannelsBody struct

+ Data []Channel

type Config

+ Debug bool

+ PingInterval time.Duration

+ type MuxOptions struct

+ Prefix string

+ SockjsOptions sockjs.Options

+ WebDir string

Aug 26, 2015

Changes in this version

+ type HistoryBody struct

+ Channel Channel

+ Data []Message

+ type PresenceBody struct

+ Channel Channel

+ Data map[ConnID]ClientInfo

Jul 23, 2015

Changes in this version

type Application

+ func (app *Application) APIHandler(w http.ResponseWriter, r *http.Request)

Jun 25, 2015

Changes in this version

type Message

+ UID string

Jun 14, 2015

Changes in this version

+ const CloseStatus

+ var DefaultConfig = &Config

+ var ErrClientClosed = errors.New("client is closed")

+ var ErrInvalidMessage = errors.New("invalid message")

+ var ErrRejected = errors.New("command rejected")

+ var ErrSendTimeout = errors.New("send timeout")

+ func DefaultMux(app *Application, prefix, webDir, sockjsURL string) *http.ServeMux

+ func NewSockJSHandler(app *Application, sockjsPrefix, sockjsUrl string) http.Handler

+ type Application struct

+ func NewApplication(c *Config) (*Application, error)

+ func (app *Application) ActionHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) AdminWebsocketHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) ApiHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) AuthHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) Authenticated(h http.Handler) http.Handler

+ func (app *Application) Disconnect(pk ProjectKey, user UserID) error

+ func (app *Application) History(pk ProjectKey, ch Channel) ([]Message, error)

+ func (app *Application) InfoHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) Logged(h http.Handler) http.Handler

+ func (app *Application) Presence(pk ProjectKey, ch Channel) (map[ConnID]ClientInfo, error)

+ func (app *Application) Publish(pk ProjectKey, ch Channel, data []byte, client ConnID, info *ClientInfo) error

+ func (app *Application) RawWebsocketHandler(w http.ResponseWriter, r *http.Request)

+ func (app *Application) Run()

+ func (app *Application) SetConfig(c *Config)

+ func (app *Application) SetEngine(e Engine)

+ func (app *Application) SetMediator(m Mediator)

+ func (app *Application) SetStructure(s *Structure)

+ func (app *Application) Shutdown()

+ func (app *Application) Unsubscribe(pk ProjectKey, user UserID, ch Channel) error

+ func (app *Application) WrapShutdown(h http.Handler) http.Handler

+ type Config struct

+ AdminChannel ChannelID

+ ChannelPrefix string

+ ClientChannelBoundary string

+ ControlChannel ChannelID

+ ExpiredConnectionCloseDelay int64

+ Insecure bool

+ MaxChannelLength int

+ MessageSendTimeout int64

+ Name string

+ NamespaceChannelBoundary string

+ NodeInfoCleanInterval int64

+ NodeInfoMaxDelay int64

+ NodePingInterval int64

+ PresenceExpireInterval int64

+ PresencePingInterval int64

+ PrivateChannelPrefix string

+ UserChannelBoundary string

+ UserChannelSeparator string

+ Version string

+ WebPassword string

+ WebSecret string

+ type Engine interface

+ type Mediator interface

+ Connect func(pk ProjectKey, info ClientInfo) bool

+ Disconnect func(pk ProjectKey, info ClientInfo)

+ Message func(pk ProjectKey, ch Channel, data []byte, client ConnID, info *ClientInfo, ...) bool

+ Subscribe func(pk ProjectKey, ch Channel, info ClientInfo) bool

+ Unsubscribe func(pk ProjectKey, ch Channel, info ClientInfo)

+ type MemoryEngine struct

+ func NewMemoryEngine(app *Application) *MemoryEngine

type Message

+ Client ConnID

+ type Namespace struct

+ Name NamespaceKey

+ type Project struct

+ ConnLifetime int64

+ Name ProjectKey

+ Namespaces []Namespace

+ Secret string

+ type RedisEngine struct

+ func NewRedisEngine(app *Application, host, port, password, db, redisURL string, api bool, ...) *RedisEngine

+ type Structure struct

+ func NewStructure(pl []Project) *Structure

+ func (s *Structure) Validate() error

May 30, 2015

Changes in this version

+ type Channel string

+ type ChannelID string

+ type ClientInfo struct

+ ChannelInfo *json.RawMessage

+ Client ConnID

+ DefaultInfo *json.RawMessage

+ User UserID

+ type ConnID string

+ type Message struct

+ Channel Channel

+ Data *json.RawMessage

+ Info *ClientInfo

+ Timestamp string

+ Uid string

+ type NamespaceKey string

+ type ProjectKey string

+ type UserID string

May 23, 2015

Changes in this version

+ const AuthTokenKey

+ const AuthTokenValue

+ const VERSION

+ var ErrConnectionExpired = errors.New("connection expired")

+ var ErrInternalServerError = errors.New("internal server error")

+ var ErrInvalidAdminMessage = errors.New("invalid admin message")

+ var ErrInvalidApiMessage = errors.New("invalid API message")

+ var ErrInvalidClientMessage = errors.New("invalid client message")

+ var ErrInvalidControlMessage = errors.New("invalid control message")

+ var ErrInvalidToken = errors.New("invalid token")

+ var ErrLimitExceeded = errors.New("limit exceeded")

+ var ErrMethodNotFound = errors.New("method not found")

+ var ErrNamespaceNotFound = errors.New("namespace not found")

+ var ErrNotAvailable = errors.New("not available")

+ var ErrPermissionDenied = errors.New("permission denied")

+ var ErrProjectNotFound = errors.New("project not found")

+ var ErrUnauthorized = errors.New("unauthorized")

+ func Main()

+ type ChannelOptions struct

+ Anonymous bool

+ HistoryLifetime int64

+ HistorySize int64

+ JoinLeave bool

+ Presence bool

+ Publish bool

+ Watch bool