subscription

package

Go to main page

Versions in this module

v0

v0.9.0

Mar 1, 2024

v0.8.0

Dec 11, 2023

Changes in this version

+ type BlockAPI interface

+ FreeFinalisedNotifierChannel func(ch chan *types.FinalisationInfo)

+ FreeImportedBlockNotifierChannel func(ch chan *types.Block)

+ GetFinalisedNotifierChannel func() chan *types.FinalisationInfo

+ GetImportedBlockNotifierChannel func() chan *types.Block

+ GetJustification func(hash common.Hash) ([]byte, error)

+ RegisterRuntimeUpdatedChannel func(ch chan<- runtime.Version) (uint32, error)

+ type CoreAPI interface

+ GetRuntimeVersion func(bhash *common.Hash) (runtime.Version, error)

+ HandleSubmittedExtrinsic func(types.Extrinsic) error

+ type StorageAPI interface

+ RegisterStorageObserver func(observer state.Observer)

+ UnregisterStorageObserver func(observer state.Observer)

+ type TransactionStateAPI interface

+ FreeStatusNotifierChannel func(ch chan transaction.Status)

+ GetStatusNotifierChannel func(ext types.Extrinsic) chan transaction.Status

v0.7.0

Nov 23, 2022

Changes in this version

+ const InvalidRequestCode

+ const InvalidRequestMessage

+ var ErrCannotCancel = errors.New("cannot cancel listening goroutines")

+ type AllBlocksListener struct

+ func (l *AllBlocksListener) Listen()

+ func (l *AllBlocksListener) Stop() error

type BlockFinalizedListener

+ func (l *BlockFinalizedListener) Stop() error

type BlockListener

+ func NewBlockListener(conn *WSConn) *BlockListener

+ func (l *BlockListener) Stop() error

+ type BooleanResponse struct

+ ID float64

+ JSONRPC string

+ Result bool

+ type Change [2]string

+ type ChangeResult struct

+ Block string

+ Changes []Change

type ExtrinsicSubmitListener

+ func NewExtrinsicSubmitListener(conn *WSConn, extBytes []byte, importedChan chan *types.Block, ...) *ExtrinsicSubmitListener

+ func (l *ExtrinsicSubmitListener) Stop() error

+ type GrandpaJustificationListener struct

+ func (g *GrandpaJustificationListener) Listen()

+ func (g *GrandpaJustificationListener) Stop() error

type Listener

+ Stop func() error

type ResponseJSON

+ func NewSubscriptionResponseJSON(subID uint32, reqID float64) ResponseJSON

type RuntimeVersionListener

+ func (*RuntimeVersionListener) Stop() error

+ func (l *RuntimeVersionListener) GetChannelID() uint32

+ type StorageObserver struct

+ func (*StorageObserver) Listen()

+ func (s *StorageObserver) GetFilter() map[string][]byte

+ func (s *StorageObserver) GetID() uint

+ func (s *StorageObserver) Stop() error

+ func (s *StorageObserver) Update(change *state.SubscriptionResult)

+ type VersionListener interface

+ GetChannelID func() uint32

type WSConn

+ HTTP httpclient

+ UnsafeEnabled bool

+ func (c *WSConn) HandleConn()

+ type WSConnAPI interface

v0.6.0

Apr 8, 2021

v0.5.2

Apr 7, 2021

v0.5.1

Apr 7, 2021

v0.5.0

Apr 7, 2021

v0.4.1

Apr 14, 2021

v0.4.0

Apr 6, 2021

v0.3.2

Mar 22, 2021

Changes in this version

+ const AuthorExtrinsicUpdates

+ type BaseResponseJSON struct

+ Jsonrpc string

+ Method string

+ Params Params

+ type BlockFinalizedListener struct

+ func (l *BlockFinalizedListener) Listen()

+ type BlockListener struct

+ ChanID byte

+ Channel chan *types.Block

+ func (l *BlockListener) Listen()

+ type ErrorMessageJSON struct

+ Code *big.Int

+ Message string

+ type ErrorResponseJSON struct

+ Error *ErrorMessageJSON

+ ID float64

+ Jsonrpc string

+ type ExtrinsicSubmitListener struct

+ func (l *ExtrinsicSubmitListener) Listen()

+ type Listener interface

+ Listen func()

+ type Params struct

+ Result interface{}

+ SubscriptionID int

+ type ResponseJSON struct

+ ID float64

+ Jsonrpc string

+ Result int

+ type RuntimeVersionListener struct

+ func (l *RuntimeVersionListener) Listen()

+ type StorageChangeListener struct

+ ChanID byte

+ Channel chan *state.SubscriptionResult

+ func (l *StorageChangeListener) Listen()

+ type WSConn struct

+ BlockAPI modules.BlockAPI

+ BlockSubChannels map[int]byte

+ CoreAPI modules.CoreAPI

+ RPCHost string

+ RuntimeAPI modules.RuntimeAPI

+ StorageAPI modules.StorageAPI

+ StorageSubChannels map[int]byte

+ Subscriptions map[int]Listener

+ TxStateAPI modules.TransactionStateAPI

+ Wsconn *websocket.Conn

+ func (c *WSConn) HandleComm()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL