(ctx context.Context, o config.DefragOption)
| 248 | } |
| 249 | |
| 250 | func (c integrationClient) Defragment(ctx context.Context, o config.DefragOption) error { |
| 251 | if o.Timeout != 0 { |
| 252 | var cancel context.CancelFunc |
| 253 | ctx, cancel = context.WithTimeout(ctx, o.Timeout) |
| 254 | defer cancel() |
| 255 | } |
| 256 | for _, ep := range c.Endpoints() { |
| 257 | _, err := c.Client.Defragment(ctx, ep) |
| 258 | if err != nil { |
| 259 | return err |
| 260 | } |
| 261 | } |
| 262 | return nil |
| 263 | } |
| 264 | |
| 265 | func (c integrationClient) TimeToLive(ctx context.Context, id clientv3.LeaseID, o config.LeaseOption) (*clientv3.LeaseTimeToLiveResponse, error) { |
| 266 | var leaseOpts []clientv3.LeaseOption |
nothing calls this directly
no test coverage detected