Versions in this module Expand all Collapse all v8 v8.0.2 Jun 27, 2022 v8.0.1 Jun 27, 2022 Changes in this version + const NewTxBufferSize + const PingInterval + func DisableLog() + func UseLogger(logger slog.Logger) + func Version() semver.Semver + type PubSubHub struct + func NewPubSubHub(dataSource wsDataSource) (*PubSubHub, error) + func (psh *PubSubHub) HubRelay() chan pstypes.HubMessage + func (psh *PubSubHub) MempoolInventory() *exptypes.MempoolInfo + func (psh *PubSubHub) Ready() bool + func (psh *PubSubHub) SetReady(ready bool) + func (psh *PubSubHub) StopWebsocketHub() + func (psh *PubSubHub) Store(blockData *blockdata.BlockData, msgBlock *wire.MsgBlock) error + func (psh *PubSubHub) StoreMPData(_ *mempool.StakeData, _ []exptypes.MempoolTx, inv *exptypes.MempoolInfo) + func (psh *PubSubHub) WebSocketHandler(w http.ResponseWriter, r *http.Request) + type State struct + BlockInfo *exptypes.BlockInfo + BlockchainInfo *chainjson.GetBlockChainInfoResult + GeneralInfo *exptypes.HomeInfo + type WebsocketHub struct + HubRelay chan pstypes.HubMessage + Register chan *clientHubSpoke + Unregister chan *hubSpoke + func NewWebsocketHub() *WebsocketHub + func (wsh *WebsocketHub) NewClientHubSpoke() *clientHubSpoke + func (wsh *WebsocketHub) NumClients() int + func (wsh *WebsocketHub) Ready() bool + func (wsh *WebsocketHub) Run() + func (wsh *WebsocketHub) SetReady(ready bool) + func (wsh *WebsocketHub) SetTimeToSendTxBuffer(ready bool) + func (wsh *WebsocketHub) Stop() + func (wsh *WebsocketHub) TimeToSendTxBuffer() bool + func (wsh *WebsocketHub) UnregisterClient(ch *clientHubSpoke) Other modules containing this package github.com/Decred-Next/dcrndata/pubsub/v8
Go to main page