pool

type ClientConn = grpc.ClientConn

type Conn interface {
	// Connect establishes connections for all slots.
	Connect(context.Context) (Conn, error)
	// Disconnect gracefully closes all connections in the pool.
	Disconnect(context.Context) error
	// Do executes the provided function using a healthy connection.
	Do(context.Context, func(*ClientConn) error) error
	// Get returns a healthy connection from the pool, if available.
	Get(context.Context) (*ClientConn, bool)
	// IsHealthy checks the overall health of the pool.
	IsHealthy(context.Context) bool
	// IsIPConn indicates whether the pool is using direct IP connections.
	IsIPConn() bool
	// Len returns the number of connection slots.
	Len() uint64
	// Size returns the configured pool size.
	Size() uint64
	// Reconnect re-establishes connections if the pool is unhealthy or if forced.
	Reconnect(context.Context, bool) (Conn, error)
	// String returns a string representation of the pool's state.
	String() string
}

type DialOption = grpc.DialOption

type Option func(*pool)