Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

websocket

package

Go to main page

Versions in this module

v1

v1.4.0

Apr 21, 2025

Changes in this version

type Manager

+ func (manager *Manager) InitRoutes(srvr *echo.Group)

v1.3.0

Dec 16, 2024

v1.2.0

Nov 9, 2024

v1.1.0

Oct 27, 2024

v1.0.0

Sep 14, 2024

Changes in this version

+ const ChannelBlocks

+ const ChannelHead

+ const MethodSubscribe

+ const MethodUnsubscribe

+ var ErrUnavailableFilter = errors.New("unknown filter value")

+ var ErrUnknownChannel = errors.New("unknown channel")

+ var ErrUnknownMethod = errors.New("unknown method")

+ type BlockFilter struct

+ func (f BlockFilter) Filter(c client, msg Notification[*responses.Block]) bool

+ type Channel struct

+ func NewChannel[I any, M INotification](processor processor[I, M], filters Filterable[M]) *Channel[I, M]

+ func (channel *Channel[I, M]) AddClient(c client)

+ func (channel *Channel[I, M]) RemoveClient(id uint64)

+ type Client struct

+ func (c *Client) ApplyFilters(msg Subscribe) error

+ func (c *Client) Close() error

+ func (c *Client) DetachFilters(msg Unsubscribe) error

+ func (c *Client) Filters() *Filters

+ func (c *Client) Id() uint64

+ func (c *Client) Notify(msg any)

+ func (c *Client) ReadMessages(ctx context.Context, ws *websocket.Conn, sub *Client, log echo.Logger)

+ func (c *Client) WriteMessages(ctx context.Context, ws *websocket.Conn, log echo.Logger)

+ type Filterable interface

+ Filter func(c client, msg Notification[M]) bool

+ type Filters struct

+ type HeadFilter struct

+ func (f HeadFilter) Filter(c client, msg Notification[*responses.State]) bool

+ type INotification interface

+ type Manager struct

+ func NewManager(observer *bus.Observer) *Manager

+ func (manager *Manager) AddClientToChannel(channel string, client *Client)

+ func (manager *Manager) Close() error

+ func (manager *Manager) Handle(c echo.Context) error

+ func (manager *Manager) RemoveClientFromChannel(channel string, client *Client)

+ func (manager *Manager) Start(ctx context.Context)

+ type Message struct

+ Body json.RawMessage

+ Method string

+ type Notification struct

+ Body T

+ Channel string

+ func NewBlockNotification(block responses.Block) Notification[*responses.Block]

+ func NewStateNotification(state responses.State) Notification[*responses.State]

+ type Subscribe struct

+ Channel string

+ Filters json.RawMessage

+ type TransactionFilters struct

+ Actions []string

+ Status []string

+ type Unsubscribe struct

+ Channel string