(c *Client)
| 31 | } |
| 32 | |
| 33 | func newRDMAClient(c *Client) (*rdmaClientHandle, error) { |
| 34 | creds, err := c.credsProvider.Get() |
| 35 | if err != nil { |
| 36 | return nil, fmt.Errorf("RDMA: credentials: %w", err) |
| 37 | } |
| 38 | |
| 39 | endpoint := C.CString(c.endpointURL.Host) |
| 40 | defer C.free(unsafe.Pointer(endpoint)) |
| 41 | region := C.CString(c.region) |
| 42 | defer C.free(unsafe.Pointer(region)) |
| 43 | accessKey := C.CString(creds.AccessKeyID) |
| 44 | defer C.free(unsafe.Pointer(accessKey)) |
| 45 | secretKey := C.CString(creds.SecretAccessKey) |
| 46 | defer C.free(unsafe.Pointer(secretKey)) |
| 47 | sessionToken := C.CString(creds.SessionToken) |
| 48 | defer C.free(unsafe.Pointer(sessionToken)) |
| 49 | |
| 50 | var useHTTPS C.int |
| 51 | if c.secure { |
| 52 | useHTTPS = 1 |
| 53 | } |
| 54 | |
| 55 | cptr := C.miniocpp_client_new(endpoint, region, accessKey, secretKey, |
| 56 | sessionToken, useHTTPS) |
| 57 | if cptr == nil { |
| 58 | return nil, fmt.Errorf("RDMA: %s", lastRDMAError()) |
| 59 | } |
| 60 | return &rdmaClientHandle{cptr: cptr}, nil |
| 61 | } |
| 62 | |
| 63 | func (c *Client) putObjectRDMA(_ context.Context, bucketName, objectName string, |
| 64 | opts PutObjectOptions, |
no test coverage detected