websocket_plugin

Documentation

Index

• type Session
  • func (s *Session) Get(key string) (interface{}, bool)
  • func (s *Session) Set(key string, value interface{})
• type WebsocketConfig
• type WebsocketController
  • func (w *WebsocketController) Bean() string
  • func (w *WebsocketController) Channel(r *http.Request, rw http.ResponseWriter)
  • func (w *WebsocketController) Group() string
• type WebsocketHandler
• type WebsocketStarter
  • func NewStarter() *WebsocketStarter
  • func (w *WebsocketStarter) Init() error

Types

type Session

type Session struct {
	*websocket.Conn
	HttpSession *http.Request
	Context     context.Context
	// contains filtered or unexported fields
}

func (*Session) Get

func (s *Session) Get(key string) (interface{}, bool)

func (*Session) Set

func (s *Session) Set(key string, value interface{})

type WebsocketConfig

type WebsocketConfig struct {
	types.AutoConfigure `prefix:"websocket"`
	WriteWait           time.Duration `yaml:"write_wait"`         // Time allowed to write a message to the peer.
	MaxMessageSize      int64         `yaml:"max_message_size"`   // Maximum message size allowed from peer.
	PongWait            time.Duration `yaml:"pong_wait"`          // Time allowed to read the next pong message from the peer.
	PingPeriod          time.Duration `yaml:"ping_period"`        // Send pings to peer with this period. Must be less than pongWait.
	CloseGracePeriod    time.Duration `yaml:"close_grace_period"` // Time to wait before force close on connection.
	CheckOrigin         bool          `yaml:"check_origin"`
}

WebsocketConfig is websocket config

type WebsocketController

type WebsocketController struct {
	types.Component

	Config *WebsocketConfig
	// contains filtered or unexported fields
}

WebsocketController is decorate dynamic controller

func (*WebsocketController) Bean

func (w *WebsocketController) Bean() string

func (*WebsocketController) Channel

func (w *WebsocketController) Channel(r *http.Request, rw http.ResponseWriter)

func (*WebsocketController) Group

func (w *WebsocketController) Group() string

type WebsocketHandler

type WebsocketHandler interface {
	bean.Bean
	Endpoint() string
	OnOpen(session *Session)
	OnClose(session *Session)
	OnMessage(session *Session, message []byte) error
	OnError(session *Session, err error)
}

WebsocketHandler bean define

type WebsocketStarter

type WebsocketStarter struct {
	types.Component
	Handlers []WebsocketHandler `wire:""`
	Log      log.Logger         `wire:""`
}

func NewStarter

func NewStarter() *WebsocketStarter

func (*WebsocketStarter) Init

func (w *WebsocketStarter) Init() error