txhandler

package

Go to main page

Versions in this module

v1

v1.3.18

Sep 13, 2024

v1.3.17

Sep 11, 2024

v1.3.16

Sep 3, 2024

v1.3.15

Jun 14, 2024

v1.3.14

Jun 6, 2024

v1.3.13

Jun 5, 2024

v1.3.12

May 22, 2024

v1.3.11

Apr 24, 2024

v1.3.10

Apr 10, 2024

v1.3.9

Mar 27, 2024

v1.3.8

Feb 29, 2024

v1.3.7

Feb 14, 2024

v1.3.6

Jan 12, 2024

v1.3.5

Dec 21, 2023

v1.3.4

Sep 28, 2023

v1.3.3

Aug 9, 2023

Changes in this version

+ type NextNonceCallback func(ctx context.Context, signer string) (uint64, error)

type RichQuery

+ ListListeners func(ctx context.Context, filter ffapi.AndFilter) ([]*apitypes.Listener, *ffapi.FilterResult, error)

+ ListStreamListeners func(ctx context.Context, streamID *fftypes.UUID, filter ffapi.AndFilter) ([]*apitypes.Listener, *ffapi.FilterResult, error)

+ ListStreams func(ctx context.Context, filter ffapi.AndFilter) ([]*apitypes.EventStream, *ffapi.FilterResult, error)

+ ListTransactionConfirmations func(ctx context.Context, txID string, filter ffapi.AndFilter) ([]*apitypes.ConfirmationRecord, *ffapi.FilterResult, error)

+ ListTransactionHistory func(ctx context.Context, txID string, filter ffapi.AndFilter) ([]*apitypes.TXHistoryRecord, *ffapi.FilterResult, error)

+ ListTransactions func(ctx context.Context, filter ffapi.AndFilter) ([]*apitypes.ManagedTX, *ffapi.FilterResult, error)

+ NewConfirmationFilter func(ctx context.Context) ffapi.FilterBuilder

+ NewListenerFilter func(ctx context.Context) ffapi.FilterBuilder

+ NewStreamFilter func(ctx context.Context) ffapi.FilterBuilder

+ NewTransactionFilter func(ctx context.Context) ffapi.FilterBuilder

+ NewTxHistoryFilter func(ctx context.Context) ffapi.FilterBuilder

+ type SortDirection int

+ const SortDirectionAscending

+ const SortDirectionDescending

type TransactionHistoryPersistence

+ AddSubStatusAction func(ctx context.Context, txID string, subStatus apitypes.TxSubStatus, ...) error

type TransactionMetrics

+ IncTxHandlerCounterMetric func(ctx context.Context, metricName string, ...)

+ IncTxHandlerCounterMetricWithLabels func(ctx context.Context, metricName string, labels map[string]string, ...)

+ InitTxHandlerCounterMetric func(ctx context.Context, metricName string, helpText string, ...)

+ InitTxHandlerCounterMetricWithLabels func(ctx context.Context, metricName string, helpText string, labelNames []string, ...)

+ InitTxHandlerGaugeMetric func(ctx context.Context, metricName string, helpText string, ...)

+ InitTxHandlerGaugeMetricWithLabels func(ctx context.Context, metricName string, helpText string, labelNames []string, ...)

+ InitTxHandlerHistogramMetric func(ctx context.Context, metricName string, helpText string, buckets []float64, ...)

+ InitTxHandlerHistogramMetricWithLabels func(ctx context.Context, metricName string, helpText string, buckets []float64, ...)

+ InitTxHandlerSummaryMetric func(ctx context.Context, metricName string, helpText string, ...)

+ InitTxHandlerSummaryMetricWithLabels func(ctx context.Context, metricName string, helpText string, labelNames []string, ...)

+ ObserveTxHandlerHistogramMetric func(ctx context.Context, metricName string, number float64, ...)

+ ObserveTxHandlerHistogramMetricWithLabels func(ctx context.Context, metricName string, number float64, ...)

+ ObserveTxHandlerSummaryMetric func(ctx context.Context, metricName string, number float64, ...)

+ ObserveTxHandlerSummaryMetricWithLabels func(ctx context.Context, metricName string, number float64, ...)

+ SetTxHandlerGaugeMetric func(ctx context.Context, metricName string, number float64, ...)

+ SetTxHandlerGaugeMetricWithLabels func(ctx context.Context, metricName string, number float64, ...)

type TransactionPersistence

+ AddTransactionConfirmations func(ctx context.Context, txID string, clearExisting bool, ...) error

+ DeleteTransaction func(ctx context.Context, txID string) error

+ GetTransactionByID func(ctx context.Context, txID string) (*apitypes.ManagedTX, error)

+ GetTransactionByIDWithStatus func(ctx context.Context, txID string, history bool) (*apitypes.TXWithStatus, error)

+ GetTransactionByNonce func(ctx context.Context, signer string, nonce *fftypes.FFBigInt) (*apitypes.ManagedTX, error)

+ GetTransactionConfirmations func(ctx context.Context, txID string) ([]*apitypes.Confirmation, error)

+ GetTransactionReceipt func(ctx context.Context, txID string) (receipt *ffcapi.TransactionReceiptResponse, err error)

+ InsertTransactionPreAssignedNonce func(ctx context.Context, tx *apitypes.ManagedTX) error

+ InsertTransactionWithNextNonce func(ctx context.Context, tx *apitypes.ManagedTX, lookupNextNonce NextNonceCallback) error

+ ListTransactionsByCreateTime func(ctx context.Context, after *apitypes.ManagedTX, limit int, dir SortDirection) ([]*apitypes.ManagedTX, error)

+ ListTransactionsByNonce func(ctx context.Context, signer string, after *fftypes.FFBigInt, limit int, ...) ([]*apitypes.ManagedTX, error)

+ ListTransactionsPending func(ctx context.Context, afterSequenceID string, limit int, dir SortDirection) ([]*apitypes.ManagedTX, error)

+ SetTransactionReceipt func(ctx context.Context, txID string, receipt *ffcapi.TransactionReceiptResponse) error

+ UpdateTransaction func(ctx context.Context, txID string, updates *apitypes.TXUpdates) error

v1.3.2

Aug 2, 2023

v1.3.1

Jul 14, 2023

v1.3.0

Jul 3, 2023

Changes in this version

+ type RichQuery interface

type Toolkit

+ RichQuery RichQuery

type TransactionHandler

+ HandleResumeTransaction func(ctx context.Context, txID string) (mtx *apitypes.ManagedTX, err error)

+ HandleSuspendTransaction func(ctx context.Context, txID string) (mtx *apitypes.ManagedTX, err error)

+ HandleTransactionConfirmations func(ctx context.Context, txID string, ...) (err error)

+ type TransactionHistoryPersistence interface

v1.2.14

May 31, 2023

v1.2.13

May 24, 2023

v1.2.12

May 22, 2023

v1.2.11

May 3, 2023

v1.2.10

Apr 27, 2023

v1.2.9

Mar 31, 2023

v1.2.8

Mar 23, 2023

v1.2.7

Mar 21, 2023

v1.2.6

Mar 10, 2023

v1.2.5

Mar 3, 2023

v1.2.4

Feb 23, 2023

Changes in this version

+ type ManagedTxEventHandler interface

+ HandleEvent func(ctx context.Context, e apitypes.ManagedTransactionEvent) error

+ type Toolkit struct

+ Connector ffcapi.API

+ EventHandler ManagedTxEventHandler

+ MetricsManager TransactionMetrics

+ TXHistory txhistory.Manager

+ TXPersistence TransactionPersistence

+ type TransactionHandler interface

+ HandleCancelTransaction func(ctx context.Context, txID string) (mtx *apitypes.ManagedTX, err error)

+ HandleNewContractDeployment func(ctx context.Context, txReq *apitypes.ContractDeployRequest) (mtx *apitypes.ManagedTX, err error)

+ HandleNewTransaction func(ctx context.Context, txReq *apitypes.TransactionRequest) (mtx *apitypes.ManagedTX, err error)

+ HandleTransactionConfirmed func(ctx context.Context, txID string, confirmations []apitypes.BlockInfo) (err error)

+ HandleTransactionReceiptReceived func(ctx context.Context, txID string, receipt *ffcapi.TransactionReceiptResponse) (err error)

+ Init func(ctx context.Context, toolkit *Toolkit)

+ Start func(ctx context.Context) (done <-chan struct{}, err error)

+ type TransactionMetrics interface

+ type TransactionPersistence interface

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