utils

package
v0.7.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// DefaultFilePermissions specifies that the user can
	// read and write the file.
	DefaultFilePermissions = 0600

	// AllFilePermissions specifies anyone can do anything
	// to the file.
	AllFilePermissions = 0777

	// NanosecondsInMillisecond is the number
	// of nanoseconds in a millisecond.
	NanosecondsInMillisecond = 1000000

	// MillisecondsInSecond is the number
	// of milliseconds in a second.
	MillisecondsInSecond = 1000

	// OneHundred is the number 100.
	OneHundred = 100

	// MaxEntrySizePerTxn is the maximum number of entries
	// in one transaction object. This is used for bootstrap
	// balances process to avoid TxnTooBig error when memory_limit_disabled=false
	// as well as reduce the running time.
	MaxEntrySizePerTxn = 600
)
View Source
const (
	// DefaultShards is the default number of shards
	// to use in ShardedMap.
	DefaultShards = 256
)

Variables

View Source
var (
	// ErrNetworkNotSupported is returned when the network
	// you are attempting to connect to is not supported.
	ErrNetworkNotSupported = errors.New("network not supported")

	// OneHundredInt is a big.Int of value 100.
	OneHundredInt = big.NewInt(OneHundred)

	// ZeroInt is a big.Int of value 0.
	ZeroInt = big.NewInt(0)
)

Functions

func AtTip

func AtTip(
	tipDelay int64,
	blockTimestamp int64,
) bool

AtTip returns a boolean indicating if a block timestamp is within tipDelay from the current time.

func BigPow10

func BigPow10(e int32) *big.Float

BigPow10 computes the value of 10^e. Inspired by: https://steemit.com/tutorial/@gopher23/power-and-root-functions-using-big-float-in-golang

func BtoMb

func BtoMb(b float64) float64

BtoMb converts B to MB.

func CheckNetworkSupported

func CheckNetworkSupported(
	ctx context.Context,
	networkIdentifier *types.NetworkIdentifier,
	helper FetcherHelper,
) (*types.NetworkStatusResponse, error)

CheckNetworkSupported checks if a Rosetta implementation supports a given *types.NetworkIdentifier. If it does, the current network status is returned.

func CheckNetworkTip

func CheckNetworkTip(ctx context.Context,
	network *types.NetworkIdentifier,
	tipDelay int64,
	f FetcherHelper,
) (bool, *types.BlockIdentifier, error)

CheckNetworkTip returns a boolean indicating if the block returned by network/status is at tip. It also returns the block identifier returned by network/status. Note that the tipDelay param takes tip delay in seconds. Block returned by network/status is considered to be at tip if one of the following two conditions is met: (1) the block was produced within tipDelay of current time (i.e. block timestamp >= current time - tipDelay) (2) the network/status endpoint returns a SyncStatus with Synced = true.

func CheckStorageTip

func CheckStorageTip(ctx context.Context,
	network *types.NetworkIdentifier,
	tipDelay int64,
	f FetcherHelper,
	b BlockStorageHelper,
) (bool, *types.BlockIdentifier, error)

CheckStorageTip returns a boolean indicating if the current block returned by block storage helper is at tip. It also returns the block identifier of the current storage block. Note that the tipDelay param takes tip delay in seconds. A block in storage is considered to be at tip if one of the following two conditions is met: (1) the block was produced within tipDelay of current time (i.e. block timestamp >= current time - tipDelay) (2) CheckNetworkTip returns true and the block it returns is same as the current block in storage

func ContainsAccountIdentifier

func ContainsAccountIdentifier(arr []*types.AccountIdentifier, s *types.AccountIdentifier) bool

ContainsAccountIdentifier returns a boolean indicating whether the struct s is in arr.

func ContainsString

func ContainsString(arr []string, s string) bool

ContainsString returns a boolean indicating whether the string s is in arr.

func ContextSleep

func ContextSleep(ctx context.Context, duration time.Duration) error

ContextSleep sleeps for the provided duration and returns an error if context is canceled.

func CreateCommandPath

func CreateCommandPath(
	dataDirectory string,
	cmd string,
	network *types.NetworkIdentifier,
) (string, error)

CreateCommandPath creates a unique path for a command and network within a data directory. This is used to avoid collision when using multiple commands on multiple networks when the same storage resources are used. If the derived path does not exist, we run os.MkdirAll on the path.

func CreateTempDir

func CreateTempDir() (string, error)

CreateTempDir creates a directory in /tmp for usage within testing.

