Documentation ¶
Index ¶
- type Callbacks
- func (_m *Callbacks) HashCollectionNSEvent(resType database.HashCollectionNS, eventType fftypes.ChangeEventType, ...)
- func (_m *Callbacks) OrderedCollectionEvent(resType database.OrderedCollection, eventType fftypes.ChangeEventType, ...)
- func (_m *Callbacks) OrderedUUIDCollectionNSEvent(resType database.OrderedUUIDCollectionNS, eventType fftypes.ChangeEventType, ...)
- func (_m *Callbacks) UUIDCollectionEvent(resType database.UUIDCollection, eventType fftypes.ChangeEventType, ...)
- func (_m *Callbacks) UUIDCollectionNSEvent(resType database.UUIDCollectionNS, eventType fftypes.ChangeEventType, ...)
- type Plugin
- func (_m *Plugin) Capabilities() *database.Capabilities
- func (_m *Plugin) DeleteBlob(ctx context.Context, sequence int64) error
- func (_m *Plugin) DeleteConfigRecord(ctx context.Context, key string) error
- func (_m *Plugin) DeleteNamespace(ctx context.Context, id *fftypes.UUID) error
- func (_m *Plugin) DeleteNextPin(ctx context.Context, sequence int64) 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) DeletePin(ctx context.Context, sequence int64) error
- func (_m *Plugin) DeleteSubscriptionByID(ctx context.Context, id *fftypes.UUID) error
- func (_m *Plugin) GetBatchByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Batch, error)
- func (_m *Plugin) GetBatches(ctx context.Context, filter database.Filter) ([]*fftypes.Batch, *database.FilterResult, error)
- func (_m *Plugin) GetBlobMatchingHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.Blob, error)
- func (_m *Plugin) GetBlobs(ctx context.Context, filter database.Filter) ([]*fftypes.Blob, *database.FilterResult, error)
- func (_m *Plugin) GetChartHistogram(ctx context.Context, ns string, intervals []fftypes.ChartHistogramInterval, ...) ([]*fftypes.ChartHistogram, error)
- func (_m *Plugin) GetConfigRecord(ctx context.Context, key string) (*fftypes.ConfigRecord, error)
- func (_m *Plugin) GetConfigRecords(ctx context.Context, filter database.Filter) ([]*fftypes.ConfigRecord, *database.FilterResult, error)
- func (_m *Plugin) GetData(ctx context.Context, filter database.Filter) ([]*fftypes.Data, *database.FilterResult, error)
- func (_m *Plugin) GetDataByID(ctx context.Context, id *fftypes.UUID, withValue bool) (*fftypes.Data, error)
- func (_m *Plugin) GetDataRefs(ctx context.Context, filter database.Filter) (fftypes.DataRefs, *database.FilterResult, error)
- func (_m *Plugin) GetDatatypeByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Datatype, error)
- func (_m *Plugin) GetDatatypeByName(ctx context.Context, ns string, name string, version string) (*fftypes.Datatype, error)
- func (_m *Plugin) GetDatatypes(ctx context.Context, filter database.Filter) ([]*fftypes.Datatype, *database.FilterResult, error)
- func (_m *Plugin) GetEventByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Event, error)
- func (_m *Plugin) GetEvents(ctx context.Context, filter database.Filter) ([]*fftypes.Event, *database.FilterResult, error)
- func (_m *Plugin) GetGroupByHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.Group, error)
- func (_m *Plugin) GetGroups(ctx context.Context, filter database.Filter) ([]*fftypes.Group, *database.FilterResult, error)
- func (_m *Plugin) GetMessageByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Message, error)
- func (_m *Plugin) GetMessageRefs(ctx context.Context, filter database.Filter) ([]*fftypes.MessageRef, *database.FilterResult, error)
- func (_m *Plugin) GetMessages(ctx context.Context, filter database.Filter) ([]*fftypes.Message, *database.FilterResult, error)
- func (_m *Plugin) GetMessagesForData(ctx context.Context, dataID *fftypes.UUID, filter database.Filter) ([]*fftypes.Message, *database.FilterResult, error)
- func (_m *Plugin) GetNamespace(ctx context.Context, name string) (*fftypes.Namespace, error)
- func (_m *Plugin) GetNamespaces(ctx context.Context, filter database.Filter) ([]*fftypes.Namespace, *database.FilterResult, error)
- func (_m *Plugin) GetNextPinByContextAndIdentity(ctx context.Context, _a1 *fftypes.Bytes32, identity string) (*fftypes.NextPin, error)
- func (_m *Plugin) GetNextPinByHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.NextPin, error)
- func (_m *Plugin) GetNextPins(ctx context.Context, filter database.Filter) ([]*fftypes.NextPin, *database.FilterResult, error)
- func (_m *Plugin) GetNode(ctx context.Context, owner string, name string) (*fftypes.Node, error)
- func (_m *Plugin) GetNodeByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Node, error)
- func (_m *Plugin) GetNodes(ctx context.Context, filter database.Filter) ([]*fftypes.Node, *database.FilterResult, error)
- func (_m *Plugin) GetNonce(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.Nonce, error)
- func (_m *Plugin) GetNonces(ctx context.Context, filter database.Filter) ([]*fftypes.Nonce, *database.FilterResult, error)
- func (_m *Plugin) GetOffset(ctx context.Context, t fftypes.FFEnum, name string) (*fftypes.Offset, error)
- func (_m *Plugin) GetOffsets(ctx context.Context, filter database.Filter) ([]*fftypes.Offset, *database.FilterResult, error)
- func (_m *Plugin) GetOperationByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Operation, error)
- func (_m *Plugin) GetOperations(ctx context.Context, filter database.Filter) ([]*fftypes.Operation, *database.FilterResult, error)
- func (_m *Plugin) GetOrganizationByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Organization, error)
- func (_m *Plugin) GetOrganizationByIdentity(ctx context.Context, identity string) (*fftypes.Organization, error)
- func (_m *Plugin) GetOrganizationByName(ctx context.Context, name string) (*fftypes.Organization, error)
- func (_m *Plugin) GetOrganizations(ctx context.Context, filter database.Filter) ([]*fftypes.Organization, *database.FilterResult, error)
- func (_m *Plugin) GetPins(ctx context.Context, filter database.Filter) ([]*fftypes.Pin, *database.FilterResult, error)
- func (_m *Plugin) GetSubscriptionByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Subscription, error)
- func (_m *Plugin) GetSubscriptionByName(ctx context.Context, ns string, name string) (*fftypes.Subscription, error)
- func (_m *Plugin) GetSubscriptions(ctx context.Context, filter database.Filter) ([]*fftypes.Subscription, *database.FilterResult, error)
- func (_m *Plugin) GetTokenAccountPools(ctx context.Context, key string, filter database.Filter) ([]*fftypes.TokenAccountPool, *database.FilterResult, error)
- func (_m *Plugin) GetTokenAccounts(ctx context.Context, filter database.Filter) ([]*fftypes.TokenAccount, *database.FilterResult, error)
- func (_m *Plugin) GetTokenBalance(ctx context.Context, poolID *fftypes.UUID, tokenIndex string, identity string) (*fftypes.TokenBalance, error)
- func (_m *Plugin) GetTokenBalances(ctx context.Context, filter database.Filter) ([]*fftypes.TokenBalance, *database.FilterResult, error)
- func (_m *Plugin) GetTokenPool(ctx context.Context, ns string, name string) (*fftypes.TokenPool, error)
- func (_m *Plugin) GetTokenPoolByID(ctx context.Context, id *fftypes.UUID) (*fftypes.TokenPool, error)
- func (_m *Plugin) GetTokenPoolByProtocolID(ctx context.Context, connector string, protocolID string) (*fftypes.TokenPool, error)
- func (_m *Plugin) GetTokenPools(ctx context.Context, filter database.Filter) ([]*fftypes.TokenPool, *database.FilterResult, error)
- func (_m *Plugin) GetTokenTransfer(ctx context.Context, localID *fftypes.UUID) (*fftypes.TokenTransfer, error)
- func (_m *Plugin) GetTokenTransferByProtocolID(ctx context.Context, connector string, protocolID string) (*fftypes.TokenTransfer, error)
- func (_m *Plugin) GetTokenTransfers(ctx context.Context, filter database.Filter) ([]*fftypes.TokenTransfer, *database.FilterResult, error)
- func (_m *Plugin) GetTransactionByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Transaction, error)
- func (_m *Plugin) GetTransactions(ctx context.Context, filter database.Filter) ([]*fftypes.Transaction, *database.FilterResult, error)
- func (_m *Plugin) Init(ctx context.Context, prefix config.Prefix, callbacks database.Callbacks) error
- func (_m *Plugin) InitPrefix(prefix config.Prefix)
- func (_m *Plugin) InsertBlob(ctx context.Context, blob *fftypes.Blob) error
- func (_m *Plugin) InsertEvent(ctx context.Context, data *fftypes.Event) error
- func (_m *Plugin) InsertNextPin(ctx context.Context, nextpin *fftypes.NextPin) error
- func (_m *Plugin) InsertOperation(ctx context.Context, operation *fftypes.Operation) error
- func (_m *Plugin) Name() string
- func (_m *Plugin) RunAsGroup(ctx context.Context, fn func(context.Context) error) error
- func (_m *Plugin) SetPinDispatched(ctx context.Context, sequence int64) error
- func (_m *Plugin) UpdateBatch(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateData(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateDatatype(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateEvent(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateGroup(ctx context.Context, hash *fftypes.Bytes32, update database.Update) error
- func (_m *Plugin) UpdateMessage(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateMessages(ctx context.Context, filter database.Filter, update database.Update) error
- func (_m *Plugin) UpdateNextPin(ctx context.Context, sequence int64, update database.Update) error
- func (_m *Plugin) UpdateNode(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateOffset(ctx context.Context, rowID int64, update database.Update) error
- func (_m *Plugin) UpdateOperation(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateOrganization(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpdateSubscription(ctx context.Context, ns string, name string, update database.Update) error
- func (_m *Plugin) UpdateTokenBalances(ctx context.Context, transfer *fftypes.TokenTransfer) error
- func (_m *Plugin) UpdateTransaction(ctx context.Context, id *fftypes.UUID, update database.Update) error
- func (_m *Plugin) UpsertBatch(ctx context.Context, data *fftypes.Batch, allowHashUpdate bool) error
- func (_m *Plugin) UpsertConfigRecord(ctx context.Context, data *fftypes.ConfigRecord, allowExisting bool) error
- func (_m *Plugin) UpsertData(ctx context.Context, data *fftypes.Data, ...) error
- func (_m *Plugin) UpsertDatatype(ctx context.Context, datadef *fftypes.Datatype, allowExisting bool) error
- func (_m *Plugin) UpsertGroup(ctx context.Context, data *fftypes.Group, allowExisting bool) error
- func (_m *Plugin) UpsertMessage(ctx context.Context, message *fftypes.Message, ...) error
- func (_m *Plugin) UpsertNamespace(ctx context.Context, data *fftypes.Namespace, allowExisting bool) error
- func (_m *Plugin) UpsertNode(ctx context.Context, data *fftypes.Node, allowExisting bool) error
- func (_m *Plugin) UpsertNonceNext(ctx context.Context, _a1 *fftypes.Nonce) error
- func (_m *Plugin) UpsertOffset(ctx context.Context, data *fftypes.Offset, allowExisting bool) error
- func (_m *Plugin) UpsertOrganization(ctx context.Context, data *fftypes.Organization, allowExisting bool) error
- func (_m *Plugin) UpsertPin(ctx context.Context, parked *fftypes.Pin) error
- func (_m *Plugin) UpsertSubscription(ctx context.Context, data *fftypes.Subscription, allowExisting bool) error
- func (_m *Plugin) UpsertTokenPool(ctx context.Context, pool *fftypes.TokenPool) error
- func (_m *Plugin) UpsertTokenTransfer(ctx context.Context, transfer *fftypes.TokenTransfer) error
- func (_m *Plugin) UpsertTransaction(ctx context.Context, data *fftypes.Transaction, allowHashUpdate bool) 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 (*Callbacks) HashCollectionNSEvent ¶
func (_m *Callbacks) HashCollectionNSEvent(resType database.HashCollectionNS, eventType fftypes.ChangeEventType, ns string, hash *fftypes.Bytes32)
HashCollectionNSEvent provides a mock function with given fields: resType, eventType, ns, hash
func (*Callbacks) OrderedCollectionEvent ¶
func (_m *Callbacks) OrderedCollectionEvent(resType database.OrderedCollection, eventType fftypes.ChangeEventType, sequence int64)
OrderedCollectionEvent provides a mock function with given fields: resType, eventType, sequence
func (*Callbacks) OrderedUUIDCollectionNSEvent ¶
func (_m *Callbacks) OrderedUUIDCollectionNSEvent(resType database.OrderedUUIDCollectionNS, eventType fftypes.ChangeEventType, ns string, id *fftypes.UUID, sequence int64)
OrderedUUIDCollectionNSEvent provides a mock function with given fields: resType, eventType, ns, id, sequence
func (*Callbacks) UUIDCollectionEvent ¶
func (_m *Callbacks) UUIDCollectionEvent(resType database.UUIDCollection, eventType fftypes.ChangeEventType, id *fftypes.UUID)
UUIDCollectionEvent provides a mock function with given fields: resType, eventType, id
func (*Callbacks) UUIDCollectionNSEvent ¶
func (_m *Callbacks) UUIDCollectionNSEvent(resType database.UUIDCollectionNS, eventType fftypes.ChangeEventType, ns string, id *fftypes.UUID)
UUIDCollectionNSEvent provides a mock function with given fields: resType, eventType, ns, id
type Plugin ¶
Plugin is an autogenerated mock type for the Plugin type
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) DeleteConfigRecord ¶
DeleteConfigRecord provides a mock function with given fields: ctx, key
func (*Plugin) DeleteNamespace ¶
DeleteNamespace provides a mock function with given fields: ctx, id
func (*Plugin) DeleteNextPin ¶
DeleteNextPin provides a mock function with given fields: ctx, sequence
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 ¶
DeleteSubscriptionByID provides a mock function with given fields: ctx, id
func (*Plugin) GetBatchByID ¶
GetBatchByID provides a mock function with given fields: ctx, id
func (*Plugin) GetBatches ¶
func (_m *Plugin) GetBatches(ctx context.Context, filter database.Filter) ([]*fftypes.Batch, *database.FilterResult, error)
GetBatches provides a mock function with given fields: ctx, filter
func (*Plugin) GetBlobMatchingHash ¶
func (_m *Plugin) GetBlobMatchingHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.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) ([]*fftypes.Blob, *database.FilterResult, error)
GetBlobs provides a mock function with given fields: ctx, filter
func (*Plugin) GetChartHistogram ¶ added in v0.11.2
func (_m *Plugin) GetChartHistogram(ctx context.Context, ns string, intervals []fftypes.ChartHistogramInterval, collection database.CollectionName) ([]*fftypes.ChartHistogram, error)
GetChartHistogram provides a mock function with given fields: ctx, ns, intervals, collection
func (*Plugin) GetConfigRecord ¶
GetConfigRecord provides a mock function with given fields: ctx, key
func (*Plugin) GetConfigRecords ¶
func (_m *Plugin) GetConfigRecords(ctx context.Context, filter database.Filter) ([]*fftypes.ConfigRecord, *database.FilterResult, error)
GetConfigRecords provides a mock function with given fields: ctx, filter
func (*Plugin) GetData ¶
func (_m *Plugin) GetData(ctx context.Context, filter database.Filter) ([]*fftypes.Data, *database.FilterResult, error)
GetData provides a mock function with given fields: ctx, filter
func (*Plugin) GetDataByID ¶
func (_m *Plugin) GetDataByID(ctx context.Context, id *fftypes.UUID, withValue bool) (*fftypes.Data, error)
GetDataByID provides a mock function with given fields: ctx, id, withValue
func (*Plugin) GetDataRefs ¶
func (_m *Plugin) GetDataRefs(ctx context.Context, filter database.Filter) (fftypes.DataRefs, *database.FilterResult, error)
GetDataRefs provides a mock function with given fields: ctx, filter
func (*Plugin) GetDatatypeByID ¶
GetDatatypeByID provides a mock function with given fields: ctx, id
func (*Plugin) GetDatatypeByName ¶
func (_m *Plugin) GetDatatypeByName(ctx context.Context, ns string, name string, version string) (*fftypes.Datatype, error)
GetDatatypeByName provides a mock function with given fields: ctx, ns, name, version
func (*Plugin) GetDatatypes ¶
func (_m *Plugin) GetDatatypes(ctx context.Context, filter database.Filter) ([]*fftypes.Datatype, *database.FilterResult, error)
GetDatatypes provides a mock function with given fields: ctx, filter
func (*Plugin) GetEventByID ¶
GetEventByID provides a mock function with given fields: ctx, id
func (*Plugin) GetEvents ¶
func (_m *Plugin) GetEvents(ctx context.Context, filter database.Filter) ([]*fftypes.Event, *database.FilterResult, error)
GetEvents provides a mock function with given fields: ctx, filter
func (*Plugin) GetGroupByHash ¶
func (_m *Plugin) GetGroupByHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.Group, error)
GetGroupByHash provides a mock function with given fields: ctx, hash
func (*Plugin) GetGroups ¶
func (_m *Plugin) GetGroups(ctx context.Context, filter database.Filter) ([]*fftypes.Group, *database.FilterResult, error)
GetGroups provides a mock function with given fields: ctx, filter
func (*Plugin) GetMessageByID ¶
GetMessageByID provides a mock function with given fields: ctx, id
func (*Plugin) GetMessageRefs ¶
func (_m *Plugin) GetMessageRefs(ctx context.Context, filter database.Filter) ([]*fftypes.MessageRef, *database.FilterResult, error)
GetMessageRefs provides a mock function with given fields: ctx, filter
func (*Plugin) GetMessages ¶
func (_m *Plugin) GetMessages(ctx context.Context, filter database.Filter) ([]*fftypes.Message, *database.FilterResult, error)
GetMessages provides a mock function with given fields: ctx, filter
func (*Plugin) GetMessagesForData ¶
func (_m *Plugin) GetMessagesForData(ctx context.Context, dataID *fftypes.UUID, filter database.Filter) ([]*fftypes.Message, *database.FilterResult, error)
GetMessagesForData provides a mock function with given fields: ctx, dataID, filter
func (*Plugin) GetNamespace ¶
GetNamespace provides a mock function with given fields: ctx, name
func (*Plugin) GetNamespaces ¶
func (_m *Plugin) GetNamespaces(ctx context.Context, filter database.Filter) ([]*fftypes.Namespace, *database.FilterResult, error)
GetNamespaces provides a mock function with given fields: ctx, filter
func (*Plugin) GetNextPinByContextAndIdentity ¶
func (_m *Plugin) GetNextPinByContextAndIdentity(ctx context.Context, _a1 *fftypes.Bytes32, identity string) (*fftypes.NextPin, error)
GetNextPinByContextAndIdentity provides a mock function with given fields: ctx, _a1, identity
func (*Plugin) GetNextPinByHash ¶
func (_m *Plugin) GetNextPinByHash(ctx context.Context, hash *fftypes.Bytes32) (*fftypes.NextPin, error)
GetNextPinByHash provides a mock function with given fields: ctx, hash
func (*Plugin) GetNextPins ¶
func (_m *Plugin) GetNextPins(ctx context.Context, filter database.Filter) ([]*fftypes.NextPin, *database.FilterResult, error)
GetNextPins provides a mock function with given fields: ctx, filter
func (*Plugin) GetNodeByID ¶
GetNodeByID provides a mock function with given fields: ctx, id
func (*Plugin) GetNodes ¶
func (_m *Plugin) GetNodes(ctx context.Context, filter database.Filter) ([]*fftypes.Node, *database.FilterResult, error)
GetNodes provides a mock function with given fields: ctx, filter
func (*Plugin) GetNonces ¶
func (_m *Plugin) GetNonces(ctx context.Context, filter database.Filter) ([]*fftypes.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) (*fftypes.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) ([]*fftypes.Offset, *database.FilterResult, error)
GetOffsets provides a mock function with given fields: ctx, filter
func (*Plugin) GetOperationByID ¶
func (_m *Plugin) GetOperationByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Operation, error)
GetOperationByID provides a mock function with given fields: ctx, id
func (*Plugin) GetOperations ¶
func (_m *Plugin) GetOperations(ctx context.Context, filter database.Filter) ([]*fftypes.Operation, *database.FilterResult, error)
GetOperations provides a mock function with given fields: ctx, filter
func (*Plugin) GetOrganizationByID ¶
func (_m *Plugin) GetOrganizationByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Organization, error)
GetOrganizationByID provides a mock function with given fields: ctx, id
func (*Plugin) GetOrganizationByIdentity ¶
func (_m *Plugin) GetOrganizationByIdentity(ctx context.Context, identity string) (*fftypes.Organization, error)
GetOrganizationByIdentity provides a mock function with given fields: ctx, identity
func (*Plugin) GetOrganizationByName ¶
func (_m *Plugin) GetOrganizationByName(ctx context.Context, name string) (*fftypes.Organization, error)
GetOrganizationByName provides a mock function with given fields: ctx, name
func (*Plugin) GetOrganizations ¶
func (_m *Plugin) GetOrganizations(ctx context.Context, filter database.Filter) ([]*fftypes.Organization, *database.FilterResult, error)
GetOrganizations provides a mock function with given fields: ctx, filter
func (*Plugin) GetPins ¶
func (_m *Plugin) GetPins(ctx context.Context, filter database.Filter) ([]*fftypes.Pin, *database.FilterResult, error)
GetPins provides a mock function with given fields: ctx, filter
func (*Plugin) GetSubscriptionByID ¶
func (_m *Plugin) GetSubscriptionByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Subscription, error)
GetSubscriptionByID provides a mock function with given fields: ctx, id
func (*Plugin) GetSubscriptionByName ¶
func (_m *Plugin) GetSubscriptionByName(ctx context.Context, ns string, name string) (*fftypes.Subscription, error)
GetSubscriptionByName provides a mock function with given fields: ctx, ns, name
func (*Plugin) GetSubscriptions ¶
func (_m *Plugin) GetSubscriptions(ctx context.Context, filter database.Filter) ([]*fftypes.Subscription, *database.FilterResult, error)
GetSubscriptions provides a mock function with given fields: ctx, filter
func (*Plugin) GetTokenAccountPools ¶ added in v0.11.0
func (_m *Plugin) GetTokenAccountPools(ctx context.Context, key string, filter database.Filter) ([]*fftypes.TokenAccountPool, *database.FilterResult, error)
GetTokenAccountPools provides a mock function with given fields: ctx, key, filter
func (*Plugin) GetTokenAccounts ¶
func (_m *Plugin) GetTokenAccounts(ctx context.Context, filter database.Filter) ([]*fftypes.TokenAccount, *database.FilterResult, error)
GetTokenAccounts provides a mock function with given fields: ctx, filter
func (*Plugin) GetTokenBalance ¶ added in v0.11.0
func (_m *Plugin) GetTokenBalance(ctx context.Context, poolID *fftypes.UUID, tokenIndex string, identity string) (*fftypes.TokenBalance, error)
GetTokenBalance provides a mock function with given fields: ctx, poolID, tokenIndex, identity
func (*Plugin) GetTokenBalances ¶ added in v0.11.0
func (_m *Plugin) GetTokenBalances(ctx context.Context, filter database.Filter) ([]*fftypes.TokenBalance, *database.FilterResult, error)
GetTokenBalances provides a mock function with given fields: ctx, filter
func (*Plugin) GetTokenPool ¶
func (_m *Plugin) GetTokenPool(ctx context.Context, ns string, name string) (*fftypes.TokenPool, error)
GetTokenPool provides a mock function with given fields: ctx, ns, name
func (*Plugin) GetTokenPoolByID ¶
func (_m *Plugin) GetTokenPoolByID(ctx context.Context, id *fftypes.UUID) (*fftypes.TokenPool, error)
GetTokenPoolByID provides a mock function with given fields: ctx, id
func (*Plugin) GetTokenPoolByProtocolID ¶
func (_m *Plugin) GetTokenPoolByProtocolID(ctx context.Context, connector string, protocolID string) (*fftypes.TokenPool, error)
GetTokenPoolByProtocolID provides a mock function with given fields: ctx, connector, protocolID
func (*Plugin) GetTokenPools ¶
func (_m *Plugin) GetTokenPools(ctx context.Context, filter database.Filter) ([]*fftypes.TokenPool, *database.FilterResult, error)
GetTokenPools provides a mock function with given fields: ctx, filter
func (*Plugin) GetTokenTransfer ¶
func (_m *Plugin) GetTokenTransfer(ctx context.Context, localID *fftypes.UUID) (*fftypes.TokenTransfer, error)
GetTokenTransfer provides a mock function with given fields: ctx, localID
func (*Plugin) GetTokenTransferByProtocolID ¶ added in v0.11.0
func (_m *Plugin) GetTokenTransferByProtocolID(ctx context.Context, connector string, protocolID string) (*fftypes.TokenTransfer, error)
GetTokenTransferByProtocolID provides a mock function with given fields: ctx, connector, protocolID
func (*Plugin) GetTokenTransfers ¶
func (_m *Plugin) GetTokenTransfers(ctx context.Context, filter database.Filter) ([]*fftypes.TokenTransfer, *database.FilterResult, error)
GetTokenTransfers provides a mock function with given fields: ctx, filter
func (*Plugin) GetTransactionByID ¶
func (_m *Plugin) GetTransactionByID(ctx context.Context, id *fftypes.UUID) (*fftypes.Transaction, error)
GetTransactionByID provides a mock function with given fields: ctx, id
func (*Plugin) GetTransactions ¶
func (_m *Plugin) GetTransactions(ctx context.Context, filter database.Filter) ([]*fftypes.Transaction, *database.FilterResult, error)
GetTransactions provides a mock function with given fields: ctx, filter
func (*Plugin) Init ¶
func (_m *Plugin) Init(ctx context.Context, prefix config.Prefix, callbacks database.Callbacks) error
Init provides a mock function with given fields: ctx, prefix, callbacks
func (*Plugin) InitPrefix ¶
InitPrefix provides a mock function with given fields: prefix
func (*Plugin) InsertBlob ¶
InsertBlob provides a mock function with given fields: ctx, blob
func (*Plugin) InsertEvent ¶
InsertEvent provides a mock function with given fields: ctx, data
func (*Plugin) InsertNextPin ¶
InsertNextPin provides a mock function with given fields: ctx, nextpin
func (*Plugin) InsertOperation ¶ added in v0.11.2
InsertOperation provides a mock function with given fields: ctx, operation
func (*Plugin) RunAsGroup ¶
RunAsGroup provides a mock function with given fields: ctx, fn
func (*Plugin) SetPinDispatched ¶
SetPinDispatched provides a mock function with given fields: ctx, sequence
func (*Plugin) UpdateBatch ¶
UpdateBatch provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateData ¶
UpdateData provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateDatatype ¶
func (_m *Plugin) UpdateDatatype(ctx context.Context, id *fftypes.UUID, update database.Update) error
UpdateDatatype provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateEvent ¶
UpdateEvent provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateGroup ¶
func (_m *Plugin) UpdateGroup(ctx context.Context, hash *fftypes.Bytes32, update database.Update) error
UpdateGroup provides a mock function with given fields: ctx, hash, update
func (*Plugin) UpdateMessage ¶
func (_m *Plugin) UpdateMessage(ctx context.Context, id *fftypes.UUID, update database.Update) error
UpdateMessage provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateMessages ¶
func (_m *Plugin) UpdateMessages(ctx context.Context, filter database.Filter, update database.Update) error
UpdateMessages provides a mock function with given fields: ctx, filter, update
func (*Plugin) UpdateNextPin ¶
UpdateNextPin provides a mock function with given fields: ctx, sequence, update
func (*Plugin) UpdateNode ¶
UpdateNode provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateOffset ¶
UpdateOffset provides a mock function with given fields: ctx, rowID, update
func (*Plugin) UpdateOperation ¶
func (_m *Plugin) UpdateOperation(ctx context.Context, id *fftypes.UUID, update database.Update) error
UpdateOperation provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateOrganization ¶
func (_m *Plugin) UpdateOrganization(ctx context.Context, id *fftypes.UUID, update database.Update) error
UpdateOrganization provides a mock function with given fields: ctx, id, update
func (*Plugin) UpdateSubscription ¶
func (_m *Plugin) UpdateSubscription(ctx context.Context, ns string, name string, update database.Update) error
UpdateSubscription provides a mock function with given fields: ctx, ns, name, 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, id *fftypes.UUID, update database.Update) error
UpdateTransaction provides a mock function with given fields: ctx, id, update
func (*Plugin) UpsertBatch ¶
UpsertBatch provides a mock function with given fields: ctx, data, allowHashUpdate
func (*Plugin) UpsertConfigRecord ¶
func (_m *Plugin) UpsertConfigRecord(ctx context.Context, data *fftypes.ConfigRecord, allowExisting bool) error
UpsertConfigRecord provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertData ¶
func (_m *Plugin) UpsertData(ctx context.Context, data *fftypes.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 *fftypes.Datatype, allowExisting bool) error
UpsertDatatype provides a mock function with given fields: ctx, datadef, allowExisting
func (*Plugin) UpsertGroup ¶
UpsertGroup provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertMessage ¶
func (_m *Plugin) UpsertMessage(ctx context.Context, message *fftypes.Message, optimization database.UpsertOptimization) error
UpsertMessage provides a mock function with given fields: ctx, message, optimization
func (*Plugin) UpsertNamespace ¶
func (_m *Plugin) UpsertNamespace(ctx context.Context, data *fftypes.Namespace, allowExisting bool) error
UpsertNamespace provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertNode ¶
UpsertNode provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertNonceNext ¶
UpsertNonceNext provides a mock function with given fields: ctx, _a1
func (*Plugin) UpsertOffset ¶
UpsertOffset provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertOrganization ¶
func (_m *Plugin) UpsertOrganization(ctx context.Context, data *fftypes.Organization, allowExisting bool) error
UpsertOrganization provides a mock function with given fields: ctx, data, allowExisting
func (*Plugin) UpsertSubscription ¶
func (_m *Plugin) UpsertSubscription(ctx context.Context, data *fftypes.Subscription, allowExisting bool) error
UpsertSubscription provides a mock function with given fields: ctx, data, allowExisting
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) UpsertTransaction ¶
func (_m *Plugin) UpsertTransaction(ctx context.Context, data *fftypes.Transaction, allowHashUpdate bool) error
UpsertTransaction provides a mock function with given fields: ctx, data, allowHashUpdate