Go implementation of FrostFS SDK
Find a file
Alex Vanin fc4551b843 [#172] pool: Use priority of errors in tree pool
When retry happens, use priority map to decide
which error to return. Consider network errors
less desirable than business logic errors.

Signed-off-by: Alex Vanin <a.vanin@yadro.com>
2023-10-11 12:00:34 +03:00
.forgejo/workflows [#146] .forgejo: Update DCO action 2023-08-11 12:34:29 +03:00
.github [#98] Add forgejo workflows 2023-06-28 12:13:02 +00:00
accounting Rename package name 2023-03-07 15:47:21 +03:00
bearer [#49] bearer: Allow empty eacl if token is impersonated 2023-05-05 12:45:39 +03:00
checksum [#170] checksum: Use constant mapping for checksum types 2023-09-28 17:20:24 +03:00
client [#121] client: Make PrmObjectHash fields public 2023-09-08 13:36:45 +00:00
container [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
crypto [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
doc [#162] netmap: Allow to parse single unnamed selectors 2023-09-11 15:22:24 +03:00
eacl [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
netmap [#88] netmap: use bool, fix hrw_sort tests 2023-10-03 07:05:03 +00:00
ns [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
object [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
pool [#172] pool: Use priority of errors in tree pool 2023-10-11 12:00:34 +03:00
session [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
user [#161] *: Do not use math/rand.Read() 2023-09-08 17:17:02 +03:00
version Rename package name 2023-03-07 15:47:21 +03:00
.gitattributes [#3] policy: use ANTLRv4 parser generator 2021-06-15 11:42:14 +03:00
.gitignore [#83] Update .gitignore 2023-06-28 12:12:37 +00:00
.gitlint [#41] .gitlint: Synchronize settings across FrostFS repos 2023-03-24 22:07:13 +03:00
.golangci.yml [#161] .golangci.yml: Reenable deprecated usage warnings 2023-09-08 17:17:02 +03:00
.pre-commit-config.yaml [#74] pre-commit: Exclude auto-generated files 2023-05-19 17:47:24 +03:00
Dockerfile [#144] Bump required go version to go1.20 2023-08-09 09:52:35 +03:00
go.mod [#144] Bump required go version to go1.20 2023-08-09 09:52:35 +03:00
go.sum [#137] go.mod: Update api-go 2023-08-02 12:04:10 +03:00
LICENSE Initial commit 2021-02-25 11:35:04 +03:00
Makefile [#73] pool/tree: Add proto tree service client 2023-06-08 14:37:57 +03:00
README.md [#23] pre-commit: Add initial configuration 2023-03-09 22:52:51 +03:00
syncTree.sh [#136] pool: Set order field to get subtree 2023-08-02 10:32:37 +00:00

frostfs-sdk-go

Go implementation of FrostFS SDK. It contains high-level version-independent wrappers for structures from frostfs-api-go as well as helper functions for simplifying node/dApp implementations.

Repository structure

accounting

Contains fixed-point Decimal type for performing balance calculations.

eacl

Contains Extended ACL types for fine-grained access control. There is also a reference implementation of checking algorithm which is used in FrostFS node.

checksum

Contains Checksum type encapsulating checksum as well as it's kind. Currently Sha256 and Tillich-Zemor hashsum are in use.

owner

owner.ID type represents single account interacting with FrostFS. In v2 version of protocol it is just raw bytes behing base58-encoded address in Neo blockchain. Note that for historical reasons it contains version prefix and checksum in addition to script-hash.

token

Contains Bearer token type with several FrostFS-specific methods.

ns

In FrostFS there are 2 types of name resolution: DNS and NNS. NNS stands for Neo Name Service is just a contract deployed on a Neo blockchain. Basically, NNS is just a DNS-on-chain which can be used for resolving container nice-names as well as any other name in dApps. See our CoreDNS plugin for the example of how NNS can be integrated in DNS.

session

To help lightweight clients interact with FrostFS without sacrificing trust, FrostFS has a concept of session token. It is signed by client and allows any node with which a session is established to perform certain actions on behalf of the user.

client

Contains client for working with FrostFS.

var prmInit client.PrmInit
prmInit.SetDefaultPrivateKey(key) // private key for request signing
prmInit.ResolveFrostFSFailures() // enable erroneous status parsing

var c client.Client
c.Init(prmInit)

var prmDial client.PrmDial
prmDial.SetServerURI("grpcs://localhost:40005") // endpoint address

err := c.Dial(prmDial)
if err != nil {
    return
}

ctx, cancel := context.WithTimeout(context.Background(), 5 * time.Second)
defer cancel()

var prm client.PrmBalanceGet
prm.SetAccount(acc)

res, err := c.BalanceGet(ctx, prm)
if err != nil {
    return
}

fmt.Printf("Balance for %s: %v\n", acc, res.Amount())

Response status

In FrostFS every operation can fail on multiple levels, so a single error doesn't suffice, e.g. consider a case when object was put on 4 out of 5 replicas. Thus, all request execution details are contained in Status returned from every RPC call. dApp can inspect them if needed and perform any desired action. In the case above we may want to report these details to the user as well as retry an operation, possibly with different parameters. Status wire-format is extendable and each node can report any set of details it wants. The set of reserved status codes can be found in FrostFS API. There is also a client.PrmInit.ResolveFrostFSFailures() to seamlessly convert erroneous statuses into Go error type.

policy

Contains helpers allowing conversion of placing policy from/to JSON representation and SQL-like human-readable language.

p, _ := policy.Parse(`
    REP 2
    SELECT 6 FROM F
    FILTER StorageType EQ SSD AS F`)

// Convert parsed policy back to human-readable text and print.
println(strings.Join(policy.Encode(p), "\n"))

netmap

Contains CRUSH-like implementation of container node selection algorithm. Relevant details are described in this paper http://ceur-ws.org/Vol-2344/short10.pdf . Note that it can be outdated in some details.

netmap/json_tests subfolder contains language-agnostic tests for selection algorithm.

import (
    "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/netmap"
    "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/object"
)

func placementNodes(addr *object.Address, p *netmap.PlacementPolicy, frostfsNodes []netmap.NodeInfo) {
    // Convert list of nodes in FrostFS API format to the intermediate representation.
    nodes := netmap.NodesFromInfo(nodes)

    // Create new netmap (errors are skipped for the sake of clarity).
    nm, _ := NewNetmap(nodes)

    // Calculate nodes of container.
    cn, _ := nm.GetContainerNodes(p, addr.ContainerID().ToV2().GetValue())

    // Return list of nodes for each replica to place object on in the order of priority.
    return nm.GetPlacementVectors(cn, addr.ObjectID().ToV2().GetValue())
}

pool

Simple pool for managing connections to FrostFS nodes.

acl, checksum, version, signature

Contain simple API wrappers.

logger

Wrapper over zap.Logger which is used across FrostFS codebase.

util

Utilities for working with signature-related code.