sqlcommon

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// SQLConfMigrationsAuto enables automatic migrations
	SQLConfMigrationsAuto = "migrations.auto"
	// SQLConfMigrationsDirectory is the directory containing the numerically ordered migration DDL files to apply to the database
	SQLConfMigrationsDirectory = "migrations.directory"
	// SQLConfDatasourceURL is the datasource connection URL string
	SQLConfDatasourceURL = "url"
	// SQLConfMaxConnections maximum connections to the database
	SQLConfMaxConnections = "maxConns"
	// SQLConfMaxConnIdleTime maximum connections to the database
	SQLConfMaxConnIdleTime = "maxConnIdleTime"
	// SQLConfMaxIdleConns maximum connections to the database
	SQLConfMaxIdleConns = "maxIdleConns"
	// SQLConfMaxConnLifetime maximum connections to the database
	SQLConfMaxConnLifetime = "maxConnLifetime"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type IdempotencyError 

type IdempotencyError struct {
	ExistingTXID  *fftypes.UUID
	OriginalError error
}

func (*IdempotencyError) Error 

func (e *IdempotencyError) Error() string

type SQLCommon 

type SQLCommon struct {
	dbsql.Database
	// contains filtered or unexported fields
}

func (*SQLCommon) Capabilities 

func (s *SQLCommon) Capabilities() *database.Capabilities

func (*SQLCommon) DeleteBlob 

func (s *SQLCommon) DeleteBlob(ctx context.Context, sequence int64) (err error)

func (*SQLCommon) DeleteContractAPI 

func (s *SQLCommon) DeleteContractAPI(ctx context.Context, namespace string, id *fftypes.UUID) error

func (*SQLCommon) DeleteContractListenerByID 

func (s *SQLCommon) DeleteContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) (err error)

func (*SQLCommon) DeleteData 

func (s *SQLCommon) DeleteData(ctx context.Context, namespace string, id *fftypes.UUID) (err error)

func (*SQLCommon) DeleteFFI 

func (s *SQLCommon) DeleteFFI(ctx context.Context, namespace string, id *fftypes.UUID) error

func (*SQLCommon) DeleteNonce 

func (s *SQLCommon) DeleteNonce(ctx context.Context, hash *fftypes.Bytes32) (err error)

func (*SQLCommon) DeleteOffset 

func (s *SQLCommon) DeleteOffset(ctx context.Context, t core.OffsetType, name string) (err error)

func (*SQLCommon) DeleteSubscriptionByID 

func (s *SQLCommon) DeleteSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) (err error)

func (*SQLCommon) DeleteTokenApprovals 

func (s *SQLCommon) DeleteTokenApprovals(ctx context.Context, namespace string, poolID *fftypes.UUID) error

func (*SQLCommon) DeleteTokenBalances 

func (s *SQLCommon) DeleteTokenBalances(ctx context.Context, namespace string, poolID *fftypes.UUID) error

func (*SQLCommon) DeleteTokenPool 

func (s *SQLCommon) DeleteTokenPool(ctx context.Context, namespace string, id *fftypes.UUID) error

func (*SQLCommon) DeleteTokenTransfers 

func (s *SQLCommon) DeleteTokenTransfers(ctx context.Context, namespace string, poolID *fftypes.UUID) error

func (*SQLCommon) GetBatchByID 

func (s *SQLCommon) GetBatchByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.BatchPersisted, err error)

func (*SQLCommon) GetBatchIDsForDataAttachments 

func (s *SQLCommon) GetBatchIDsForDataAttachments(ctx context.Context, namespace string, dataIDs []*fftypes.UUID) (batchIDs []*fftypes.UUID, err error)

func (*SQLCommon) GetBatchIDsForMessages 

func (s *SQLCommon) GetBatchIDsForMessages(ctx context.Context, namespace string, msgIDs []*fftypes.UUID) (batchIDs []*fftypes.UUID, err error)

func (*SQLCommon) GetBatches 

