(ctx context.Context, id string)
| 105 | } |
| 106 | |
| 107 | type queueDriver struct { |
| 108 | ep *Endpoint |
| 109 | client *azqueue.ServiceClient |
| 110 | cfg *Config |
| 111 | |
| 112 | handshakeQueue, tokenQueue *azqueue.QueueClient |
| 113 | receipts sync.Map // connID -> messageID:popReceipt |
| 114 | } |
| 115 | |
| 116 | func (p *queueDriver) PostHandshake(ctx context.Context, connID string, msg []byte) error { |
| 117 | _, err := p.handshakeQueue.EnqueueMessage(ctx, base64.StdEncoding.EncodeToString(msg), nil) |
nothing calls this directly
no outgoing calls
no test coverage detected