func CurrencyBalance

func CurrencyBalance(
	ctx context.Context,
	network *types.NetworkIdentifier,
	helper FetcherHelper,
	account *types.AccountIdentifier,
	currency *types.Currency,
	index int64,
) (*types.Amount, *types.BlockIdentifier, error)

CurrencyBalance returns the balance of an account for a particular currency at a particular height. It is up to the caller to determine if the retrieved block has the expected hash for the requested index.

func EnsurePathExists

func EnsurePathExists(path string) error

EnsurePathExists creates directories along a path if they do not exist.

func Equal

func Equal(a interface{}, b interface{}) bool

Equal returns a boolean indicating if two interfaces are equal.

func LoadAndParse

func LoadAndParse(filePath string, output interface{}) error

LoadAndParse reads the file at the provided path and attempts to unmarshal it into output.

func Milliseconds

func Milliseconds() int64

Milliseconds gets the current time in milliseconds.

func PrettyAmount

func PrettyAmount(amount *big.Int, currency *types.Currency) string

PrettyAmount returns a currency amount in native format with its symbol.

func RandomNumber

func RandomNumber(minimum *big.Int, maximum *big.Int) (*big.Int, error)

RandomNumber returns some number in the range [minimum, maximum). Source: https://golang.org/pkg/crypto/rand/#Int

func RemoveTempDir

func RemoveTempDir(dir string)

RemoveTempDir deletes a directory at a provided path for usage within testing.

func SerializeAndWrite

func SerializeAndWrite(filePath string, object interface{}) error

SerializeAndWrite attempts to serialize the provided object into a file at filePath.

func SizeOf

func SizeOf(v interface{}) int

SizeOf returns the size of 'v' in bytes. If there is an error during calculation, Of returns -1.

func TimeToTip

func TimeToTip(
	blocksPerSecond float64,
	lastSyncedIndex int64,
	tipIndex int64,
) time.Duration

TimeToTip returns the estimate time to tip given the current sync speed.

func Zero

func Zero() *big.Float

Zero returns a float with 256 bit precision.

Types

type AccountBalance

type AccountBalance struct {
	Account *types.AccountIdentifier
	Amount  *types.Amount
	Coins   []*types.Coin
	Block   *types.BlockIdentifier
}

AccountBalance defines an account's balance, including either balance or coins, as well as the block which this balance was fetched at.

func GetAccountBalances

func GetAccountBalances(
	ctx context.Context,
	fetcher FetcherHelper,
	balanceRequests []*AccountBalanceRequest,
) ([]*AccountBalance, error)

GetAccountBalances returns an array of AccountBalances for an array of AccountBalanceRequests

type AccountBalanceRequest

type AccountBalanceRequest struct {
	Account  *types.AccountIdentifier
	Network  *types.NetworkIdentifier
	Currency *types.Currency
}

AccountBalanceRequest defines the required information to get an account's balance.

type AccountCoinsRequest

type AccountCoinsRequest struct {
	Account        *types.AccountIdentifier
	Network        *types.NetworkIdentifier
	Currencies     []*types.Currency
	IncludeMempool bool
}

AccountCoinsRequest defines the required information to get an account's coins.

type AccountCoinsResponse

type AccountCoinsResponse struct {
	Coins []*types.Coin
}

AccountCoins defines an account's coins info at tip.

func GetAccountCoins

func GetAccountCoins(
	ctx context.Context,
	fetcher FetcherHelper,
	acctCoinsReqs []*AccountCoinsRequest,
) ([]*AccountCoinsResponse, error)

GetAccountCoins calls /account/coins endpoint and returns an array of coins at tip.

type BST

type BST struct {
	// contains filtered or unexported fields
}

BST is an implementation of a binary search tree.

func (*BST) Delete

func (t *BST) Delete(key int64)

Delete removes the key from the BST.

func (*BST) Empty

func (t *BST) Empty() bool

Empty returns a boolean indicating if there are any nodes in the BST.

func (*BST) Get

func (t *BST) Get(key int64) *Node

Get gets the key in the BST and returns its representative node (so that modifications can be done in constant time).

func (*BST) Min

func (t *BST) Min() *Node

Min returns the smallest node in the BST.

func (*BST) Set

func (t *BST) Set(key int64, value int)

Set stores the key and value in the BST

type BlockStorageHelper

type BlockStorageHelper interface {
	GetBlockLazy(
		ctx context.Context,
		blockIdentifier *types.PartialBlockIdentifier,
	) (*types.BlockResponse, error)
}

