websocket

Aug 23, 2024

Changes in this version

+ const ChannelGasPrice

+ type GasPriceFilter struct

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

type Manager

+ func (manager *Manager) GasTrackerHandler(_ context.Context, state gas.GasPrice) error

type Notification

+ func NewGasPriceNotification(value responses.GasPrice) Notification[*responses.GasPrice]

Aug 13, 2024

Changes in this version

+ type ClientHandler func(string, *Client)

Feb 12, 2024

Changes in this version

+ const ChannelBlocks

+ type BlockFilter struct

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

+ type INotification interface

+ type Notification struct

+ Body T

+ Channel string

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

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

Oct 31, 2023

Changes in this version

+ const ChannelHead

+ const ChannelTx

+ const MethodSubscribe

+ const MethodUnsubscribe

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

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

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

+ func HeadProcessor(ctx context.Context, payload string, repo identifiable[storage.Block]) (*responses.Block, error)

+ func TxProcessor(ctx context.Context, payload string, repo identifiable[storage.Tx]) (*responses.Tx, error)

+ type Channel struct

+ func NewChannel[I, M any](storageChannelName string, processor processor[I, M], repo identifiable[I], ...) *Channel[I, M]

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

+ func (channel *Channel[I, M]) Close() error

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

+ func (channel *Channel[I, M]) Start(ctx context.Context, factory storage.ListenerFactory)

+ func (channel *Channel[I, M]) String() string

+ 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 M) bool

+ type Filters struct

+ type HeadFilter struct

+ func (hf HeadFilter) Filter(c client, msg *responses.Block) bool

+ type Manager struct

+ func NewManager(factory storage.ListenerFactory, blockRepo storage.IBlock, txRepo storage.ITx) *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 Subscribe struct

+ Channel string

+ Filters json.RawMessage

+ type TransactionFilters struct

+ Messages []string

+ Status []string

+ type TxFilter struct

+ func (hf TxFilter) Filter(c client, msg *responses.Tx) bool

+ type Unsubscribe struct

+ Channel string