Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

melody

package module

Go to main page

Versions in this module

v1

v1.2.1

Apr 16, 2024

Changes in this version

type Session

+ func (s *Session) WebsocketConnection() *websocket.Conn

v1.2.0

Mar 30, 2024

v1.1.5

Mar 6, 2024

Changes in this version

type Config

+ ConcurrentMessageHandling bool

v1.1.4

Jul 1, 2023

v1.1.3

Mar 14, 2023

Changes in this version

type Session

+ func (s *Session) UnSet(key string)

v1.1.2

Mar 8, 2023

v1.1.1

Sep 30, 2022

v1.1.0

Sep 14, 2022

Changes in this version

+ const CloseAbnormalClosure

+ const CloseGoingAway

+ const CloseInternalServerErr

+ const CloseInvalidFramePayloadData

+ const CloseMandatoryExtension

+ const CloseMessageTooBig

+ const CloseNoStatusReceived

+ const CloseNormalClosure

+ const ClosePolicyViolation

+ const CloseProtocolError

+ const CloseServiceRestart

+ const CloseTLSHandshake

+ const CloseTryAgainLater

+ const CloseUnsupportedData

+ var ErrClosed = errors.New("melody instance is closed")

+ var ErrMessageBufferFull = errors.New("session message buffer is full")

+ var ErrSessionClosed = errors.New("session is closed")

+ var ErrWriteClosed = errors.New("tried to write to closed a session")

+ func FormatCloseMessage(closeCode int, text string) []byte

+ type Config struct

+ MaxMessageSize int64

+ MessageBufferSize int

+ PingPeriod time.Duration

+ PongWait time.Duration

+ WriteWait time.Duration

+ type Melody struct

+ Config *Config

+ Upgrader *websocket.Upgrader

+ func New() *Melody

+ func (m *Melody) Broadcast(msg []byte) error

+ func (m *Melody) BroadcastBinary(msg []byte) error

+ func (m *Melody) BroadcastBinaryFilter(msg []byte, fn func(*Session) bool) error

+ func (m *Melody) BroadcastBinaryOthers(msg []byte, s *Session) error

+ func (m *Melody) BroadcastFilter(msg []byte, fn func(*Session) bool) error

+ func (m *Melody) BroadcastMultiple(msg []byte, sessions []*Session) error

+ func (m *Melody) BroadcastOthers(msg []byte, s *Session) error

+ func (m *Melody) Close() error

+ func (m *Melody) CloseWithMsg(msg []byte) error

+ func (m *Melody) HandleClose(fn func(*Session, int, string) error)

+ func (m *Melody) HandleConnect(fn func(*Session))

+ func (m *Melody) HandleDisconnect(fn func(*Session))

+ func (m *Melody) HandleError(fn func(*Session, error))

+ func (m *Melody) HandleMessage(fn func(*Session, []byte))

+ func (m *Melody) HandleMessageBinary(fn func(*Session, []byte))

+ func (m *Melody) HandlePong(fn func(*Session))

+ func (m *Melody) HandleRequest(w http.ResponseWriter, r *http.Request) error

+ func (m *Melody) HandleRequestWithKeys(w http.ResponseWriter, r *http.Request, keys map[string]interface{}) error

+ func (m *Melody) HandleSentMessage(fn func(*Session, []byte))

+ func (m *Melody) HandleSentMessageBinary(fn func(*Session, []byte))

+ func (m *Melody) IsClosed() bool

+ func (m *Melody) Len() int

+ func (m *Melody) Sessions() ([]*Session, error)

+ type Session struct

+ Keys map[string]interface{}

+ Request *http.Request

+ func (s *Session) Close() error

+ func (s *Session) CloseWithMsg(msg []byte) error

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

+ func (s *Session) IsClosed() bool

+ func (s *Session) LocalAddr() net.Addr

+ func (s *Session) MustGet(key string) interface{}

+ func (s *Session) RemoteAddr() net.Addr

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

+ func (s *Session) Write(msg []byte) error

+ func (s *Session) WriteBinary(msg []byte) error