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.ServiceCtx
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.