wsrpc

package
v2.9.1-zksync-20240229... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 29, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const MaxConsecutiveRequestFailures = 10

MaxConsecutiveRequestFailures controls how many consecutive requests are allowed to time out before we reset the connection

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client interface {
	services.Service
	pb.MercuryClient
	ServerURL() string
	RawClient() pb.MercuryClient
}

func NewClient

func NewClient(lggr logger.Logger, clientPrivKey csakey.KeyV2, serverPubKey []byte, serverURL string, cacheSet cache.CacheSet) Client

Consumers of wsrpc package should not usually call NewClient directly, but instead use the Pool

type Conn added in v2.3.0

type Conn interface {
	WaitForReady(ctx context.Context) bool
	GetState() connectivity.State
	Close()
}

type Pool

type Pool interface {
	services.ServiceCtx
	// Checkout gets a wsrpc.Client for the given arguments
	// The same underlying client can be checked out multiple times, the pool
	// handles lifecycle management. The consumer can treat it as if it were
	// its own unique client.
	Checkout(ctx context.Context, clientPrivKey csakey.KeyV2, serverPubKey []byte, serverURL string) (client Client, err error)
}

func NewPool

func NewPool(lggr logger.Logger, cacheCfg cache.Config) Pool

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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