(ctx context.Context, data io.ReadSeeker)
| 239 | } |
| 240 | return &queueTransport{connID: connID, txQueue: tx, rxQueue: rx, ep: p.ep, txName: reqName, rxName: resName, cfg: p.cfg, pending: make(map[uint64][]byte)}, nil |
| 241 | } |
| 242 | |
| 243 | func (p *queueDriver) CleanupBootstrap(ctx context.Context) error { |
| 244 | if p.client == nil { |
| 245 | return nil |
| 246 | } |
| 247 | _, _ = p.client.NewQueueClient(p.cfg.handshakeEndpoint).Delete(ctx, nil) |
| 248 | _, _ = p.client.NewQueueClient(p.cfg.tokenEndpoint).Delete(ctx, nil) |
nothing calls this directly
no outgoing calls
no test coverage detected