TrueCloudLab
/
frostfs-sdk-go
29
0
Fork 18
Code Issues 29 Pull Requests 3 Actions Releases Activity

[#121] client: Make PrmAnnounceSpace, PrmEndpointInfo, PrmNetworkInfo fields public #158

Merged
fyrchik merged 2 commits from aarifullin/frostfs-sdk-go:feature/121-prm_endpoint into master 2023-09-05 11:07:18 +00:00
Conversation 0 Commits 2 Files Changed 2
2 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
client/container_space.go
View File

@ -14,27 +14,29 @@ import (
// PrmAnnounceSpace groups parameters of ContainerAnnounceUsedSpace operation. // PrmAnnounceSpace groups parameters of ContainerAnnounceUsedSpace operation.
type PrmAnnounceSpace struct { type PrmAnnounceSpace struct {
prmCommonMeta XHeaders []string
announcements []container.SizeEstimation Announcements []container.SizeEstimation
} }
// SetValues sets values describing volume of space that is used for the container objects. // SetValues sets values describing volume of space that is used for the container objects.
// Required parameter. Must not be empty. // Required parameter. Must not be empty.
// //
// Must not be mutated before the end of the operation. // Must not be mutated before the end of the operation.
//
// Deprecated: Use PrmAnnounceSpace.Announcements instead.
func (x *PrmAnnounceSpace) SetValues(vs []container.SizeEstimation) { func (x *PrmAnnounceSpace) SetValues(vs []container.SizeEstimation) {
x.announcements = vs x.Announcements = vs
} }
func (x *PrmAnnounceSpace) buildRequest(c *Client) (*v2container.AnnounceUsedSpaceRequest, error) { func (x *PrmAnnounceSpace) buildRequest(c *Client) (*v2container.AnnounceUsedSpaceRequest, error) {
if len(x.announcements) == 0 { if len(x.Announcements) == 0 {
return nil, errorMissingAnnouncements return nil, errorMissingAnnouncements
} }
v2announce := make([]v2container.UsedSpaceAnnouncement, len(x.announcements)) v2announce := make([]v2container.UsedSpaceAnnouncement, len(x.Announcements))
for i := range x.announcements { for i := range x.Announcements {
x.announcements[i].WriteToV2(&v2announce[i]) x.Announcements[i].WriteToV2(&v2announce[i])
} }
reqBody := new(v2container.AnnounceUsedSpaceRequestBody) reqBody := new(v2container.AnnounceUsedSpaceRequestBody)

8
client/netmap.go
View File

@ -16,12 +16,12 @@ import (
// PrmEndpointInfo groups parameters of EndpointInfo operation. // PrmEndpointInfo groups parameters of EndpointInfo operation.
type PrmEndpointInfo struct { type PrmEndpointInfo struct {
prmCommonMeta XHeaders []string
} }
func (x *PrmEndpointInfo) buildRequest(c *Client) (*v2netmap.LocalNodeInfoRequest, error) { func (x *PrmEndpointInfo) buildRequest(c *Client) (*v2netmap.LocalNodeInfoRequest, error) {
meta := new(v2session.RequestMetaHeader) meta := new(v2session.RequestMetaHeader)
writeXHeadersToMeta(x.xHeaders, meta) writeXHeadersToMeta(x.XHeaders, meta)
req := new(v2netmap.LocalNodeInfoRequest) req := new(v2netmap.LocalNodeInfoRequest)
req.SetBody(new(v2netmap.LocalNodeInfoRequestBody)) req.SetBody(new(v2netmap.LocalNodeInfoRequestBody))
@ -112,12 +112,12 @@ func (c *Client) EndpointInfo(ctx context.Context, prm PrmEndpointInfo) (*ResEnd
// PrmNetworkInfo groups parameters of NetworkInfo operation. // PrmNetworkInfo groups parameters of NetworkInfo operation.
type PrmNetworkInfo struct { type PrmNetworkInfo struct {
prmCommonMeta XHeaders []string
} }
func (x PrmNetworkInfo) buildRequest(c *Client) (*v2netmap.NetworkInfoRequest, error) { func (x PrmNetworkInfo) buildRequest(c *Client) (*v2netmap.NetworkInfoRequest, error) {
meta := new(v2session.RequestMetaHeader) meta := new(v2session.RequestMetaHeader)
writeXHeadersToMeta(x.xHeaders, meta) writeXHeadersToMeta(x.XHeaders, meta)
var req v2netmap.NetworkInfoRequest var req v2netmap.NetworkInfoRequest
req.SetBody(new(v2netmap.NetworkInfoRequestBody)) req.SetBody(new(v2netmap.NetworkInfoRequestBody))