func (s *SQLCommon) GetBatches(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.BatchPersisted, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetBlobs 

func (s *SQLCommon) GetBlobs(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Blob, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetBlockchainEventByID 

func (s *SQLCommon) GetBlockchainEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.BlockchainEvent, error)

func (*SQLCommon) GetBlockchainEventByProtocolID 

func (s *SQLCommon) GetBlockchainEventByProtocolID(ctx context.Context, ns string, listener *fftypes.UUID, protocolID string) (*core.BlockchainEvent, error)

func (*SQLCommon) GetBlockchainEvents 

func (s *SQLCommon) GetBlockchainEvents(ctx context.Context, namespace string, filter ffapi.Filter) ([]*core.BlockchainEvent, *ffapi.FilterResult, error)

func (*SQLCommon) GetChartHistogram 

func (s *SQLCommon) GetChartHistogram(ctx context.Context, ns string, intervals []core.ChartHistogramInterval, collection database.CollectionName) (histogramList []*core.ChartHistogram, err error)

func (*SQLCommon) GetContractAPIByID 

func (s *SQLCommon) GetContractAPIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.ContractAPI, error)

func (*SQLCommon) GetContractAPIByName 

func (s *SQLCommon) GetContractAPIByName(ctx context.Context, namespace, name string) (*core.ContractAPI, error)

func (*SQLCommon) GetContractAPIByNetworkName 

func (s *SQLCommon) GetContractAPIByNetworkName(ctx context.Context, namespace, networkName string) (*core.ContractAPI, error)

func (*SQLCommon) GetContractAPIs 

func (s *SQLCommon) GetContractAPIs(ctx context.Context, namespace string, filter ffapi.AndFilter) (contractAPIs []*core.ContractAPI, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetContractListener 

func (s *SQLCommon) GetContractListener(ctx context.Context, namespace, name string) (sub *core.ContractListener, err error)

func (*SQLCommon) GetContractListenerByBackendID 

func (s *SQLCommon) GetContractListenerByBackendID(ctx context.Context, namespace, id string) (sub *core.ContractListener, err error)

func (*SQLCommon) GetContractListenerByID 

func (s *SQLCommon) GetContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) (sub *core.ContractListener, err error)

func (*SQLCommon) GetContractListeners 

func (s *SQLCommon) GetContractListeners(ctx context.Context, namespace string, filter ffapi.Filter) ([]*core.ContractListener, *ffapi.FilterResult, error)

func (*SQLCommon) GetData 

