txcommon

Documentation

Index

• func AddTokenApprovalInputs(op *core.Operation, approval *core.TokenApproval) (err error)
• func AddTokenPoolActivateInputs(op *core.Operation, poolID *fftypes.UUID)
• func AddTokenPoolCreateInputs(op *core.Operation, pool *core.TokenPool) (err error)
• func AddTokenTransferInputs(op *core.Operation, transfer *core.TokenTransfer) (err error)
• func RetrieveTokenApprovalInputs(ctx context.Context, op *core.Operation) (approval *core.TokenApproval, err error)
• func RetrieveTokenPoolActivateInputs(ctx context.Context, op *core.Operation) (*fftypes.UUID, error)
• func RetrieveTokenPoolCreateInputs(ctx context.Context, op *core.Operation) (*core.TokenPool, error)
• func RetrieveTokenTransferInputs(ctx context.Context, op *core.Operation) (*core.TokenTransfer, error)
• type Helper
  • func NewTransactionHelper(ctx context.Context, ns string, di database.Plugin, dm data.Manager, ...) (Helper, error)

Functions

func AddTokenApprovalInputs

func AddTokenApprovalInputs(op *core.Operation, approval *core.TokenApproval) (err error)

func AddTokenPoolActivateInputs

func AddTokenPoolActivateInputs(op *core.Operation, poolID *fftypes.UUID)

func AddTokenPoolCreateInputs

func AddTokenPoolCreateInputs(op *core.Operation, pool *core.TokenPool) (err error)

func AddTokenTransferInputs

func AddTokenTransferInputs(op *core.Operation, transfer *core.TokenTransfer) (err error)

func RetrieveTokenApprovalInputs

func RetrieveTokenApprovalInputs(ctx context.Context, op *core.Operation) (approval *core.TokenApproval, err error)

func RetrieveTokenPoolActivateInputs

func RetrieveTokenPoolActivateInputs(ctx context.Context, op *core.Operation) (*fftypes.UUID, error)

func RetrieveTokenPoolCreateInputs

func RetrieveTokenPoolCreateInputs(ctx context.Context, op *core.Operation) (*core.TokenPool, error)

func RetrieveTokenTransferInputs

func RetrieveTokenTransferInputs(ctx context.Context, op *core.Operation) (*core.TokenTransfer, error)

Types

type Helper

type Helper interface {
	SubmitNewTransaction(ctx context.Context, txType core.TransactionType, idempotencyKey core.IdempotencyKey) (*fftypes.UUID, error)
	PersistTransaction(ctx context.Context, id *fftypes.UUID, txType core.TransactionType, blockchainTXID string) (valid bool, err error)
	AddBlockchainTX(ctx context.Context, tx *core.Transaction, blockchainTXID string) error
	InsertOrGetBlockchainEvent(ctx context.Context, event *core.BlockchainEvent) (existing *core.BlockchainEvent, err error)
	GetTransactionByIDCached(ctx context.Context, id *fftypes.UUID) (*core.Transaction, error)
	GetBlockchainEventByIDCached(ctx context.Context, id *fftypes.UUID) (*core.BlockchainEvent, error)
}

func NewTransactionHelper

func NewTransactionHelper(ctx context.Context, ns string, di database.Plugin, dm data.Manager, cacheManager cache.Manager) (Helper, error)