dkirillov/frostfs-api-go
1
0
Fork 0
forked from TrueCloudLab/frostfs-api-go
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#188] sdk: Implement Epoch method

Browse source 
Implement Epoch method on Client that receives epoch number through Netmap
.LocalNodeInfo call.

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2020-11-03 18:59:57 +03:00 committed by Alex Vanin
parent 89a7a946dc
commit 2b171e1617
1 changed files with 23 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
pkg/client/netmap.go
View file

@ -15,13 +15,33 @@ import (
func (c Client) EndpointInfo(ctx context.Context, opts ...CallOption) (*netmap.NodeInfo, error) { func (c Client) EndpointInfo(ctx context.Context, opts ...CallOption) (*netmap.NodeInfo, error) {
switch c.remoteNode.Version.GetMajor() { switch c.remoteNode.Version.GetMajor() {
case 2: case 2:
return c.endpointInfoV2(ctx, opts...) resp, err := c.endpointInfoV2(ctx, opts...)
if err != nil {
return nil, err
}
return resp.GetBody().GetNodeInfo(), nil
default: default:
return nil, unsupportedProtocolErr return nil, unsupportedProtocolErr
} }
} }
func (c Client) endpointInfoV2(ctx context.Context, opts ...CallOption) (*netmap.NodeInfo, error) { // Epoch returns the epoch number from the local state of the remote host.
func (c Client) Epoch(ctx context.Context, opts ...CallOption) (uint64, error) {
switch c.remoteNode.Version.GetMajor() {
case 2:
resp, err := c.endpointInfoV2(ctx, opts...)
if err != nil {
return 0, err
}
return resp.GetMetaHeader().GetEpoch(), nil
default:
return 0, unsupportedProtocolErr
}
}
func (c Client) endpointInfoV2(ctx context.Context, opts ...CallOption) (*netmap.LocalNodeInfoResponse, error) {
// apply all available options // apply all available options
callOptions := c.defaultCallOptions() callOptions := c.defaultCallOptions()
for i := range opts { for i := range opts {
@ -56,7 +76,7 @@ func (c Client) endpointInfoV2(ctx context.Context, opts ...CallOption) (*netmap
return nil, errors.Wrap(err, "can't verify response message") return nil, errors.Wrap(err, "can't verify response message")
} }
return resp.GetBody().GetNodeInfo(), nil return resp, nil
default: default:
return nil, unsupportedProtocolErr return nil, unsupportedProtocolErr
} }