Documentation
¶
Index ¶
Constants ¶
View Source
const MaxConsecutiveTransmitFailures = 5
MaxConsecutiveTransmitFailures 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 }
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) }
Click to show internal directories.
Click to hide internal directories.