dwebsocket

package
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.8.0

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 added in v0.8.0

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

Jump to

Keyboard shortcuts

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