gethws

package

v0.4.22-alpha.2 Latest Latest Go to latest Published: May 31, 2023 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(nodeConn Connectionner, namespace string, try bool, l log.Logger) *Client

func (f *Client) IsSet() bool

func (c *Client) Kind() string

func (c *Client) ValidateBlock(ctx context.Context, block *types.BuilderBlockValidationRequest) (err error)

func (c *Client) ValidateBlockV2(ctx context.Context, block *types.BuilderBlockValidationRequestV2) (err error)

type Conn struct {
	Done chan struct{}
	// contains filtered or unexported fields
}

func NewConn(l log.Logger, input chan []byte) *Conn

func (conn *Conn) Close()

func (conn *Conn) Connect(url string) (err error)

func (conn *Conn) EnqueueRPC(ctx context.Context, method string, content []byte)

func (conn *Conn) RequestRPC(ctx context.Context, method string, content []byte) (b types.RpcRawResponse, err error)

func (conn *Conn) Status() bool

type Connectionner interface {
	Get() (*Conn, uint32, error)
	TryOtherThan(uint32) (*Conn, error)
}

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

func NewReConn(l log.Logger) *ReConn

func (rc *ReConn) Get() (*Conn, uint32, error)

func (rc *ReConn) KeepConnection(url string, input chan []byte)

func (rc *ReConn) Next() (*Conn, uint32)

func (rc *ReConn) TryOtherThan(e uint32) (*Conn, error)

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

func NewRespCache() *RespCache

func (rc *RespCache) Del(id uint64)

func (rc *RespCache) Get(id uint64) (ch chan types.RpcRawResponse, ok bool)

func (rc *RespCache) PoolGet() (ch chan types.RpcRawResponse)

func (rc *RespCache) PoolPut(ch chan types.RpcRawResponse)

func (rc *RespCache) Set(id uint64, ch chan types.RpcRawResponse)