type FetcherHelper

type FetcherHelper interface {
	NetworkList(
		ctx context.Context,
		metadata map[string]interface{},
	) (*types.NetworkListResponse, *fetcher.Error)

	NetworkStatusRetry(
		ctx context.Context,
		network *types.NetworkIdentifier,
		metadata map[string]interface{},
	) (*types.NetworkStatusResponse, *fetcher.Error)

	AccountBalanceRetry(
		ctx context.Context,
		network *types.NetworkIdentifier,
		account *types.AccountIdentifier,
		block *types.PartialBlockIdentifier,
		currencies []*types.Currency,
	) (*types.BlockIdentifier, []*types.Amount, map[string]interface{}, *fetcher.Error)

	AccountCoinsRetry(
		ctx context.Context,
		network *types.NetworkIdentifier,
		acct *types.AccountIdentifier,
		includeMempool bool,
		currencies []*types.Currency,
	) (*types.BlockIdentifier, []*types.Coin, map[string]interface{}, *fetcher.Error)
}

FetcherHelper is used by util functions to mock Fetcher

type MemoryUsage

type MemoryUsage struct {
	Heap               float64 `json:"heap"`
	Stack              float64 `json:"stack"`
	OtherSystem        float64 `json:"other_system"`
	System             float64 `json:"system"`
	GarbageCollections uint32  `json:"garbage_collections"`
}

MemoryUsage contains memory usage stats converted to MBs.

func MonitorMemoryUsage

func MonitorMemoryUsage(
	ctx context.Context,
	maxHeapUsage int,
) *MemoryUsage

MonitorMemoryUsage returns a collection of memory usage stats in MB. It will also run garbage collection if the heap is greater than maxHeapUsage in MB.

type MutexMap

type MutexMap struct {
	// contains filtered or unexported fields
}

MutexMap is a struct that allows for acquiring a *PriorityMutex via a string identifier or for acquiring a global mutex that blocks the acquisition of any identifier mutexes.

This is useful for coordinating concurrent, non-overlapping writes in the storage package.

func NewMutexMap

func NewMutexMap(shards int) *MutexMap

NewMutexMap returns a new *MutexMap.

func (*MutexMap) GLock

func (m *MutexMap) GLock()

GLock acquires an exclusive lock across an entire *MutexMap.

func (*MutexMap) GUnlock

func (m *MutexMap) GUnlock()

GUnlock releases an exclusive lock held for an entire *MutexMap.

func (*MutexMap) Lock

func (m *MutexMap) Lock(identifier string, priority bool)

Lock acquires a lock for a particular identifier, as long as no other caller has the global mutex or a lock by the same identifier.

func (*MutexMap) Unlock

func (m *MutexMap) Unlock(identifier string)

Unlock releases a lock held for a particular identifier.

type Node

type Node struct {
	Key   int64
	Value int
	// contains filtered or unexported fields
}

Node is a Node in a BST

type PriorityMutex

type PriorityMutex struct {
	// contains filtered or unexported fields
}

PriorityMutex is a special type of mutex that allows callers to request priority over other callers. This can be useful if there is a "hot path" in an application that requires lock access.

WARNING: It is possible to cause lock starvation if not careful (i.e. only high priority callers ever do work).

func (*PriorityMutex) Lock

func (m *PriorityMutex) Lock(priority bool)

Lock attempts to acquire either a high or low priority mutex. When priority is true, a lock will be granted before other low priority callers.

func (*PriorityMutex) Unlock

func (m *PriorityMutex) Unlock()

Unlock selects the next highest priority lock to grant. If there are no locks to grant, it sets the value of m.lock to false.

type ShardedMap

type ShardedMap struct {
	// contains filtered or unexported fields
}

ShardedMap allows concurrent writes to a map by sharding the map into some number of independently locked subsections.

func NewShardedMap

func NewShardedMap(shards int) *ShardedMap

NewShardedMap creates a new *ShardedMap with some number of shards. The larger the number provided for shards, the less lock contention there will be.

As a rule of thumb, shards should usually be set to the concurrency of the caller.

func (*ShardedMap) Lock

func (m *ShardedMap) Lock(key string, priority bool) map[string]interface{}

Lock acquires the lock for a shard that could contain the key. This syntax allows the caller to perform multiple operations while holding the lock for a single shard.

func (*ShardedMap) Unlock

func (m *ShardedMap) Unlock(key string)

Unlock releases the lock for a shard that could contain the key.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL