dwebsocket

Documentation

Index

• Constants
• type CloseHandler
• type DefaultSession
  • func NewDefaultServerSession(ctx context.Context, writer http.ResponseWriter, req *http.Request) (*DefaultSession, error)
  • func (s *DefaultSession) Close()
  • func (s *DefaultSession) Done() <-chan struct{}
  • func (s *DefaultSession) IsOK() bool
  • func (s *DefaultSession) RemoteAddr() string
  • func (s *DefaultSession) SendBinary(data []byte)
  • func (s *DefaultSession) SendControl(messageType int, data []byte, deadline time.Time) error
  • func (s *DefaultSession) SendJson(data interface{})
  • func (s *DefaultSession) SendRaw(data []byte)
  • func (s *DefaultSession) SetCloseHandler(closeHandler CloseHandler)
  • func (s *DefaultSession) SetPingHandler(pingHandler PingHandler)
  • func (s *DefaultSession) SetPongHandler(pongHandler PongHandler)
  • func (s *DefaultSession) SetReadHandler(readHandler ReadHandler)
  • func (s *DefaultSession) UpdateLastCommTime()
• type PingHandler
• type PongHandler
• type Pusher
  • func NewServer() *Pusher
  • func (wp *Pusher) AddSession(c *gin.Context, session Session) error
  • func (wp *Pusher) Close()
  • func (wp *Pusher) Push(data interface{})
  • func (wp *Pusher) PushBinary(data []byte)
• type ReadHandler
• type Session

Constants

const (
	INIT         state = 0
	CONNECTED    state = 1
	DISCONNECTED state = 2
)

Types

type CloseHandler

type CloseHandler = func(code int, text string) error

type DefaultSession

type DefaultSession struct {
	// contains filtered or unexported fields
}

func NewDefaultServerSession

func NewDefaultServerSession(ctx context.Context, writer http.ResponseWriter, req *http.Request) (*DefaultSession, error)

func (*DefaultSession) Close

func (s *DefaultSession) Close()

func (*DefaultSession) Done

func (s *DefaultSession) Done() <-chan struct{}

func (*DefaultSession) IsOK

func (s *DefaultSession) IsOK() bool

func (*DefaultSession) RemoteAddr

func (s *DefaultSession) RemoteAddr() string

func (*DefaultSession) SendBinary

func (s *DefaultSession) SendBinary(data []byte)

func (*DefaultSession) SendControl

func (s *DefaultSession) SendControl(messageType int, data []byte, deadline time.Time) error

func (*DefaultSession) SendJson

func (s *DefaultSession) SendJson(data interface{})

func (*DefaultSession) SendRaw

func (s *DefaultSession) SendRaw(data []byte)

func (*DefaultSession) SetCloseHandler

func (s *DefaultSession) SetCloseHandler(closeHandler CloseHandler)

func (*DefaultSession) SetPingHandler

func (s *DefaultSession) SetPingHandler(pingHandler PingHandler)

func (*DefaultSession) SetPongHandler

func (s *DefaultSession) SetPongHandler(pongHandler PongHandler)

func (*DefaultSession) SetReadHandler

func (s *DefaultSession) SetReadHandler(readHandler ReadHandler)

func (*DefaultSession) UpdateLastCommTime

func (s *DefaultSession) UpdateLastCommTime()

type PingHandler

type PingHandler = func(appData string) error

type PongHandler

type PongHandler = func(appData string) error

type Pusher

type Pusher struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Pusher

func (*Pusher) AddSession

func (wp *Pusher) AddSession(c *gin.Context, session Session) error

func (*Pusher) Close

func (wp *Pusher) Close()

func (*Pusher) Push

func (wp *Pusher) Push(data interface{})

func (*Pusher) PushBinary

func (wp *Pusher) PushBinary(data []byte)

type ReadHandler

type ReadHandler = func(appData string)

type Session

type Session interface {
	SetPingHandler(pingHandler PingHandler)
	SetPongHandler(pongHandler PongHandler)
	SetCloseHandler(closeHandler CloseHandler)
	SendJson(data interface{})
	SendRaw(data []byte)
	SendBinary(data []byte)
	SendControl(messageType int, data []byte, deadline time.Time) error
	RemoteAddr() string
	IsOK() bool
	Close()
	Done() <-chan struct{}
}