wsrpc

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

type ClientOpts struct {
	Logger       logger.SugaredLogger
	CSASigner    crypto.Signer
	ServerPubKey []byte
	ServerURL    string
	CacheSet     cache.CacheSet

	// DialWithContext allows optional dependency injection for testing
	DialWithContext DialWithContextFunc
}

type Conn interface {
	wsrpc.ClientInterface
	WaitForReady(ctx context.Context) bool
	GetState() grpc_connectivity.State
	Close() error
}

type DialWithContextFunc func(ctxCaller context.Context, target string, opts ...wsrpc.DialOption) (Conn, error)

type GRPCCompatibilityWrapper struct {
	Client
}

type Pool interface {
	services.Service
	// 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, clientPubKeyHex string, clientSigner crypto.Signer, serverPubKey []byte, serverURL string) (client Client, err error)
}