PoolStats returns connection pool stats.
()
| 1504 | |
| 1505 | // PoolStats returns connection pool stats. |
| 1506 | func (c *Client) PoolStats() *PoolStats { |
| 1507 | stats := c.connPool.Stats() |
| 1508 | stats.PubSubStats = *(c.pubSubPool.Stats()) |
| 1509 | return (*PoolStats)(stats) |
| 1510 | } |
| 1511 | |
| 1512 | func (c *Client) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1513 | return c.Pipeline().Pipelined(ctx, fn) |