func (s *SQLCommon) GetData(ctx context.Context, namespace string, filter ffapi.Filter) (message core.DataArray, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetDataByID 

func (s *SQLCommon) GetDataByID(ctx context.Context, namespace string, id *fftypes.UUID, withValue bool) (message *core.Data, err error)

func (*SQLCommon) GetDataRefs 

func (s *SQLCommon) GetDataRefs(ctx context.Context, namespace string, filter ffapi.Filter) (message core.DataRefs, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetDataSubPaths 

func (s *SQLCommon) GetDataSubPaths(ctx context.Context, namespace, path string) (subPaths []string, err error)

func (*SQLCommon) GetDatatypeByID 

func (s *SQLCommon) GetDatatypeByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.Datatype, err error)

func (*SQLCommon) GetDatatypeByName 

func (s *SQLCommon) GetDatatypeByName(ctx context.Context, ns, name, version string) (message *core.Datatype, err error)

func (*SQLCommon) GetDatatypes 

func (s *SQLCommon) GetDatatypes(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Datatype, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetEventByID 

func (s *SQLCommon) GetEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.Event, err error)

func (*SQLCommon) GetEvents 

func (s *SQLCommon) GetEvents(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Event, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetEventsInSequenceRange 

func (s *SQLCommon) GetEventsInSequenceRange(ctx context.Context, namespace string, filter ffapi.Filter, startSequence int, endSequence int) (message []*core.Event, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetFFI 

func (s *SQLCommon) GetFFI(ctx context.Context, namespace, name, version string) (*fftypes.FFI, error)

func (*SQLCommon) GetFFIByID 

func (s *SQLCommon) GetFFIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*fftypes.FFI, error)

func (*SQLCommon) GetFFIByNetworkName 

func (s *SQLCommon) GetFFIByNetworkName(ctx context.Context, namespace, networkName, version string) (*fftypes.FFI, error)

func (*SQLCommon) GetFFIErrors 

func (s *SQLCommon) GetFFIErrors(ctx context.Context, namespace string, filter ffapi.Filter) (errors []*fftypes.FFIError, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetFFIEvent 

func (s *SQLCommon) GetFFIEvent(ctx context.Context, namespace string, interfaceID *fftypes.UUID, pathName string) (*fftypes.FFIEvent, error)

func (*SQLCommon) GetFFIEvents 

func (s *SQLCommon) GetFFIEvents(ctx context.Context, namespace string, filter ffapi.Filter) (events []*fftypes.FFIEvent, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetFFIMethod 

func (s *SQLCommon) GetFFIMethod(ctx context.Context, ns string, interfaceID *fftypes.UUID, pathName string) (*fftypes.FFIMethod, error)

func (*SQLCommon) GetFFIMethods 

func (s *SQLCommon) GetFFIMethods(ctx context.Context, namespace string, filter ffapi.Filter) (methods []*fftypes.FFIMethod, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetFFIs 

func (s *SQLCommon) GetFFIs(ctx context.Context, namespace string, filter ffapi.Filter) (ffis []*fftypes.FFI, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetGroupByHash 

func (s *SQLCommon) GetGroupByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (group *core.Group, err error)

func (*SQLCommon) GetGroups 

func (s *SQLCommon) GetGroups(ctx context.Context, namespace string, filter ffapi.Filter) (group []*core.Group, res *ffapi.FilterResult, err error)

func (*SQLCommon) GetIdentities 

func (s *SQLCommon) GetIdentities(ctx context.Context, namespace string, filter ffapi.Filter) (identities []*core.Identity, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetIdentityByDID 

func (s *SQLCommon) GetIdentityByDID(ctx context.Context, namespace, did string) (identity *core.Identity, err error)

func (*SQLCommon) GetIdentityByID 

func (s *SQLCommon) GetIdentityByID(ctx context.Context, namespace string, id *fftypes.UUID) (identity *core.Identity, err error)

func (*SQLCommon) GetIdentityByName 

func (s *SQLCommon) GetIdentityByName(ctx context.Context, iType core.IdentityType, namespace, name string) (identity *core.Identity, err error)

func (*SQLCommon) GetMessageByID 

func (s *SQLCommon) GetMessageByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.Message, err error)

func (*SQLCommon) GetMessageIDs 

func (s *SQLCommon) GetMessageIDs(ctx context.Context, namespace string, filter ffapi.Filter) (ids []*core.IDAndSequence, err error)

func (*SQLCommon) GetMessages 

func (s *SQLCommon) GetMessages(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Message, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetMessagesForData 

func (s *SQLCommon) GetMessagesForData(ctx context.Context, namespace string, dataID *fftypes.UUID, filter ffapi.Filter) (message []*core.Message, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetNamespace 

func (s *SQLCommon) GetNamespace(ctx context.Context, name string) (message *core.Namespace, err error)

func (*SQLCommon) GetNextPins 

func (s *SQLCommon) GetNextPins(ctx context.Context, namespace string, filter ffapi.Filter) ([]*core.NextPin, *ffapi.FilterResult, error)

func (*SQLCommon) GetNextPinsForContext 

func (s *SQLCommon) GetNextPinsForContext(ctx context.Context, namespace string, context *fftypes.Bytes32) (message []*core.NextPin, err error)

func (*SQLCommon) GetNonce 

func (s *SQLCommon) GetNonce(ctx context.Context, hash *fftypes.Bytes32) (message *core.Nonce, err error)

func (*SQLCommon) GetNonces 

func (s *SQLCommon) GetNonces(ctx context.Context, filter ffapi.Filter) (message []*core.Nonce, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetOffset 

func (s *SQLCommon) GetOffset(ctx context.Context, t core.OffsetType, name string) (message *core.Offset, err error)

func (*SQLCommon) GetOffsets 

func (s *SQLCommon) GetOffsets(ctx context.Context, filter ffapi.Filter) (message []*core.Offset, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetOperationByID 

func (s *SQLCommon) GetOperationByID(ctx context.Context, namespace string, id *fftypes.UUID) (operation *core.Operation, err error)

func (*SQLCommon) GetOperations 

func (s *SQLCommon) GetOperations(ctx context.Context, namespace string, filter ffapi.Filter) (operation []*core.Operation, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetPins 

func (s *SQLCommon) GetPins(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Pin, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetSubscriptionByID 

func (s *SQLCommon) GetSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.Subscription, err error)

func (*SQLCommon) GetSubscriptionByName 

func (s *SQLCommon) GetSubscriptionByName(ctx context.Context, namespace, name string) (message *core.Subscription, err error)

func (*SQLCommon) GetSubscriptions 

func (s *SQLCommon) GetSubscriptions(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Subscription, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetTokenAccountPools 

func (s *SQLCommon) GetTokenAccountPools(ctx context.Context, namespace, key string, filter ffapi.Filter) ([]*core.TokenAccountPool, *ffapi.FilterResult, error)

func (*SQLCommon) GetTokenAccounts 

func (s *SQLCommon) GetTokenAccounts(ctx context.Context, namespace string, filter ffapi.Filter) ([]*core.TokenAccount, *ffapi.FilterResult, error)

func (*SQLCommon) GetTokenApprovalByID 

func (s *SQLCommon) GetTokenApprovalByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenApproval, error)

func (*SQLCommon) GetTokenApprovalByProtocolID 

func (s *SQLCommon) GetTokenApprovalByProtocolID(ctx context.Context, namespace string, poolID *fftypes.UUID, protocolID string) (*core.TokenApproval, error)

func (*SQLCommon) GetTokenApprovals 

func (s *SQLCommon) GetTokenApprovals(ctx context.Context, namespace string, filter ffapi.Filter) (approvals []*core.TokenApproval, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetTokenBalance 

func (s *SQLCommon) GetTokenBalance(ctx context.Context, namespace string, poolID *fftypes.UUID, tokenIndex, key string) (message *core.TokenBalance, err error)

func (*SQLCommon) GetTokenBalances 

func (s *SQLCommon) GetTokenBalances(ctx context.Context, namespace string, filter ffapi.Filter) ([]*core.TokenBalance, *ffapi.FilterResult, error)

func (*SQLCommon) GetTokenPool 

func (s *SQLCommon) GetTokenPool(ctx context.Context, namespace string, name string) (message *core.TokenPool, err error)

func (*SQLCommon) GetTokenPoolByID 

func (s *SQLCommon) GetTokenPoolByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.TokenPool, err error)

func (*SQLCommon) GetTokenPoolByNetworkName 

func (s *SQLCommon) GetTokenPoolByNetworkName(ctx context.Context, namespace, networkName string) (*core.TokenPool, error)

func (*SQLCommon) GetTokenPools 

func (s *SQLCommon) GetTokenPools(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.TokenPool, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetTokenTransferByID 

func (s *SQLCommon) GetTokenTransferByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenTransfer, error)

func (*SQLCommon) GetTokenTransferByProtocolID 

func (s *SQLCommon) GetTokenTransferByProtocolID(ctx context.Context, namespace string, poolID *fftypes.UUID, protocolID string) (*core.TokenTransfer, error)

func (*SQLCommon) GetTokenTransfers 

func (s *SQLCommon) GetTokenTransfers(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.TokenTransfer, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetTransactionByID 

func (s *SQLCommon) GetTransactionByID(ctx context.Context, namespace string, id *fftypes.UUID) (message *core.Transaction, err error)

func (*SQLCommon) GetTransactions 

func (s *SQLCommon) GetTransactions(ctx context.Context, namespace string, filter ffapi.Filter) (message []*core.Transaction, fr *ffapi.FilterResult, err error)

func (*SQLCommon) GetVerifierByHash 

func (s *SQLCommon) GetVerifierByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (verifier *core.Verifier, err error)

func (*SQLCommon) GetVerifierByValue 

func (s *SQLCommon) GetVerifierByValue(ctx context.Context, vType core.VerifierType, namespace, value string) (verifier *core.Verifier, err error)

func (*SQLCommon) GetVerifiers 

func (s *SQLCommon) GetVerifiers(ctx context.Context, namespace string, filter ffapi.Filter) (verifiers []*core.Verifier, fr *ffapi.FilterResult, err error)

func (*SQLCommon) Init 

func (s *SQLCommon) Init(ctx context.Context, provider dbsql.Provider, config config.Section, capabilities *database.Capabilities) (err error)

func (*SQLCommon) InitConfig 

func (s *SQLCommon) InitConfig(provider dbsql.Provider, config config.Section)

func (*SQLCommon) InsertBlob 

func (s *SQLCommon) InsertBlob(ctx context.Context, blob *core.Blob) (err error)

func (*SQLCommon) InsertBlobs 

func (s *SQLCommon) InsertBlobs(ctx context.Context, blobs []*core.Blob) (err error)

func (*SQLCommon) InsertBlockchainEvents 

func (s *SQLCommon) InsertBlockchainEvents(ctx context.Context, events []*core.BlockchainEvent, hooks ...database.PostCompletionHook) (err error)

func (*SQLCommon) InsertContractListener 

func (s *SQLCommon) InsertContractListener(ctx context.Context, listener *core.ContractListener) (err error)

func (*SQLCommon) InsertDataArray 

func (s *SQLCommon) InsertDataArray(ctx context.Context, dataArray core.DataArray) (err error)

func (*SQLCommon) InsertEvent 

func (s *SQLCommon) InsertEvent(ctx context.Context, event *core.Event) (err error)

Events are special.

They are an ordered sequence of recorded state, that must be detected and processed in order.

We choose (today) to coordinate the emission of these, into a DB transaction where the other state changes happen - so the event is assured atomically to happen "after" the other state changes, but also not to be lost. Downstream fan-out of those events occurs via Webhook/WebSocket (.../NATS/Kafka) pluggable pub/sub interfaces.

Implementing this single stream of incrementing (note not guaranteed to be gapless) ordered items on top of a SQL database, means taking a lock (see below). This is not safe to do unless you are really sure what other locks will be taken after that in the transaction. So we defer the emission of the events to a pre-commit capture.

func (*SQLCommon) InsertMessages 

func (s *SQLCommon) InsertMessages(ctx context.Context, messages []*core.Message, hooks ...database.PostCompletionHook) (err error)

func (*SQLCommon) InsertNextPin 

func (s *SQLCommon) InsertNextPin(ctx context.Context, nextpin *core.NextPin) (err error)

func (*SQLCommon) InsertNonce 

func (s *SQLCommon) InsertNonce(ctx context.Context, nonce *core.Nonce) (err error)

func (*SQLCommon) InsertOperation 

func (s *SQLCommon) InsertOperation(ctx context.Context, operation *core.Operation, hooks ...database.PostCompletionHook) (err error)

func (*SQLCommon) InsertOperations 

func (s *SQLCommon) InsertOperations(ctx context.Context, operations []*core.Operation, hooks ...database.PostCompletionHook) (err error)

func (*SQLCommon) InsertOrGetBatch 

func (s *SQLCommon) InsertOrGetBatch(ctx context.Context, batch *core.BatchPersisted) (existing *core.BatchPersisted, err error)

func (*SQLCommon) InsertOrGetBlockchainEvent 

func (s *SQLCommon) InsertOrGetBlockchainEvent(ctx context.Context, event *core.BlockchainEvent) (existing *core.BlockchainEvent, err error)

func (*SQLCommon) InsertOrGetContractAPI 

func (s *SQLCommon) InsertOrGetContractAPI(ctx context.Context, api *core.ContractAPI) (*core.ContractAPI, error)

func (*SQLCommon) InsertOrGetFFI 

func (s *SQLCommon) InsertOrGetFFI(ctx context.Context, ffi *fftypes.FFI) (existing *fftypes.FFI, err error)

func (*SQLCommon) InsertOrGetTokenPool 

func (s *SQLCommon) InsertOrGetTokenPool(ctx context.Context, pool *core.TokenPool) (existing *core.TokenPool, err error)

func (*SQLCommon) InsertOrGetTokenTransfer 

func (s *SQLCommon) InsertOrGetTokenTransfer(ctx context.Context, transfer *core.TokenTransfer) (existing *core.TokenTransfer, err error)

func (*SQLCommon) InsertPins 

func (s *SQLCommon) InsertPins(ctx context.Context, pins []*core.Pin) error

func (*SQLCommon) InsertTransaction 

func (s *SQLCommon) InsertTransaction(ctx context.Context, transaction *core.Transaction) (err error)

func (*SQLCommon) InsertTransactions 

func (s *SQLCommon) InsertTransactions(ctx context.Context, txns []*core.Transaction) (err error)

func (*SQLCommon) ReplaceMessage 

func (s *SQLCommon) ReplaceMessage(ctx context.Context, message *core.Message) (err error)

In SQL update+bump is a delete+insert within a TX

func (*SQLCommon) SetHandler 

func (s *SQLCommon) SetHandler(namespace string, handler database.Callbacks)

func (*SQLCommon) UpdateBatch 

func (s *SQLCommon) UpdateBatch(ctx context.Context, namespace string, id *fftypes.UUID, update ffapi.Update) (err error)

func (*SQLCommon) UpdateContractListener 

func (s *SQLCommon) UpdateContractListener(ctx context.Context, ns string, id *fftypes.UUID, update ffapi.Update) (err error)

func (*SQLCommon) UpdateData 

func (s *SQLCommon) UpdateData(ctx context.Context, namespace string, id *fftypes.UUID, update ffapi.Update) (err error)

func (*SQLCommon) UpdateMessage 

func (s *SQLCommon) UpdateMessage(ctx context.Context, namespace string, msgid *fftypes.UUID, update ffapi.Update) (err error)

func (*SQLCommon) UpdateMessages 

func (s *SQLCommon) UpdateMessages(ctx context.Context, namespace string, filter ffapi.Filter, update ffapi.Update) (err error)

func (*SQLCommon) UpdateNextPin 

func (s *SQLCommon) UpdateNextPin(ctx context.Context, namespace string, sequence int64, update ffapi.Update) (err error)

func (*SQLCommon) UpdateNonce 

func (s *SQLCommon) UpdateNonce(ctx context.Context, nonce *core.Nonce) (err error)

func (*SQLCommon) UpdateOffset 

func (s *SQLCommon) UpdateOffset(ctx context.Context, rowID int64, update ffapi.Update) (err error)

func (*SQLCommon) UpdateOperation 

func (s *SQLCommon) UpdateOperation(ctx context.Context, ns string, id *fftypes.UUID, filter ffapi.Filter, update ffapi.Update) (updated bool, err error)

func (*SQLCommon) UpdatePins 

func (s *SQLCommon) UpdatePins(ctx context.Context, namespace string, filter ffapi.Filter, update ffapi.Update) (err error)

func (*SQLCommon) UpdateSubscription 

func (s *SQLCommon) UpdateSubscription(ctx context.Context, namespace, name string, update ffapi.Update) (err error)

func (*SQLCommon) UpdateTokenApprovals 

func (s *SQLCommon) UpdateTokenApprovals(ctx context.Context, filter ffapi.Filter, update ffapi.Update) (err error)

func (*SQLCommon) UpdateTokenBalances 

func (s *SQLCommon) UpdateTokenBalances(ctx context.Context, transfer *core.TokenTransfer) (err error)

func (*SQLCommon) UpdateTransaction 

func (s *SQLCommon) UpdateTransaction(ctx context.Context, namespace string, id *fftypes.UUID, update ffapi.Update) (err error)

func (*SQLCommon) UpsertContractAPI 

func (s *SQLCommon) UpsertContractAPI(ctx context.Context, api *core.ContractAPI, optimization database.UpsertOptimization) (err error)

func (*SQLCommon) UpsertContractListener 

func (s *SQLCommon) UpsertContractListener(ctx context.Context, listener *core.ContractListener, allowExisting bool) (err error)

func (*SQLCommon) UpsertData 

func (s *SQLCommon) UpsertData(ctx context.Context, data *core.Data, optimization database.UpsertOptimization) (err error)

func (*SQLCommon) UpsertDatatype 

func (s *SQLCommon) UpsertDatatype(ctx context.Context, datatype *core.Datatype, allowExisting bool) (err error)

func (*SQLCommon) UpsertFFI 

func (s *SQLCommon) UpsertFFI(ctx context.Context, ffi *fftypes.FFI, optimization database.UpsertOptimization) error

func (*SQLCommon) UpsertFFIError 

func (s *SQLCommon) UpsertFFIError(ctx context.Context, errorDef *fftypes.FFIError) (err error)

func (*SQLCommon) UpsertFFIEvent 

func (s *SQLCommon) UpsertFFIEvent(ctx context.Context, event *fftypes.FFIEvent) (err error)

func (*SQLCommon) UpsertFFIMethod 

func (s *SQLCommon) UpsertFFIMethod(ctx context.Context, method *fftypes.FFIMethod) (err error)

func (*SQLCommon) UpsertGroup 

func (s *SQLCommon) UpsertGroup(ctx context.Context, group *core.Group, optimization database.UpsertOptimization) (err error)

func (*SQLCommon) UpsertIdentity 

func (s *SQLCommon) UpsertIdentity(ctx context.Context, identity *core.Identity, optimization database.UpsertOptimization) (err error)

func (*SQLCommon) UpsertMessage 

func (s *SQLCommon) UpsertMessage(ctx context.Context, message *core.Message, optimization database.UpsertOptimization, hooks ...database.PostCompletionHook) (err error)

func (*SQLCommon) UpsertNamespace 

func (s *SQLCommon) UpsertNamespace(ctx context.Context, namespace *core.Namespace, allowExisting bool) (err error)

func (*SQLCommon) UpsertOffset 

func (s *SQLCommon) UpsertOffset(ctx context.Context, offset *core.Offset, allowExisting bool) (err error)

func (*SQLCommon) UpsertPin 

func (s *SQLCommon) UpsertPin(ctx context.Context, pin *core.Pin) (err error)

func (*SQLCommon) UpsertSubscription 

func (s *SQLCommon) UpsertSubscription(ctx context.Context, subscription *core.Subscription, allowExisting bool) (err error)

func (*SQLCommon) UpsertTokenApproval 

func (s *SQLCommon) UpsertTokenApproval(ctx context.Context, approval *core.TokenApproval) (err error)

func (*SQLCommon) UpsertTokenPool 

func (s *SQLCommon) UpsertTokenPool(ctx context.Context, pool *core.TokenPool, optimization database.UpsertOptimization) (err error)

func (*SQLCommon) UpsertVerifier 

func (s *SQLCommon) UpsertVerifier(ctx context.Context, verifier *core.Verifier, optimization database.UpsertOptimization) (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.