subscription

type AllBlocksListener struct {
	// contains filtered or unexported fields
}

type BaseResponseJSON struct {
	Jsonrpc string `json:"jsonrpc"`
	Method  string `json:"method"`
	Params  Params `json:"params"`
}

type BlockAPI interface {
	GetJustification(hash common.Hash) ([]byte, error)
	GetImportedBlockNotifierChannel() chan *types.Block
	FreeImportedBlockNotifierChannel(ch chan *types.Block)
	GetFinalisedNotifierChannel() chan *types.FinalisationInfo
	FreeFinalisedNotifierChannel(ch chan *types.FinalisationInfo)
	RegisterRuntimeUpdatedChannel(ch chan<- runtime.Version) (uint32, error)
}

type BlockFinalizedListener struct {
	// contains filtered or unexported fields
}

type BlockListener struct {
	Channel chan *types.Block
	// contains filtered or unexported fields
}

type BooleanResponse struct {
	JSONRPC string  `json:"jsonrpc"`
	Result  bool    `json:"result"`
	ID      float64 `json:"id"`
}

type Change [2]string

type ChangeResult struct {
	Changes []Change `json:"changes"`
	Block   string   `json:"block"`
}

type CoreAPI interface {
	GetRuntimeVersion(bhash *common.Hash) (runtime.Version, error)
	HandleSubmittedExtrinsic(types.Extrinsic) error
}

type ErrorMessageJSON struct {
	Code    *big.Int `json:"code"`
	Message string   `json:"message"`
}

type ErrorResponseJSON struct {
	Jsonrpc string            `json:"jsonrpc"`
	Error   *ErrorMessageJSON `json:"error"`
	ID      float64           `json:"id"`
}

type ExtrinsicSubmitListener struct {
	// contains filtered or unexported fields
}

type GrandpaJustificationListener struct {
	// contains filtered or unexported fields
}

type Listener interface {
	Listen()
	Stop() error
}

type Params struct {
	Result         interface{} `json:"result"`
	SubscriptionID uint32      `json:"subscription"`
}

type ResponseJSON struct {
	Jsonrpc string  `json:"jsonrpc"`
	Result  uint32  `json:"result"`
	ID      float64 `json:"id"`
}

type RuntimeVersionListener struct {
	// contains filtered or unexported fields
}

type StorageAPI interface {
	RegisterStorageObserver(observer state.Observer)
	UnregisterStorageObserver(observer state.Observer)
}

type StorageObserver struct {
	// contains filtered or unexported fields
}

type TransactionStateAPI interface {
	GetStatusNotifierChannel(ext types.Extrinsic) chan transaction.Status
	FreeStatusNotifierChannel(ch chan transaction.Status)
}

type WSConn struct {
	UnsafeEnabled bool
	Wsconn        *websocket.Conn

	Subscriptions map[uint32]Listener
	StorageAPI    StorageAPI
	BlockAPI      BlockAPI
	CoreAPI       CoreAPI
	TxStateAPI    TransactionStateAPI
	RPCHost       string
	HTTP          httpclient
	// contains filtered or unexported fields
}

type WSConnAPI interface {
	// contains filtered or unexported methods
}