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 OpBlockchainInvoke(op *core.Operation, req *core.ContractCallRequest, batch *BatchPinData) *core.PreparedOperation
• func RetrieveBlockchainInvokeInputs(ctx context.Context, op *core.Operation) (*core.ContractCallRequest, 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 BatchPinData
• type BatchedTransactionInsert
• type BlockchainInvokeData
• type Helper
  • func NewTransactionHelper(ctx context.Context, ns string, di database.Plugin, dm data.Manager, ...) (Helper, error)
• type TransactionInsertInput

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 OpBlockchainInvoke

func OpBlockchainInvoke(op *core.Operation, req *core.ContractCallRequest, batch *BatchPinData) *core.PreparedOperation

func RetrieveBlockchainInvokeInputs

func RetrieveBlockchainInvokeInputs(ctx context.Context, op *core.Operation) (*core.ContractCallRequest, 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 BatchPinData

type BatchPinData struct {
	Batch      *core.BatchPersisted `json:"batch"`
	Contexts   []*fftypes.Bytes32   `json:"contexts"`
	PayloadRef string               `json:"payloadRef"`
}

type BatchedTransactionInsert

type BatchedTransactionInsert struct {
	Input  TransactionInsertInput
	Output struct {
		IdempotencyError error
		Transaction      *core.Transaction
	}
}

type BlockchainInvokeData

type BlockchainInvokeData struct {
	Request  *core.ContractCallRequest `json:"request"`
	BatchPin *BatchPinData             `json:"batchPin"`
}

type Helper

type Helper interface {
	SubmitNewTransaction(ctx context.Context, txType core.TransactionType, idempotencyKey core.IdempotencyKey) (*fftypes.UUID, error)
	SubmitNewTransactionBatch(ctx context.Context, namespace string, batch []*BatchedTransactionInsert) 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)
	InsertNewBlockchainEvents(ctx context.Context, events []*core.BlockchainEvent) (inserted []*core.BlockchainEvent, err error)
	GetTransactionByIDCached(ctx context.Context, id *fftypes.UUID) (*core.Transaction, error)
	GetBlockchainEventByIDCached(ctx context.Context, id *fftypes.UUID) (*core.BlockchainEvent, error)
	FindOperationInTransaction(ctx context.Context, tx *fftypes.UUID, opType core.OpType) (*core.Operation, error)
}

func NewTransactionHelper

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

type TransactionInsertInput

type TransactionInsertInput struct {
	Type           core.TransactionType
	IdempotencyKey core.IdempotencyKey
}