Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultBufferSize = 4 * 1024 * 1024 // 4MB
DefaultBufferSize describes default max GRPC message size. Unfortunately GRPC lib contains this const in private.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Clients ¶ added in v0.45.2
type Clients struct {
// contains filtered or unexported fields
}
Clients manages connections to remote SNs.
func NewClients ¶ added in v0.45.2
func NewClients(l *zap.Logger, signBufPool *sync.Pool, streamTimeout, minConnTimeout, pingInterval, pingTimeout time.Duration) *Clients
NewClients constructs Clients initializing connection to any endpoint with given parameters.
func (*Clients) CloseAll ¶ added in v0.45.2
func (x *Clients) CloseAll()
CloseAll closes all opened connections.
func (*Clients) Get ¶ added in v0.45.2
func (x *Clients) Get(info clientcore.NodeInfo) (clientcore.MultiAddressClient, error)
Get initializes connections to network addresses of described SN and returns interface to access them. All opened connections are cached and kept alive until Clients.CloseAll.
Source Files
Click to show internal directories.
Click to hide internal directories.