Documentation ¶
Index ¶
- type Callbacks
- func (_m *Callbacks) HashCollectionNSEvent(resType database.HashCollectionNS, eventType core.ChangeEventType, ...)
- func (_m *Callbacks) OrderedCollectionNSEvent(resType database.OrderedCollectionNS, eventType core.ChangeEventType, ...)
- func (_m *Callbacks) OrderedUUIDCollectionNSEvent(resType database.OrderedUUIDCollectionNS, eventType core.ChangeEventType, ...)
- func (_m *Callbacks) UUIDCollectionNSEvent(resType database.UUIDCollectionNS, eventType core.ChangeEventType, ...)
- type Plugin
- func (_m *Plugin) Capabilities() *database.Capabilities
- func (_m *Plugin) DeleteBlob(ctx context.Context, sequence int64) error
- func (_m *Plugin) DeleteContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) error
- func (_m *Plugin) DeleteNonce(ctx context.Context, hash *fftypes.Bytes32) error
- func (_m *Plugin) DeleteOffset(ctx context.Context, t fftypes.FFEnum, name string) error
- func (_m *Plugin) DeleteSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) error
- func (_m *Plugin) GetBatchByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.BatchPersisted, error)
- func (_m *Plugin) GetBatchIDsForDataAttachments(ctx context.Context, namespace string, dataIDs []*fftypes.UUID) ([]*fftypes.UUID, error)
- func (_m *Plugin) GetBatchIDsForMessages(ctx context.Context, namespace string, msgIDs []*fftypes.UUID) ([]*fftypes.UUID, error)
- func (_m *Plugin) GetBatches(ctx context.Context, namespace string, filter database.Filter) ([]*core.BatchPersisted, *database.FilterResult, error)
- func (_m *Plugin) GetBlobMatchingHash(ctx context.Context, hash *fftypes.Bytes32) (*core.Blob, error)
- func (_m *Plugin) GetBlobs(ctx context.Context, filter database.Filter) ([]*core.Blob, *database.FilterResult, error)
- func (_m *Plugin) GetBlockchainEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.BlockchainEvent, error)
- func (_m *Plugin) GetBlockchainEventByProtocolID(ctx context.Context, namespace string, listener *fftypes.UUID, ...) (*core.BlockchainEvent, error)
- func (_m *Plugin) GetBlockchainEvents(ctx context.Context, namespace string, filter database.Filter) ([]*core.BlockchainEvent, *database.FilterResult, error)
- func (_m *Plugin) GetChartHistogram(ctx context.Context, namespace string, intervals []core.ChartHistogramInterval, ...) ([]*core.ChartHistogram, error)
- func (_m *Plugin) GetContractAPIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.ContractAPI, error)
- func (_m *Plugin) GetContractAPIByName(ctx context.Context, namespace string, name string) (*core.ContractAPI, error)
- func (_m *Plugin) GetContractAPIs(ctx context.Context, namespace string, filter database.AndFilter) ([]*core.ContractAPI, *database.FilterResult, error)
- func (_m *Plugin) GetContractListener(ctx context.Context, namespace string, name string) (*core.ContractListener, error)
- func (_m *Plugin) GetContractListenerByBackendID(ctx context.Context, namespace string, id string) (*core.ContractListener, error)
- func (_m *Plugin) GetContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.ContractListener, error)
- func (_m *Plugin) GetContractListeners(ctx context.Context, namespace string, filter database.Filter) ([]*core.ContractListener, *database.FilterResult, error)
- func (_m *Plugin) GetData(ctx context.Context, namespace string, filter database.Filter) (core.DataArray, *database.FilterResult, error)
- func (_m *Plugin) GetDataByID(ctx context.Context, namespace string, id *fftypes.UUID, withValue bool) (*core.Data, error)
- func (_m *Plugin) GetDataRefs(ctx context.Context, namespace string, filter database.Filter) (core.DataRefs, *database.FilterResult, error)
- func (_m *Plugin) GetDatatypeByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Datatype, error)
- func (_m *Plugin) GetDatatypeByName(ctx context.Context, namespace string, name string, version string) (*core.Datatype, error)
- func (_m *Plugin) GetDatatypes(ctx context.Context, namespace string, filter database.Filter) ([]*core.Datatype, *database.FilterResult, error)
- func (_m *Plugin) GetEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Event, error)
- func (_m *Plugin) GetEvents(ctx context.Context, namespace string, filter database.Filter) ([]*core.Event, *database.FilterResult, error)
- func (_m *Plugin) GetFFI(ctx context.Context, namespace string, name string, version string) (*fftypes.FFI, error)
- func (_m *Plugin) GetFFIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*fftypes.FFI, error)
- func (_m *Plugin) GetFFIEvent(ctx context.Context, namespace string, interfaceID *fftypes.UUID, ...) (*fftypes.FFIEvent, error)
- func (_m *Plugin) GetFFIEvents(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFIEvent, *database.FilterResult, error)
- func (_m *Plugin) GetFFIMethod(ctx context.Context, namespace string, interfaceID *fftypes.UUID, ...) (*fftypes.FFIMethod, error)
- func (_m *Plugin) GetFFIMethods(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFIMethod, *database.FilterResult, error)
- func (_m *Plugin) GetFFIs(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFI, *database.FilterResult, error)
- func (_m *Plugin) GetGroupByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (*core.Group, error)
- func (_m *Plugin) GetGroups(ctx context.Context, namespace string, filter database.Filter) ([]*core.Group, *database.FilterResult, error)
- func (_m *Plugin) GetIdentities(ctx context.Context, namespace string, filter database.Filter) ([]*core.Identity, *database.FilterResult, error)
- func (_m *Plugin) GetIdentityByDID(ctx context.Context, namespace string, did string) (*core.Identity, error)
- func (_m *Plugin) GetIdentityByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Identity, error)
- func (_m *Plugin) GetIdentityByName(ctx context.Context, iType fftypes.FFEnum, namespace string, name string) (*core.Identity, error)
- func (_m *Plugin) GetMessageByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Message, error)
- func (_m *Plugin) GetMessageIDs(ctx context.Context, namespace string, filter database.Filter) ([]*core.IDAndSequence, error)
- func (_m *Plugin) GetMessages(ctx context.Context, namespace string, filter database.Filter) ([]*core.Message, *database.FilterResult, error)
- func (_m *Plugin) GetMessagesForData(ctx context.Context, namespace string, dataID *fftypes.UUID, ...) ([]*core.Message, *database.FilterResult, error)
- func (_m *Plugin) GetNamespace(ctx context.Context, name string) (*core.Namespace, error)
- func (_m *Plugin) GetNextPinsForContext(ctx context.Context, namespace string, _a2 *fftypes.Bytes32) ([]*core.NextPin, error)
- func (_m *Plugin) GetNonce(ctx context.Context, hash *fftypes.Bytes32) (*core.Nonce, error)
- func (_m *Plugin) GetNonces(ctx context.Context, filter database.Filter) ([]*core.Nonce, *database.FilterResult, error)
- func (_m *Plugin) GetOffset(ctx context.Context, t fftypes.FFEnum, name string) (*core.Offset, error)
- func (_m *Plugin) GetOffsets(ctx context.Context, filter database.Filter) ([]*core.Offset, *database.FilterResult, error)
- func (_m *Plugin) GetOperationByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Operation, error)
- func (_m *Plugin) GetOperations(ctx context.Context, namespace string, filter database.Filter) ([]*core.Operation, *database.FilterResult, error)
- func (_m *Plugin) GetPins(ctx context.Context, namespace string, filter database.Filter) ([]*core.Pin, *database.FilterResult, error)
- func (_m *Plugin) GetSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Subscription, error)
- func (_m *Plugin) GetSubscriptionByName(ctx context.Context, namespace string, name string) (*core.Subscription, error)
- func (_m *Plugin) GetSubscriptions(ctx context.Context, namespace string, filter database.Filter) ([]*core.Subscription, *database.FilterResult, error)
- func (_m *Plugin) GetTokenAccountPools(ctx context.Context, namespace string, key string, filter database.Filter) ([]*core.TokenAccountPool, *database.FilterResult, error)
- func (_m *Plugin) GetTokenAccounts(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenAccount, *database.FilterResult, error)
- func (_m *Plugin) GetTokenApprovalByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenApproval, error)
- func (_m *Plugin) GetTokenApprovalByProtocolID(ctx context.Context, namespace string, connector string, protocolID string) (*core.TokenApproval, error)
- func (_m *Plugin) GetTokenApprovals(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenApproval, *database.FilterResult, error)
- func (_m *Plugin) GetTokenBalance(ctx context.Context, namespace string, poolID *fftypes.UUID, tokenIndex string, ...) (*core.TokenBalance, error)
- func (_m *Plugin) GetTokenBalances(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenBalance, *database.FilterResult, error)
- func (_m *Plugin) GetTokenPool(ctx context.Context, namespace string, name string) (*core.TokenPool, error)
- func (_m *Plugin) GetTokenPoolByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.TokenPool, error)
- func (_m *Plugin) GetTokenPoolByLocator(ctx context.Context, namespace string, connector string, locator string) (*core.TokenPool, error)
- func (_m *Plugin) GetTokenPools(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenPool, *database.FilterResult, error)
- func (_m *Plugin) GetTokenTransferByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenTransfer, error)
- func (_m *Plugin) GetTokenTransferByProtocolID(ctx context.Context, namespace string, connector string, protocolID string) (*core.TokenTransfer, error)
- func (_m *Plugin) GetTokenTransfers(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenTransfer, *database.FilterResult, error)
- func (_m *Plugin) GetTransactionByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Transaction, error)
- func (_m *Plugin) GetTransactions(ctx context.Context, namespace string, filter database.Filter) ([]*core.Transaction, *database.FilterResult, error)
- func (_m *Plugin) GetVerifierByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (*core.Verifier, error)
- func (_m *Plugin) GetVerifierByValue(ctx context.Context, vType fftypes.FFEnum, namespace string, value string) (*core.Verifier, error)
- func (_m *Plugin) GetVerifiers(ctx context.Context, namespace string, filter database.Filter) ([]*core.Verifier, *database.FilterResult, error)
- func (_m *Plugin) Init(ctx context.Context, _a1 config.Section) error
- func (_m *Plugin) InitConfig(_a0 config.Section)
- func (_m *Plugin) InsertBlob(ctx context.Context, blob *core.Blob) error
- func (_m *Plugin) InsertBlobs(ctx context.Context, blobs []*core.Blob) error
- func (_m *Plugin) InsertContractListener(ctx context.Context, sub *core.ContractListener) error
- func (_m *Plugin) InsertDataArray(ctx context.Context, data core.DataArray) error
- func (_m *Plugin) InsertEvent(ctx context.Context, data *core.Event) error
- func (_m *Plugin) InsertMessages(ctx context.Context, messages []*core.Message, ...) error
- func (_m *Plugin) InsertNextPin(ctx context.Context, nextpin *core.NextPin) error
- func (_m *Plugin) InsertNonce(ctx context.Context, nonce *core.Nonce) error
- func (_m *Plugin) InsertOperation(ctx context.Context, operation *core.Operation, ...) error
- func (_m *Plugin) InsertOrGetBlockchainEvent(ctx context.Context, event *core.BlockchainEvent) (*core.BlockchainEvent, error)
- func (_m *Plugin) InsertPins(ctx context.Context, pins []*core.Pin) error
- func (_m *Plugin) InsertTransaction(ctx context.Context, data *core.Transaction) error
- func (_m *Plugin) Name() string
- func (_m *Plugin) ReplaceMessage(ctx context.Context, message *core.Message) error
- func (_m *Plugin) RunAsGroup(ctx context.Context, fn func(context.Context) error) error
- func (_m *Plugin) SetHandler(namespace string, handler database.Callbacks)
- func (_m *Plugin) UpdateBatch(ctx context.Context, namespace string, id *fftypes.UUID, ...) error
- func (_m *Plugin) UpdateData(ctx context.Context, namespace string, id *fftypes.UUID, ...) error
- func (_m *Plugin) UpdateMessage(ctx context.Context, namespace string, id *fftypes.UUID, ...) error
- func (_m *Plugin) UpdateMessages(ctx context.Context, namespace string, filter database.Filter, ...) error
- func (_m *Plugin) UpdateNextPin(ctx context.Context, namespace string, sequence int64, update database.Update) error
- func (_m *Plugin) UpdateNonce(ctx context.Context, nonce *core.Nonce) error
- func (_m *Plugin) UpdateOffset(ctx context.Context, rowID int64, update database.Update) error
- func (_m *Plugin) UpdateOperation(ctx context.Context, namespace string, id *fftypes.UUID, ...) error
- func (_m *Plugin) UpdatePins(ctx context.Context, namespace string, filter database.Filter, ...) error
- func (_m *Plugin) UpdateSubscription(ctx context.Context, namespace string, name string, update database.Update) error
- func (_m *Plugin) UpdateTokenApprovals(ctx context.Context, filter database.Filter, update database.Update) error
- func (_m *Plugin) UpdateTokenBalances(ctx context.Context, transfer *core.TokenTransfer) error
- func (_m *Plugin) UpdateTransaction(ctx context.Context, namespace string, id *fftypes.UUID, ...) error
- func (_m *Plugin) UpsertBatch(ctx context.Context, data *core.BatchPersisted) error
- func (_m *Plugin) UpsertContractAPI(ctx context.Context, cd *core.ContractAPI) error
- func (_m *Plugin) UpsertData(ctx context.Context, data *core.Data, optimization database.UpsertOptimization) error
- func (_m *Plugin) UpsertDatatype(ctx context.Context, datadef *core.Datatype, allowExisting bool) error
- func (_m *Plugin) UpsertFFI(ctx context.Context, cd *fftypes.FFI) error
- func (_m *Plugin) UpsertFFIEvent(ctx context.Context, method *fftypes.FFIEvent) error
- func (_m *Plugin) UpsertFFIMethod(ctx context.Context, method *fftypes.FFIMethod) error
- func (_m *Plugin) UpsertGroup(ctx context.Context, data *core.Group, ...) error
- func (_m *Plugin) UpsertIdentity(ctx context.Context, data *core.Identity, ...) error
- func (_m *Plugin) UpsertMessage(ctx context.Context, message *core.Message, ...) error
- func (_m *Plugin) UpsertNamespace(ctx context.Context, data *core.Namespace, allowExisting bool) error
- func (_m *Plugin) UpsertOffset(ctx context.Context, data *core.Offset, allowExisting bool) error
- func (_m *Plugin) UpsertPin(ctx context.Context, parked *core.Pin) error
- func (_m *Plugin) UpsertSubscription(ctx context.Context, data *core.Subscription, allowExisting bool) error
- func (_m *Plugin) UpsertTokenApproval(ctx context.Context, approval *core.TokenApproval) error
- func (_m *Plugin) UpsertTokenPool(ctx context.Context, pool *core.TokenPool) error
- func (_m *Plugin) UpsertTokenTransfer(ctx context.Context, transfer *core.TokenTransfer) error
- func (_m *Plugin) UpsertVerifier(ctx context.Context, data *core.Verifier, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
Callbacks is an autogenerated mock type for the Callbacks type
func NewCallbacks ¶ added in v1.1.2
func NewCallbacks(t mockConstructorTestingTNewCallbacks) *Callbacks
NewCallbacks creates a new instance of Callbacks. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Callbacks) HashCollectionNSEvent ¶
func (_m *Callbacks) HashCollectionNSEvent(resType database.HashCollectionNS, eventType core.ChangeEventType, namespace string, hash *fftypes.Bytes32)
HashCollectionNSEvent provides a mock function with given fields: resType, eventType, namespace, hash
func (*Callbacks) OrderedCollectionNSEvent ¶ added in v1.1.0
func (_m *Callbacks) OrderedCollectionNSEvent(resType database.OrderedCollectionNS, eventType core.ChangeEventType, namespace string, sequence int64)
OrderedCollectionNSEvent provides a mock function with given fields: resType, eventType, namespace, sequence
func (*Callbacks) OrderedUUIDCollectionNSEvent ¶
func (_m *Callbacks) OrderedUUIDCollectionNSEvent(resType database.OrderedUUIDCollectionNS, eventType core.ChangeEventType, namespace string, id *fftypes.UUID, sequence int64)
OrderedUUIDCollectionNSEvent provides a mock function with given fields: resType, eventType, namespace, id, sequence
func (*Callbacks) UUIDCollectionNSEvent ¶
func (_m *Callbacks) UUIDCollectionNSEvent(resType database.UUIDCollectionNS, eventType core.ChangeEventType, namespace string, id *fftypes.UUID)
UUIDCollectionNSEvent provides a mock function with given fields: resType, eventType, namespace, id
type Plugin ¶
Plugin is an autogenerated mock type for the Plugin type
func NewPlugin ¶ added in v1.1.2
func NewPlugin(t mockConstructorTestingTNewPlugin) *Plugin
NewPlugin creates a new instance of Plugin. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Plugin) Capabilities ¶
func (_m *Plugin) Capabilities() *database.Capabilities
Capabilities provides a mock function with given fields:
func (*Plugin) DeleteBlob ¶
DeleteBlob provides a mock function with given fields: ctx, sequence
func (*Plugin) DeleteContractListenerByID ¶ added in v0.14.0
func (_m *Plugin) DeleteContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) error
DeleteContractListenerByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) DeleteNonce ¶
DeleteNonce provides a mock function with given fields: ctx, hash
func (*Plugin) DeleteOffset ¶
DeleteOffset provides a mock function with given fields: ctx, t, name
func (*Plugin) DeleteSubscriptionByID ¶
func (_m *Plugin) DeleteSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) error
DeleteSubscriptionByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetBatchByID ¶
func (_m *Plugin) GetBatchByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.BatchPersisted, error)
GetBatchByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetBatchIDsForDataAttachments ¶ added in v1.0.0
func (_m *Plugin) GetBatchIDsForDataAttachments(ctx context.Context, namespace string, dataIDs []*fftypes.UUID) ([]*fftypes.UUID, error)
GetBatchIDsForDataAttachments provides a mock function with given fields: ctx, namespace, dataIDs
func (*Plugin) GetBatchIDsForMessages ¶ added in v1.0.0
func (_m *Plugin) GetBatchIDsForMessages(ctx context.Context, namespace string, msgIDs []*fftypes.UUID) ([]*fftypes.UUID, error)
GetBatchIDsForMessages provides a mock function with given fields: ctx, namespace, msgIDs
func (*Plugin) GetBatches ¶
func (_m *Plugin) GetBatches(ctx context.Context, namespace string, filter database.Filter) ([]*core.BatchPersisted, *database.FilterResult, error)
GetBatches provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetBlobMatchingHash ¶
func (_m *Plugin) GetBlobMatchingHash(ctx context.Context, hash *fftypes.Bytes32) (*core.Blob, error)
GetBlobMatchingHash provides a mock function with given fields: ctx, hash
func (*Plugin) GetBlobs ¶
func (_m *Plugin) GetBlobs(ctx context.Context, filter database.Filter) ([]*core.Blob, *database.FilterResult, error)
GetBlobs provides a mock function with given fields: ctx, filter
func (*Plugin) GetBlockchainEventByID ¶ added in v0.12.0
func (_m *Plugin) GetBlockchainEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.BlockchainEvent, error)
GetBlockchainEventByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetBlockchainEventByProtocolID ¶ added in v1.0.0
func (_m *Plugin) GetBlockchainEventByProtocolID(ctx context.Context, namespace string, listener *fftypes.UUID, protocolID string) (*core.BlockchainEvent, error)
GetBlockchainEventByProtocolID provides a mock function with given fields: ctx, namespace, listener, protocolID
func (*Plugin) GetBlockchainEvents ¶ added in v0.12.0
func (_m *Plugin) GetBlockchainEvents(ctx context.Context, namespace string, filter database.Filter) ([]*core.BlockchainEvent, *database.FilterResult, error)
GetBlockchainEvents provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetChartHistogram ¶ added in v0.11.2
func (_m *Plugin) GetChartHistogram(ctx context.Context, namespace string, intervals []core.ChartHistogramInterval, collection database.CollectionName) ([]*core.ChartHistogram, error)
GetChartHistogram provides a mock function with given fields: ctx, namespace, intervals, collection
func (*Plugin) GetContractAPIByID ¶ added in v0.12.0
func (_m *Plugin) GetContractAPIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.ContractAPI, error)
GetContractAPIByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetContractAPIByName ¶ added in v0.12.0
func (_m *Plugin) GetContractAPIByName(ctx context.Context, namespace string, name string) (*core.ContractAPI, error)
GetContractAPIByName provides a mock function with given fields: ctx, namespace, name
func (*Plugin) GetContractAPIs ¶ added in v0.12.0
func (_m *Plugin) GetContractAPIs(ctx context.Context, namespace string, filter database.AndFilter) ([]*core.ContractAPI, *database.FilterResult, error)
GetContractAPIs provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetContractListener ¶ added in v0.14.0
func (_m *Plugin) GetContractListener(ctx context.Context, namespace string, name string) (*core.ContractListener, error)
GetContractListener provides a mock function with given fields: ctx, namespace, name
func (*Plugin) GetContractListenerByBackendID ¶ added in v1.0.0
func (_m *Plugin) GetContractListenerByBackendID(ctx context.Context, namespace string, id string) (*core.ContractListener, error)
GetContractListenerByBackendID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetContractListenerByID ¶ added in v0.14.0
func (_m *Plugin) GetContractListenerByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.ContractListener, error)
GetContractListenerByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetContractListeners ¶ added in v0.14.0
func (_m *Plugin) GetContractListeners(ctx context.Context, namespace string, filter database.Filter) ([]*core.ContractListener, *database.FilterResult, error)
GetContractListeners provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetData ¶
func (_m *Plugin) GetData(ctx context.Context, namespace string, filter database.Filter) (core.DataArray, *database.FilterResult, error)
GetData provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetDataByID ¶
func (_m *Plugin) GetDataByID(ctx context.Context, namespace string, id *fftypes.UUID, withValue bool) (*core.Data, error)
GetDataByID provides a mock function with given fields: ctx, namespace, id, withValue
func (*Plugin) GetDataRefs ¶
func (_m *Plugin) GetDataRefs(ctx context.Context, namespace string, filter database.Filter) (core.DataRefs, *database.FilterResult, error)
GetDataRefs provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetDatatypeByID ¶
func (_m *Plugin) GetDatatypeByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Datatype, error)
GetDatatypeByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetDatatypeByName ¶
func (_m *Plugin) GetDatatypeByName(ctx context.Context, namespace string, name string, version string) (*core.Datatype, error)
GetDatatypeByName provides a mock function with given fields: ctx, namespace, name, version
func (*Plugin) GetDatatypes ¶
func (_m *Plugin) GetDatatypes(ctx context.Context, namespace string, filter database.Filter) ([]*core.Datatype, *database.FilterResult, error)
GetDatatypes provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetEventByID ¶
func (_m *Plugin) GetEventByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Event, error)
GetEventByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetEvents ¶
func (_m *Plugin) GetEvents(ctx context.Context, namespace string, filter database.Filter) ([]*core.Event, *database.FilterResult, error)
GetEvents provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetFFI ¶ added in v0.12.0
func (_m *Plugin) GetFFI(ctx context.Context, namespace string, name string, version string) (*fftypes.FFI, error)
GetFFI provides a mock function with given fields: ctx, namespace, name, version
func (*Plugin) GetFFIByID ¶ added in v0.12.0
func (_m *Plugin) GetFFIByID(ctx context.Context, namespace string, id *fftypes.UUID) (*fftypes.FFI, error)
GetFFIByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetFFIEvent ¶ added in v0.12.0
func (_m *Plugin) GetFFIEvent(ctx context.Context, namespace string, interfaceID *fftypes.UUID, pathName string) (*fftypes.FFIEvent, error)
GetFFIEvent provides a mock function with given fields: ctx, namespace, interfaceID, pathName
func (*Plugin) GetFFIEvents ¶ added in v0.12.0
func (_m *Plugin) GetFFIEvents(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFIEvent, *database.FilterResult, error)
GetFFIEvents provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetFFIMethod ¶ added in v0.12.0
func (_m *Plugin) GetFFIMethod(ctx context.Context, namespace string, interfaceID *fftypes.UUID, pathName string) (*fftypes.FFIMethod, error)
GetFFIMethod provides a mock function with given fields: ctx, namespace, interfaceID, pathName
func (*Plugin) GetFFIMethods ¶ added in v0.12.0
func (_m *Plugin) GetFFIMethods(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFIMethod, *database.FilterResult, error)
GetFFIMethods provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetFFIs ¶ added in v0.12.0
func (_m *Plugin) GetFFIs(ctx context.Context, namespace string, filter database.Filter) ([]*fftypes.FFI, *database.FilterResult, error)
GetFFIs provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetGroupByHash ¶
func (_m *Plugin) GetGroupByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (*core.Group, error)
GetGroupByHash provides a mock function with given fields: ctx, namespace, hash
func (*Plugin) GetGroups ¶
func (_m *Plugin) GetGroups(ctx context.Context, namespace string, filter database.Filter) ([]*core.Group, *database.FilterResult, error)
GetGroups provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetIdentities ¶ added in v0.14.0
func (_m *Plugin) GetIdentities(ctx context.Context, namespace string, filter database.Filter) ([]*core.Identity, *database.FilterResult, error)
GetIdentities provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetIdentityByDID ¶ added in v0.14.0
func (_m *Plugin) GetIdentityByDID(ctx context.Context, namespace string, did string) (*core.Identity, error)
GetIdentityByDID provides a mock function with given fields: ctx, namespace, did
func (*Plugin) GetIdentityByID ¶ added in v0.14.0
func (_m *Plugin) GetIdentityByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Identity, error)
GetIdentityByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetIdentityByName ¶ added in v0.14.0
func (_m *Plugin) GetIdentityByName(ctx context.Context, iType fftypes.FFEnum, namespace string, name string) (*core.Identity, error)
GetIdentityByName provides a mock function with given fields: ctx, iType, namespace, name
func (*Plugin) GetMessageByID ¶
func (_m *Plugin) GetMessageByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Message, error)
GetMessageByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetMessageIDs ¶ added in v0.14.0
func (_m *Plugin) GetMessageIDs(ctx context.Context, namespace string, filter database.Filter) ([]*core.IDAndSequence, error)
GetMessageIDs provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetMessages ¶
func (_m *Plugin) GetMessages(ctx context.Context, namespace string, filter database.Filter) ([]*core.Message, *database.FilterResult, error)
GetMessages provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetMessagesForData ¶
func (_m *Plugin) GetMessagesForData(ctx context.Context, namespace string, dataID *fftypes.UUID, filter database.Filter) ([]*core.Message, *database.FilterResult, error)
GetMessagesForData provides a mock function with given fields: ctx, namespace, dataID, filter
func (*Plugin) GetNamespace ¶
GetNamespace provides a mock function with given fields: ctx, name
func (*Plugin) GetNextPinsForContext ¶ added in v1.1.0
func (_m *Plugin) GetNextPinsForContext(ctx context.Context, namespace string, _a2 *fftypes.Bytes32) ([]*core.NextPin, error)
GetNextPinsForContext provides a mock function with given fields: ctx, namespace, _a2
func (*Plugin) GetNonces ¶
func (_m *Plugin) GetNonces(ctx context.Context, filter database.Filter) ([]*core.Nonce, *database.FilterResult, error)
GetNonces provides a mock function with given fields: ctx, filter
func (*Plugin) GetOffset ¶
func (_m *Plugin) GetOffset(ctx context.Context, t fftypes.FFEnum, name string) (*core.Offset, error)
GetOffset provides a mock function with given fields: ctx, t, name
func (*Plugin) GetOffsets ¶
func (_m *Plugin) GetOffsets(ctx context.Context, filter database.Filter) ([]*core.Offset, *database.FilterResult, error)
GetOffsets provides a mock function with given fields: ctx, filter
func (*Plugin) GetOperationByID ¶
func (_m *Plugin) GetOperationByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Operation, error)
GetOperationByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetOperations ¶
func (_m *Plugin) GetOperations(ctx context.Context, namespace string, filter database.Filter) ([]*core.Operation, *database.FilterResult, error)
GetOperations provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetPins ¶
func (_m *Plugin) GetPins(ctx context.Context, namespace string, filter database.Filter) ([]*core.Pin, *database.FilterResult, error)
GetPins provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetSubscriptionByID ¶
func (_m *Plugin) GetSubscriptionByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Subscription, error)
GetSubscriptionByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetSubscriptionByName ¶
func (_m *Plugin) GetSubscriptionByName(ctx context.Context, namespace string, name string) (*core.Subscription, error)
GetSubscriptionByName provides a mock function with given fields: ctx, namespace, name
func (*Plugin) GetSubscriptions ¶
func (_m *Plugin) GetSubscriptions(ctx context.Context, namespace string, filter database.Filter) ([]*core.Subscription, *database.FilterResult, error)
GetSubscriptions provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTokenAccountPools ¶ added in v0.11.0
func (_m *Plugin) GetTokenAccountPools(ctx context.Context, namespace string, key string, filter database.Filter) ([]*core.TokenAccountPool, *database.FilterResult, error)
GetTokenAccountPools provides a mock function with given fields: ctx, namespace, key, filter
func (*Plugin) GetTokenAccounts ¶
func (_m *Plugin) GetTokenAccounts(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenAccount, *database.FilterResult, error)
GetTokenAccounts provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTokenApprovalByID ¶ added in v1.0.0
func (_m *Plugin) GetTokenApprovalByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenApproval, error)
GetTokenApprovalByID provides a mock function with given fields: ctx, namespace, localID
func (*Plugin) GetTokenApprovalByProtocolID ¶ added in v0.13.1
func (_m *Plugin) GetTokenApprovalByProtocolID(ctx context.Context, namespace string, connector string, protocolID string) (*core.TokenApproval, error)
GetTokenApprovalByProtocolID provides a mock function with given fields: ctx, namespace, connector, protocolID
func (*Plugin) GetTokenApprovals ¶ added in v0.13.1
func (_m *Plugin) GetTokenApprovals(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenApproval, *database.FilterResult, error)
GetTokenApprovals provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTokenBalance ¶ added in v0.11.0
func (_m *Plugin) GetTokenBalance(ctx context.Context, namespace string, poolID *fftypes.UUID, tokenIndex string, identity string) (*core.TokenBalance, error)
GetTokenBalance provides a mock function with given fields: ctx, namespace, poolID, tokenIndex, identity
func (*Plugin) GetTokenBalances ¶ added in v0.11.0
func (_m *Plugin) GetTokenBalances(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenBalance, *database.FilterResult, error)
GetTokenBalances provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTokenPool ¶
func (_m *Plugin) GetTokenPool(ctx context.Context, namespace string, name string) (*core.TokenPool, error)
GetTokenPool provides a mock function with given fields: ctx, namespace, name
func (*Plugin) GetTokenPoolByID ¶
func (_m *Plugin) GetTokenPoolByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.TokenPool, error)
GetTokenPoolByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetTokenPoolByLocator ¶ added in v1.0.0
func (_m *Plugin) GetTokenPoolByLocator(ctx context.Context, namespace string, connector string, locator string) (*core.TokenPool, error)
GetTokenPoolByLocator provides a mock function with given fields: ctx, namespace, connector, locator
func (*Plugin) GetTokenPools ¶
func (_m *Plugin) GetTokenPools(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenPool, *database.FilterResult, error)
GetTokenPools provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTokenTransferByID ¶ added in v1.0.0
func (_m *Plugin) GetTokenTransferByID(ctx context.Context, namespace string, localID *fftypes.UUID) (*core.TokenTransfer, error)
GetTokenTransferByID provides a mock function with given fields: ctx, namespace, localID
func (*Plugin) GetTokenTransferByProtocolID ¶ added in v0.11.0
func (_m *Plugin) GetTokenTransferByProtocolID(ctx context.Context, namespace string, connector string, protocolID string) (*core.TokenTransfer, error)
GetTokenTransferByProtocolID provides a mock function with given fields: ctx, namespace, connector, protocolID
func (*Plugin) GetTokenTransfers ¶
func (_m *Plugin) GetTokenTransfers(ctx context.Context, namespace string, filter database.Filter) ([]*core.TokenTransfer, *database.FilterResult, error)
GetTokenTransfers provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetTransactionByID ¶
func (_m *Plugin) GetTransactionByID(ctx context.Context, namespace string, id *fftypes.UUID) (*core.Transaction, error)
GetTransactionByID provides a mock function with given fields: ctx, namespace, id
func (*Plugin) GetTransactions ¶
func (_m *Plugin) GetTransactions(ctx context.Context, namespace string, filter database.Filter) ([]*core.Transaction, *database.FilterResult, error)
GetTransactions provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) GetVerifierByHash ¶ added in v0.14.0
func (_m *Plugin) GetVerifierByHash(ctx context.Context, namespace string, hash *fftypes.Bytes32) (*core.Verifier, error)
GetVerifierByHash provides a mock function with given fields: ctx, namespace, hash
func (*Plugin) GetVerifierByValue ¶ added in v0.14.0
func (_m *Plugin) GetVerifierByValue(ctx context.Context, vType fftypes.FFEnum, namespace string, value string) (*core.Verifier, error)
GetVerifierByValue provides a mock function with given fields: ctx, vType, namespace, value
func (*Plugin) GetVerifiers ¶ added in v0.14.0
func (_m *Plugin) GetVerifiers(ctx context.Context, namespace string, filter database.Filter) ([]*core.Verifier, *database.FilterResult, error)
GetVerifiers provides a mock function with given fields: ctx, namespace, filter
func (*Plugin) InitConfig ¶ added in v1.1.0
InitConfig provides a mock function with given fields: _a0
func (*Plugin) InsertBlob ¶
InsertBlob provides a mock function with given fields: ctx, blob
func (*Plugin) InsertBlobs ¶ added in v1.0.0
InsertBlobs provides a mock function with given fields: ctx, blobs
func (*Plugin) InsertContractListener ¶ added in v1.1.0
InsertContractListener provides a mock function with given fields: ctx, sub
func (*Plugin) InsertDataArray ¶ added in v0.14.0
InsertDataArray provides a mock function with given fields: ctx, data
func (*Plugin) InsertEvent ¶
InsertEvent provides a mock function with given fields: ctx, data
func (*Plugin) InsertMessages ¶ added in v0.14.0
func (_m *Plugin) InsertMessages(ctx context.Context, messages []*core.Message, hooks ...database.PostCompletionHook) error
InsertMessages provides a mock function with given fields: ctx, messages, hooks
func (*Plugin) InsertNextPin ¶
InsertNextPin provides a mock function with given fields: ctx, nextpin
func (*Plugin) InsertNonce ¶ added in v1.0.0
InsertNonce provides a mock function with given fields: ctx, nonce
func (*Plugin) InsertOperation ¶ added in v0.11.2
func (_m *Plugin) InsertOperation(ctx context.Context, operation *core.Operation, hooks ...database.PostCompletionHook) error
InsertOperation provides a mock function with given fields: ctx, operation, hooks
func (*Plugin) InsertOrGetBlockchainEvent ¶ added in v1.1.0
func (_m *Plugin) InsertOrGetBlockchainEvent(ctx context.Context, event *core.BlockchainEvent) (*core.BlockchainEvent, error)
InsertOrGetBlockchainEvent provides a mock function with given fields: ctx, event
func (*Plugin) InsertPins ¶ added in v0.14.0
InsertPins provides a mock function with given fields: ctx, pins
func (*Plugin) InsertTransaction ¶ added in v0.12.0
InsertTransaction provides a mock function with given fields: ctx, data
func (*Plugin) ReplaceMessage ¶ added in v0.11.5
ReplaceMessage provides a mock function with given fields: ctx, message
func (*Plugin) RunAsGroup ¶
RunAsGroup provides a mock function with given fields: ctx, fn
func (*Plugin) SetHandler ¶ added in v1.1.0
SetHandler provides a mock function with given fields: namespace, handler
func (*Plugin) UpdateBatch ¶
func (_m *Plugin) UpdateBatch(ctx context.Context, namespace string, id *fftypes.UUID, update database.Update) error
UpdateBatch provides a mock function with given fields: ctx, namespace, id, update
func (*Plugin) UpdateData ¶
func (_m *Plugin) UpdateData(ctx context.Context, namespace string, id *fftypes.UUID, update database.Update) error
UpdateData provides a mock function with given fields: ctx, namespace, id, update
func (*Plugin) UpdateMessage ¶
func (_m *Plugin) UpdateMessage(ctx context.Context, namespace string, id *fftypes.UUID, update database.Update) error
UpdateMessage provides a mock function with given fields: ctx, namespace, id, update
func (*Plugin) UpdateMessages ¶
func (_m *Plugin) UpdateMessages(ctx context.Context, namespace string, filter database.Filter, update database.Update) error
UpdateMessages provides a mock function with given fields: ctx, namespace, filter, update
func (*Plugin) UpdateNextPin ¶
func (_m *Plugin) UpdateNextPin(ctx context.Context, namespace string, sequence int64, update database.Update) error
UpdateNextPin provides a mock function with given fields: ctx, namespace, sequence, update
func (*Plugin) UpdateNonce ¶ added in v1.0.0
UpdateNonce provides a mock function with given fields: ctx, nonce
func (*Plugin) UpdateOffset ¶
UpdateOffset provides a mock function with given fields: ctx, rowID, update
func (*Plugin) UpdateOperation ¶
func (_m *Plugin) UpdateOperation(ctx context.Context, namespace string, id *fftypes.UUID, update database.Update) error
UpdateOperation provides a mock function with given fields: ctx, namespace, id, update
func (*Plugin) UpdatePins ¶ added in v0.13.0
func (_m *Plugin) UpdatePins(ctx context.Context, namespace string, filter database.Filter, update database.Update) error
UpdatePins provides a mock function with given fields: ctx, namespace, filter, update
func (*Plugin) UpdateSubscription ¶
func (_m *Plugin) UpdateSubscription(ctx context.Context, namespace string, name string, update database.Update) error
UpdateSubscription provides a mock function with given fields: ctx, namespace, name, update
func (*Plugin) UpdateTokenApprovals ¶ added in v1.0.0
func (_m *Plugin) UpdateTokenApprovals(ctx context.Context, filter database.Filter, update database.Update) error
UpdateTokenApprovals provides a mock function with given fields: ctx, filter, update
func (*Plugin) UpdateTokenBalances ¶ added in v0.11.0
UpdateTokenBalances provides a mock function with given fields: ctx, transfer
func (*Plugin) UpdateTransaction ¶
func (_m *Plugin) UpdateTransaction(ctx context.Context, namespace string, id *fftypes.UUID, update database.Update) error
UpdateTransaction provides a mock function with given fields: ctx, namespace, id, update
func (*Plugin) UpsertBatch ¶
UpsertBatch provides a mock function with given fields: ctx, data
func (*Plugin) UpsertContractAPI ¶ added in v0.12.0
UpsertContractAPI provides a mock function with given fields: ctx, cd
func (*Plugin) UpsertData ¶
func (_m *Plugin) UpsertData(ctx context.Context, data *core.Data, optimization database.UpsertOptimization) error
UpsertData provides a mock function with given fields: ctx, data, optimization
func (*Plugin) UpsertDatatype ¶
func (_m *Plugin) UpsertDatatype(ctx context.Context, datadef *core.Datatype, allowExisting bool) error
UpsertDatatype provides a mock function with given fields: ctx, datadef, allowExisting
func (*Plugin) UpsertFFI ¶ added in v0.12.0
UpsertFFI provides a mock function with given fields: ctx, cd
func (*Plugin) UpsertFFIEvent ¶ added in v0.12.0
UpsertFFIEvent provides a mock function with given fields: ctx, method
func (*Plugin) UpsertFFIMethod ¶ added in v0.12.0
UpsertFFIMethod provides a mock function with given fields: ctx, method
func (*Plugin) UpsertGroup ¶
func (_m *Plugin) UpsertGroup(ctx context.Context, data *core.Group, optimization database.UpsertOptimization) error
UpsertGroup provides a mock function with given fields: ctx, data, optimization
func (*Plugin) UpsertIdentity ¶ added in v0.14.0
func (_m *Plugin) UpsertIdentity(ctx context.Context, data *core.Identity, optimization database.UpsertOptimization) error
UpsertIdentity provides a mock function with given fields: ctx, data, optimization
func (*Plugin) UpsertMessage ¶
func (_m *Plugin) UpsertMessage(ctx context.Context, message *core.Message, optimization database.UpsertOptimization, hooks ...database.PostCompletionHook) error
UpsertMessage provides a mock function with given fields: ctx, message, optimization, hooks
func (*Plugin) UpsertNamespace ¶
func (_m *Plugin) UpsertNamespace(ctx context.Context, data *core.Namespace, allowExisting bool) error
UpsertNamespace provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertOffset ¶
UpsertOffset provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertSubscription ¶
func (_m *Plugin) UpsertSubscription(ctx context.Context, data *core.Subscription, allowExisting bool) error
UpsertSubscription provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertTokenApproval ¶ added in v0.13.1
UpsertTokenApproval provides a mock function with given fields: ctx, approval
func (*Plugin) UpsertTokenPool ¶
UpsertTokenPool provides a mock function with given fields: ctx, pool
func (*Plugin) UpsertTokenTransfer ¶
UpsertTokenTransfer provides a mock function with given fields: ctx, transfer
func (*Plugin) UpsertVerifier ¶ added in v0.14.0
func (_m *Plugin) UpsertVerifier(ctx context.Context, data *core.Verifier, optimization database.UpsertOptimization) error
UpsertVerifier provides a mock function with given fields: ctx, data, optimization