storage

Documentation

Index

• Variables
• func AddBalance(ctx context.Context, db chain.Database, pk crypto.PublicKey, asset ids.ID, ...) error
• func AddLoan(ctx context.Context, db chain.Database, asset ids.ID, destination ids.ID, ...) error
• func DeleteAsset(ctx context.Context, db chain.Database, asset ids.ID) error
• func DeleteBalance(ctx context.Context, db chain.Database, pk crypto.PublicKey, asset ids.ID) error
• func DeleteOrder(ctx context.Context, db chain.Database, order ids.ID) error
• func GetAsset(ctx context.Context, db chain.Database, asset ids.ID) (bool, []byte, uint64, crypto.PublicKey, bool, error)
• func GetAssetFromState(ctx context.Context, f ReadState, asset ids.ID) (bool, []byte, uint64, crypto.PublicKey, bool, error)
• func GetBalance(ctx context.Context, db chain.Database, pk crypto.PublicKey, asset ids.ID) (uint64, error)
• func GetBalanceFromState(ctx context.Context, f ReadState, pk crypto.PublicKey, asset ids.ID) (uint64, error)
• func GetLoan(ctx context.Context, db chain.Database, asset ids.ID, destination ids.ID) (uint64, error)
• func GetLoanFromState(ctx context.Context, f ReadState, asset ids.ID, destination ids.ID) (uint64, error)
• func GetOrder(ctx context.Context, db chain.Database, order ids.ID) (bool, ids.ID, uint64, ids.ID, uint64, uint64, crypto.PublicKey, error)
• func GetTransaction(_ context.Context, db database.KeyValueReader, id ids.ID) (bool, int64, bool, uint64, error)
• func HeightKey() (k []byte)
• func IncomingWarpKeyPrefix(sourceChainID ids.ID, msgID ids.ID) (k []byte)
• func OutgoingWarpKeyPrefix(txID ids.ID) (k []byte)
• func PrefixAssetKey(asset ids.ID) (k []byte)
• func PrefixBalanceKey(pk crypto.PublicKey, asset ids.ID) (k []byte)
• func PrefixLoanKey(asset ids.ID, destination ids.ID) (k []byte)
• func PrefixOrderKey(txID ids.ID) (k []byte)
• func PrefixTxKey(id ids.ID) (k []byte)
• func SetAsset(ctx context.Context, db chain.Database, asset ids.ID, metadata []byte, ...) error
• func SetBalance(ctx context.Context, db chain.Database, pk crypto.PublicKey, asset ids.ID, ...) error
• func SetLoan(ctx context.Context, db chain.Database, asset ids.ID, destination ids.ID, ...) error
• func SetOrder(ctx context.Context, db chain.Database, txID ids.ID, in ids.ID, inTick uint64, ...) error
• func StoreTransaction(_ context.Context, db database.KeyValueWriter, id ids.ID, t int64, ...) error
• func SubBalance(ctx context.Context, db chain.Database, pk crypto.PublicKey, asset ids.ID, ...) error
• func SubLoan(ctx context.Context, db chain.Database, asset ids.ID, destination ids.ID, ...) error
• type ReadState

Variables

var ErrInvalidBalance = errors.New("invalid balance")

Functions

func AddBalance

func AddBalance(
	ctx context.Context,
	db chain.Database,
	pk crypto.PublicKey,
	asset ids.ID,
	amount uint64,
) error

func AddLoan

func AddLoan(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
	destination ids.ID,
	amount uint64,
) error

func DeleteAsset

func DeleteAsset(ctx context.Context, db chain.Database, asset ids.ID) error

func DeleteBalance

func DeleteBalance(
	ctx context.Context,
	db chain.Database,
	pk crypto.PublicKey,
	asset ids.ID,
) error

func DeleteOrder

func DeleteOrder(ctx context.Context, db chain.Database, order ids.ID) error

func GetAsset

func GetAsset(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
) (bool, []byte, uint64, crypto.PublicKey, bool, error)

func GetAssetFromState

func GetAssetFromState(
	ctx context.Context,
	f ReadState,
	asset ids.ID,
) (bool, []byte, uint64, crypto.PublicKey, bool, error)

Used to serve RPC queries

func GetBalance

func GetBalance(
	ctx context.Context,
	db chain.Database,
	pk crypto.PublicKey,
	asset ids.ID,
) (uint64, error)

If locked is 0, then account does not exist

func GetBalanceFromState

func GetBalanceFromState(
	ctx context.Context,
	f ReadState,
	pk crypto.PublicKey,
	asset ids.ID,
) (uint64, error)

Used to serve RPC queries

func GetLoan

func GetLoan(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
	destination ids.ID,
) (uint64, error)

func GetLoanFromState

func GetLoanFromState(
	ctx context.Context,
	f ReadState,
	asset ids.ID,
	destination ids.ID,
) (uint64, error)

Used to serve RPC queries

func GetOrder

func GetOrder(
	ctx context.Context,
	db chain.Database,
	order ids.ID,
) (
	bool,
	ids.ID,
	uint64,
	ids.ID,
	uint64,
	uint64,
	crypto.PublicKey,
	error,
)

func GetTransaction

func GetTransaction(
	_ context.Context,
	db database.KeyValueReader,
	id ids.ID,
) (bool, int64, bool, uint64, error)

func HeightKey

func HeightKey() (k []byte)

func IncomingWarpKeyPrefix

func IncomingWarpKeyPrefix(sourceChainID ids.ID, msgID ids.ID) (k []byte)

func OutgoingWarpKeyPrefix

func OutgoingWarpKeyPrefix(txID ids.ID) (k []byte)

func PrefixAssetKey

func PrefixAssetKey(asset ids.ID) (k []byte)

[assetPrefix] + [address]

func PrefixBalanceKey

func PrefixBalanceKey(pk crypto.PublicKey, asset ids.ID) (k []byte)

[accountPrefix] + [address] + [asset]

func PrefixLoanKey

func PrefixLoanKey(asset ids.ID, destination ids.ID) (k []byte)

[loanPrefix] + [asset] + [destination]

func PrefixOrderKey

func PrefixOrderKey(txID ids.ID) (k []byte)

[orderPrefix] + [txID]

func PrefixTxKey

func PrefixTxKey(id ids.ID) (k []byte)

[txPrefix] + [txID]

func SetAsset

func SetAsset(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
	metadata []byte,
	supply uint64,
	owner crypto.PublicKey,
	warp bool,
) error

func SetBalance

func SetBalance(
	ctx context.Context,
	db chain.Database,
	pk crypto.PublicKey,
	asset ids.ID,
	balance uint64,
) error

func SetLoan

func SetLoan(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
	destination ids.ID,
	amount uint64,
) error

func SetOrder

func SetOrder(
	ctx context.Context,
	db chain.Database,
	txID ids.ID,
	in ids.ID,
	inTick uint64,
	out ids.ID,
	outTick uint64,
	supply uint64,
	owner crypto.PublicKey,
) error

func StoreTransaction

func StoreTransaction(
	_ context.Context,
	db database.KeyValueWriter,
	id ids.ID,
	t int64,
	success bool,
	units uint64,
) error

func SubBalance

func SubBalance(
	ctx context.Context,
	db chain.Database,
	pk crypto.PublicKey,
	asset ids.ID,
	amount uint64,
) error

func SubLoan

func SubLoan(
	ctx context.Context,
	db chain.Database,
	asset ids.ID,
	destination ids.ID,
	amount uint64,
) error

Types

type ReadState

type ReadState func(context.Context, [][]byte) ([][]byte, []error)