mpseth

Documentation

Index

• Variables
• type ClientOp
• type FeedPacket
• type FeedType
• type Remote
  • func NewRemote(c *websocket.Conn, logger log.Logger) *Remote
  • func (r *Remote) FeedBlockedTxHash(hashes []common.Hash) error
  • func (r *Remote) FeedChainConfig(config *params.ChainConfig) error
  • func (r *Remote) FeedNewTx(txs types.Transactions) error
  • func (r *Remote) FeedResponse(id int, ok bool, msg string) error
  • func (r *Remote) RecvLoop() error
  • func (r *Remote) Serve(cfg *params.ChainConfig) error
  • func (r *Remote) Stop()
• type RequestPacket
• type ResponsePacket
• type Server
  • func New(pool txSub, bc blockchain, logger log.Logger) *Server
  • func (a *Server) Start() error
  • func (a *Server) Stop() error
• type Topic

Variables

var ErrConnClosed = errors.New("ws conn closed")

Types

type ClientOp

type ClientOp int

const (
	ClientOPSubscribe ClientOp = iota
	ClientOPUnsubscribe
)

type FeedPacket

type FeedPacket struct {
	T    FeedType `json:"T"`
	Data any      `json:"Data"`
}

FeedPacket 服务器向客户端推送的数据类型

type FeedType

type FeedType int

const (
	FeedTypeChainConfig FeedType = iota
	FeedTypeTransactions
	FeedTypeBlockedTxHashes
	FeedTypeResponse
)

type Remote

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

Remote represents one conn instance

func NewRemote

func NewRemote(c *websocket.Conn, logger log.Logger) *Remote

func (*Remote) FeedBlockedTxHash

func (r *Remote) FeedBlockedTxHash(hashes []common.Hash) error

FeedBlockedTxHash relay new blocked tx hash to clients

func (*Remote) FeedChainConfig

func (r *Remote) FeedChainConfig(config *params.ChainConfig) error

func (*Remote) FeedNewTx

func (r *Remote) FeedNewTx(txs types.Transactions) error

FeedNewTx relay new tx event to clients

func (*Remote) FeedResponse

func (r *Remote) FeedResponse(id int, ok bool, msg string) error

FeedResponse respond to client requests

func (*Remote) RecvLoop

func (r *Remote) RecvLoop() error

func (*Remote) Serve

func (r *Remote) Serve(cfg *params.ChainConfig) error

Serve blocked until conn closed

func (*Remote) Stop

func (r *Remote) Stop()

type RequestPacket

type RequestPacket struct {
	Op ClientOp `json:"op"`
	// 请求id
	Id    int   `json:"id"`
	Topic Topic `json:"topic"`
}

type ResponsePacket

type ResponsePacket struct {
	// 响应的请求id
	Id      int    `json:"id"`
	Ok      bool   `json:"ok"`
	Message string `json:"message"`
}

type Server

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

func New

func New(pool txSub, bc blockchain, logger log.Logger) *Server

func (*Server) Start

func (a *Server) Start() error

func (*Server) Stop

func (a *Server) Stop() error

type Topic

type Topic string

const (
	TopicNewTx           Topic = "newTx"
	TopicBlockedTxHashes       = "blockedTxHashes"
)