gethws

Documentation

Index

• type Client
  • func NewClient(nodeConn Connectionner, namespace string, try bool, l log.Logger) *Client
  • func (c *Client) ID() string
  • 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
  • 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
• type ReConn
  • 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
  • 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)

Types

type Client

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

func NewClient

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

func (*Client) ID

func (c *Client) ID() string

func (*Client) IsSet

func (f *Client) IsSet() bool

func (*Client) Kind

func (c *Client) Kind() string

func (*Client) ValidateBlock

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

func (*Client) ValidateBlockV2

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

type Conn

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

func NewConn

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

func (*Conn) Close

func (conn *Conn) Close()

func (*Conn) Connect

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

func (*Conn) EnqueueRPC

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

func (*Conn) RequestRPC

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

func (*Conn) Status

func (conn *Conn) Status() bool

type Connectionner

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

type ReConn

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

func NewReConn

func NewReConn(l log.Logger) *ReConn

func (*ReConn) Get

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

func (*ReConn) KeepConnection

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

func (*ReConn) Next

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

func (*ReConn) TryOtherThan

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

type RespCache

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

func NewRespCache

func NewRespCache() *RespCache

func (*RespCache) Del

func (rc *RespCache) Del(id uint64)

func (*RespCache) Get

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

func (*RespCache) PoolGet

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

func (*RespCache) PoolPut

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

func (*RespCache) Set

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