| 1458 | } |
| 1459 | |
| 1460 | func (c *Cluster) ClusterClient(t testing.TB, opts ...framecfg.ClientOption) (client *clientv3.Client, err error) { |
| 1461 | cfg, err := c.newClientCfg() |
| 1462 | if err != nil { |
| 1463 | return nil, err |
| 1464 | } |
| 1465 | for _, opt := range opts { |
| 1466 | opt(cfg) |
| 1467 | } |
| 1468 | client, err = newClientV3(*cfg) |
| 1469 | if err != nil { |
| 1470 | return nil, err |
| 1471 | } |
| 1472 | t.Cleanup(func() { |
| 1473 | client.Close() |
| 1474 | }) |
| 1475 | return client, nil |
| 1476 | } |
| 1477 | |
| 1478 | func WithAuth(userName, password string) framecfg.ClientOption { |
| 1479 | return func(c any) { |