assets

Documentation

Index

• type Manager
  • func NewAssetManager(ctx context.Context, ns, keyNormalization string, di database.Plugin, ...) (Manager, error)

Types

type Manager

type Manager interface {
	core.Named

	CreateTokenPool(ctx context.Context, pool *core.TokenPoolInput, waitConfirm bool) (*core.TokenPool, error)
	ActivateTokenPool(ctx context.Context, pool *core.TokenPool) error
	GetTokenPools(ctx context.Context, filter ffapi.AndFilter) ([]*core.TokenPool, *ffapi.FilterResult, error)
	GetTokenPoolByLocator(ctx context.Context, connector, poolLocator string) (*core.TokenPool, error)
	GetTokenPoolByNameOrID(ctx context.Context, poolNameOrID string) (*core.TokenPool, error)
	GetTokenPoolByID(ctx context.Context, id *fftypes.UUID) (*core.TokenPool, error)
	ResolvePoolMethods(ctx context.Context, pool *core.TokenPool) error
	DeleteTokenPool(ctx context.Context, poolNameOrID string) error

	GetTokenBalances(ctx context.Context, filter ffapi.AndFilter) ([]*core.TokenBalance, *ffapi.FilterResult, error)
	GetTokenAccounts(ctx context.Context, filter ffapi.AndFilter) ([]*core.TokenAccount, *ffapi.FilterResult, error)
	GetTokenAccountPools(ctx context.Context, key string, filter ffapi.AndFilter) ([]*core.TokenAccountPool, *ffapi.FilterResult, error)

	GetTokenTransfers(ctx context.Context, filter ffapi.AndFilter) ([]*core.TokenTransfer, *ffapi.FilterResult, error)
	GetTokenTransferByID(ctx context.Context, id string) (*core.TokenTransfer, error)

	NewTransfer(transfer *core.TokenTransferInput) syncasync.Sender
	MintTokens(ctx context.Context, transfer *core.TokenTransferInput, waitConfirm bool) (*core.TokenTransfer, error)
	BurnTokens(ctx context.Context, transfer *core.TokenTransferInput, waitConfirm bool) (*core.TokenTransfer, error)
	TransferTokens(ctx context.Context, transfer *core.TokenTransferInput, waitConfirm bool) (*core.TokenTransfer, error)

	GetTokenConnectors(ctx context.Context) []*core.TokenConnector

	NewApproval(approve *core.TokenApprovalInput) syncasync.Sender
	TokenApproval(ctx context.Context, approval *core.TokenApprovalInput, waitConfirm bool) (*core.TokenApproval, error)
	GetTokenApprovals(ctx context.Context, filter ffapi.AndFilter) ([]*core.TokenApproval, *ffapi.FilterResult, error)

	// From operations.OperationHandler
	PrepareOperation(ctx context.Context, op *core.Operation) (*core.PreparedOperation, error)
	RunOperation(ctx context.Context, op *core.PreparedOperation) (outputs fftypes.JSONObject, phase core.OpPhase, err error)

	// Starts the namespace on each of the configured token plugins
	Start() error
}

func NewAssetManager

func NewAssetManager(ctx context.Context, ns, keyNormalization string, di database.Plugin, ti map[string]tokens.Plugin, im identity.Manager, sa syncasync.Bridge, bm broadcast.Manager, pm privatemessaging.Manager, mm metrics.Manager, om operations.Manager, cm contracts.Manager, txHelper txcommon.Helper, cacheManager cache.Manager) (Manager, error)