(ctx context.Context)
| 90 | cfg: cfg, |
| 91 | handshakeQueue: hq, |
| 92 | tokenQueue: tq, |
| 93 | }, nil |
| 94 | } |
| 95 | |
| 96 | func resolveQueueClient(client *azqueue.ServiceClient, ep *Endpoint, name, sasToken string) (*azqueue.QueueClient, error) { |
| 97 | if client != nil && sasToken == "" { |
| 98 | return client.NewQueueClient(name), nil |
| 99 | } |
| 100 | c, err := azqueue.NewQueueClientWithNoCredential(ep.JoinURL(name, sasToken), nil) |
| 101 | if err != nil { |
| 102 | return nil, fmt.Errorf("%w: %v", ErrClientCreationFailed, err) |
| 103 | } |
| 104 | return c, nil |
| 105 | } |
| 106 | |
| 107 | type queueDriver struct { |
| 108 | ep *Endpoint |
nothing calls this directly
no outgoing calls
no test coverage detected