webds

package module

Go to main page

Versions in this module

v0

v0.2.5

May 16, 2020

Changes in this version

type Config

+ MsgPrefix []byte

+ func (c *Config) Ctx() context.Context

+ func (c *Config) MsgSerializer() *message.Serializer

+ func (c *Config) Webds() core.Webds

v0.2.4

May 10, 2020

Changes in this version

type Config

+ EnableCluster bool

+ ID string

type Connection

+ Alive func() bool

+ Type func() uint

+ type Masters []*serverMaster

+ func (m Masters) Search(url string) *serverMaster

+ type SampleConn interface

+ Alive func() bool

+ ID func() string

+ Server func() *Server

+ Type func() uint

type Server

+ func (s *Server) ID() string

v0.2.3

Apr 8, 2020

v0.2.2

Apr 7, 2020

Changes in this version

+ var ErrID = errors.New("id is not exist")

+ var ErrOrigin = errors.New("error origin")

type Config

+ LateralMaster []string

+ NewConn func(server *Server, w http.ResponseWriter, r *http.Request) (Connection, error)

+ SuperiorMaster []string

type Connection

+ func NewConn(s *Server, w http.ResponseWriter, r *http.Request) (Connection, error)

+ Echo func(topic string, data interface{}) error

+ On func(topic string, callback message.Func)

+ Request func() *http.Request

+ type RowConn = connection

v0.2.1

Feb 12, 2020

Changes in this version

+ var ErrDuplicatedClient = errors.New("duplicated client")

v0.2.0

Feb 11, 2020

Changes in this version

+ const DefaultEvtMessageKey

+ const DefaultWebsocketMaxMessageSize

+ const DefaultWebsocketPingPeriod

+ const DefaultWebsocketPongTimeout

+ const DefaultWebsocketReadBufferSize

+ const DefaultWebsocketReadTimeout

+ const DefaultWebsocketWriteTimeout

+ const DefaultWebsocketWriterBufferSize

+ const WriteWait

+ var UnformedMsg = errors.New("unformed Msg")

+ func DefaultIDGenerator(*http.Request) string

+ type Config struct

+ BinaryMessages bool

+ CheckOrigin func(r *http.Request) bool

+ EnableCompression bool

+ Error func(w http.ResponseWriter, r *http.Request, status int, reason error)

+ EvtMessagePrefix []byte

+ HandshakeTimeout time.Duration

+ IDGenerator func(r *http.Request) string

+ MaxMessageSize int64

+ PingPeriod time.Duration

+ PongTimeout time.Duration

+ ReadBufferSize int

+ ReadTimeout time.Duration

+ Subprotocols []string

+ WriteBufferSize int

+ WriteTimeout time.Duration

+ func (c Config) Validate() Config

+ type Connection interface

+ CancelSubscribe func(string)

+ Disconnect func(error) error

+ FireOnError func(err error)

+ ID func() string

+ IsSubscribe func(string) bool

+ OnDisconnect func(DisconnectFunc)

+ OnError func(ErrorFunc)

+ OnInner func(string, MessageFunc)

+ Publisher func(string) Publisher

+ Server func() *Server

+ Subscribe func(string)

+ Wait func()

+ type ConnectionFunc func(Connection)

+ type DisconnectFunc func()

+ type ErrorFunc func(error)

+ type LeaveRoomFunc func(roomName string)

+ type MessageFunc interface

+ type PingFunc func()

+ type PongFunc func()

+ type Publisher interface

+ Pub func(interface{}) error

+ type Server struct

+ func New(cfg Config) *Server

+ func (s *Server) Broadcast(topic trie.Trie, msg []byte) error

+ func (s *Server) CancelAll(id string)

+ func (s *Server) CancelSubscribe(topic, id string)

+ func (s *Server) Disconnect(id string) error

+ func (s *Server) GetConnection(id string) *connection

+ func (s *Server) GetConnections() []Connection

+ func (s *Server) GetConnectionsByTopic(topic string) []Connection

+ func (s *Server) IsConnected(id string) bool

+ func (s *Server) IsSubscribe(topic string, id string) bool

+ func (s *Server) LenConnections() (n int)

+ func (s *Server) OnConnection(cb ConnectionFunc)

+ func (s *Server) Subscribe(topic string, id string)

+ func (s *Server) Upgrade(w http.ResponseWriter, r *http.Request) (*connection, error)

v0.1.0

Feb 6, 2020

Changes in this version

+ const Version

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