forked from TrueCloudLab/frostfs-api-go
1031f3122e
Implement `message.Message` interface on all structures and use new methods for conversion instead of functions. make `Unmarshal` and JSON methods to use encoding functions from `message` library. Remove all per-service clients and implement `rpc` library of the functions which execute NeoFS API RPC through new RPC client. Remove no longer used gRPC per-service clients. Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
131 lines
3.3 KiB
Go
131 lines
3.3 KiB
Go
package rpc
|
|
|
|
import (
|
|
"github.com/nspcc-dev/neofs-api-go/rpc/client"
|
|
"github.com/nspcc-dev/neofs-api-go/rpc/common"
|
|
"github.com/nspcc-dev/neofs-api-go/v2/container"
|
|
)
|
|
|
|
const serviceContainer = serviceNamePrefix + "container.ContainerService"
|
|
|
|
const (
|
|
rpcContainerPut = "Put"
|
|
rpcContainerGet = "Get"
|
|
rpcContainerDel = "Delete"
|
|
rpcContainerList = "List"
|
|
rpcContainerSetEACL = "SetExtendedACL"
|
|
rpcContainerGetEACL = "GetExtendedACL"
|
|
rpcContainerUsedSpace = "AnnounceUsedSpace"
|
|
)
|
|
|
|
// PutContainer executes ContainerService.Put RPC.
|
|
func PutContainer(
|
|
cli *client.Client,
|
|
req *container.PutRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.PutResponse, error) {
|
|
resp := new(container.PutResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerPut), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// GetContainer executes ContainerService.Get RPC.
|
|
func GetContainer(
|
|
cli *client.Client,
|
|
req *container.GetRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.GetResponse, error) {
|
|
resp := new(container.GetResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerGet), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// DeleteContainer executes ContainerService.Delete RPC.
|
|
func DeleteContainer(
|
|
cli *client.Client,
|
|
req *container.DeleteRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.PutResponse, error) {
|
|
resp := new(container.PutResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerDel), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// ListContainers executes ContainerService.List RPC.
|
|
func ListContainers(
|
|
cli *client.Client,
|
|
req *container.ListRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.ListResponse, error) {
|
|
resp := new(container.ListResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerList), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// SetEACL executes ContainerService.SetExtendedACL RPC.
|
|
func SetEACL(
|
|
cli *client.Client,
|
|
req *container.SetExtendedACLRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.PutResponse, error) {
|
|
resp := new(container.PutResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerSetEACL), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// GetEACL executes ContainerService.GetExtendedACL RPC.
|
|
func GetEACL(
|
|
cli *client.Client,
|
|
req *container.GetExtendedACLRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.GetExtendedACLResponse, error) {
|
|
resp := new(container.GetExtendedACLResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerGetEACL), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// AnnounceUsedSpace executes ContainerService.AnnounceUsedSpace RPC.
|
|
func AnnounceUsedSpace(
|
|
cli *client.Client,
|
|
req *container.AnnounceUsedSpaceRequest,
|
|
opts ...client.CallOption,
|
|
) (*container.PutResponse, error) {
|
|
resp := new(container.PutResponse)
|
|
|
|
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerUsedSpace), req, resp, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|