mocks

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: May 4, 2026 License: MPL-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockAPIExecutor 

type MockAPIExecutor struct {
	// contains filtered or unexported fields
}

MockAPIExecutor is a mock of Executor interface.

func NewMockAPIExecutor 

func NewMockAPIExecutor(ctrl *gomock.Controller) *MockAPIExecutor

NewMockAPIExecutor creates a new mock instance.

func (*MockAPIExecutor) CreateWebhookClient added in v0.5.0 

func (m *MockAPIExecutor) CreateWebhookClient(ctx context.Context, webhookURL string, eventFilters []string, retryMaxAttempts int) (*dto.CreateWebhookClientResponse, error)

CreateWebhookClient mocks base method.

func (*MockAPIExecutor) EXPECT 

func (m *MockAPIExecutor) EXPECT() *MockAPIExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAPIExecutor) GetAddressIndexingJob added in v0.5.0 

func (m *MockAPIExecutor) GetAddressIndexingJob(ctx context.Context, jobID int64, opts executor.GetAddressIndexingJobOptions) (*dto.AddressIndexingJobResponse, error)

GetAddressIndexingJob mocks base method.

func (*MockAPIExecutor) GetAddressIndexingJobByLegacyWorkflowID added in v0.5.0 

func (m *MockAPIExecutor) GetAddressIndexingJobByLegacyWorkflowID(ctx context.Context, workflowID string, opts executor.GetAddressIndexingJobOptions) (*dto.AddressIndexingJobResponse, error)

GetAddressIndexingJobByLegacyWorkflowID mocks base method.

func (*MockAPIExecutor) GetJobStatus added in v0.5.0 

func (m *MockAPIExecutor) GetJobStatus(ctx context.Context, jobID int64) (*dto.JobStatusResponse, error)

GetJobStatus mocks base method.

func (*MockAPIExecutor) GetToken 

func (m *MockAPIExecutor) GetToken(ctx context.Context, tokenCID string, expansions []types.Expansion, ownersLimit *uint8, ownersOffset *uint64, provenanceEventsLimit *uint8, provenanceEventsOffset *uint64, provenanceEventsOrder *types.Order) (*dto.TokenResponse, error)

GetToken mocks base method.

func (*MockAPIExecutor) GetTokens 

func (m *MockAPIExecutor) GetTokens(ctx context.Context, owners []string, chains []domain.Chain, contractAddresses, tokenNumbers []string, tokenIDs []uint64, tokenCIDs []string, limit *uint8, offset *uint64, includeUnviewable *bool, sortBy *types.TokenSortBy, sortOrder *types.Order, expansions []types.Expansion) (*dto.TokenListResponse, error)

GetTokens mocks base method.

func (*MockAPIExecutor) SyncCollection added in v0.5.0 

func (m *MockAPIExecutor) SyncCollection(ctx context.Context, address string, checkpoint *dto.SyncCheckpoint, limit uint8) (*dto.SyncCollectionResponse, error)

SyncCollection mocks base method.

func (*MockAPIExecutor) TriggerAddressIndexing added in v0.5.0 

func (m *MockAPIExecutor) TriggerAddressIndexing(ctx context.Context, addresses []string) (*dto.TriggerAddressIndexingResponse, error)

TriggerAddressIndexing mocks base method.

func (*MockAPIExecutor) TriggerMetadataIndexing added in v0.2.0 

func (m *MockAPIExecutor) TriggerMetadataIndexing(ctx context.Context, tokenIDs []uint64, tokenCIDs []domain.TokenCID) (*dto.TriggerIndexingResponse, error)

TriggerMetadataIndexing mocks base method.

func (*MockAPIExecutor) TriggerTokenIndexing 

func (m *MockAPIExecutor) TriggerTokenIndexing(ctx context.Context, tokenCIDs []domain.TokenCID) (*dto.TriggerIndexingResponse, error)

TriggerTokenIndexing mocks base method.

type MockAPIExecutorMockRecorder 

type MockAPIExecutorMockRecorder struct {
	// contains filtered or unexported fields
}

MockAPIExecutorMockRecorder is the mock recorder for MockAPIExecutor.

func (*MockAPIExecutorMockRecorder) CreateWebhookClient added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) CreateWebhookClient(ctx, webhookURL, eventFilters, retryMaxAttempts any) *gomock.Call

CreateWebhookClient indicates an expected call of CreateWebhookClient.

func (*MockAPIExecutorMockRecorder) GetAddressIndexingJob added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) GetAddressIndexingJob(ctx, jobID, opts any) *gomock.Call

GetAddressIndexingJob indicates an expected call of GetAddressIndexingJob.

func (*MockAPIExecutorMockRecorder) GetAddressIndexingJobByLegacyWorkflowID added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) GetAddressIndexingJobByLegacyWorkflowID(ctx, workflowID, opts any) *gomock.Call

GetAddressIndexingJobByLegacyWorkflowID indicates an expected call of GetAddressIndexingJobByLegacyWorkflowID.

func (*MockAPIExecutorMockRecorder) GetJobStatus added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) GetJobStatus(ctx, jobID any) *gomock.Call

GetJobStatus indicates an expected call of GetJobStatus.

func (*MockAPIExecutorMockRecorder) GetToken 

func (mr *MockAPIExecutorMockRecorder) GetToken(ctx, tokenCID, expansions, ownersLimit, ownersOffset, provenanceEventsLimit, provenanceEventsOffset, provenanceEventsOrder any) *gomock.Call

GetToken indicates an expected call of GetToken.

func (*MockAPIExecutorMockRecorder) GetTokens 

func (mr *MockAPIExecutorMockRecorder) GetTokens(ctx, owners, chains, contractAddresses, tokenNumbers, tokenIDs, tokenCIDs, limit, offset, includeUnviewable, sortBy, sortOrder, expansions any) *gomock.Call

GetTokens indicates an expected call of GetTokens.

func (*MockAPIExecutorMockRecorder) SyncCollection added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) SyncCollection(ctx, address, checkpoint, limit any) *gomock.Call

SyncCollection indicates an expected call of SyncCollection.

func (*MockAPIExecutorMockRecorder) TriggerAddressIndexing added in v0.5.0 

func (mr *MockAPIExecutorMockRecorder) TriggerAddressIndexing(ctx, addresses any) *gomock.Call

TriggerAddressIndexing indicates an expected call of TriggerAddressIndexing.

func (*MockAPIExecutorMockRecorder) TriggerMetadataIndexing added in v0.2.0 

func (mr *MockAPIExecutorMockRecorder) TriggerMetadataIndexing(ctx, tokenIDs, tokenCIDs any) *gomock.Call

TriggerMetadataIndexing indicates an expected call of TriggerMetadataIndexing.

func (*MockAPIExecutorMockRecorder) TriggerTokenIndexing 

func (mr *MockAPIExecutorMockRecorder) TriggerTokenIndexing(ctx, tokenCIDs any) *gomock.Call

TriggerTokenIndexing indicates an expected call of TriggerTokenIndexing.

type MockAPIHandler 

type MockAPIHandler struct {
	// contains filtered or unexported fields
}

MockAPIHandler is a mock of Handler interface.

func NewMockAPIHandler 

func NewMockAPIHandler(ctrl *gomock.Controller) *MockAPIHandler

NewMockAPIHandler creates a new mock instance.

func (*MockAPIHandler) CreateWebhookClient added in v0.5.0 

func (m *MockAPIHandler) CreateWebhookClient(c *gin.Context)

CreateWebhookClient mocks base method.

func (*MockAPIHandler) EXPECT 

func (m *MockAPIHandler) EXPECT() *MockAPIHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAPIHandler) GetAddressIndexingJob added in v0.5.0 

func (m *MockAPIHandler) GetAddressIndexingJob(c *gin.Context)

GetAddressIndexingJob mocks base method.

func (*MockAPIHandler) GetJobStatus added in v0.5.0 

func (m *MockAPIHandler) GetJobStatus(c *gin.Context)

GetJobStatus mocks base method.

func (*MockAPIHandler) GetToken 

func (m *MockAPIHandler) GetToken(c *gin.Context)

GetToken mocks base method.

func (*MockAPIHandler) GetWorkflowRun added in v0.5.0 

func (m *MockAPIHandler) GetWorkflowRun(c *gin.Context)

GetWorkflowRun mocks base method.

func (*MockAPIHandler) HealthCheck 

func (m *MockAPIHandler) HealthCheck(c *gin.Context)

HealthCheck mocks base method.

func (*MockAPIHandler) ListTokens 

func (m *MockAPIHandler) ListTokens(c *gin.Context)

ListTokens mocks base method.

func (*MockAPIHandler) SyncCollection added in v0.5.0 

func (m *MockAPIHandler) SyncCollection(c *gin.Context)

SyncCollection mocks base method.

func (*MockAPIHandler) TriggerAddressIndexing added in v0.5.0 

func (m *MockAPIHandler) TriggerAddressIndexing(c *gin.Context)

TriggerAddressIndexing mocks base method.

func (*MockAPIHandler) TriggerMetadataIndexing added in v0.2.0 

func (m *MockAPIHandler) TriggerMetadataIndexing(c *gin.Context)

TriggerMetadataIndexing mocks base method.

func (*MockAPIHandler) TriggerTokenIndexing 

func (m *MockAPIHandler) TriggerTokenIndexing(c *gin.Context)

TriggerTokenIndexing mocks base method.

type MockAPIHandlerMockRecorder 

type MockAPIHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockAPIHandlerMockRecorder is the mock recorder for MockAPIHandler.

func (*MockAPIHandlerMockRecorder) CreateWebhookClient added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) CreateWebhookClient(c any) *gomock.Call

CreateWebhookClient indicates an expected call of CreateWebhookClient.

func (*MockAPIHandlerMockRecorder) GetAddressIndexingJob added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) GetAddressIndexingJob(c any) *gomock.Call

GetAddressIndexingJob indicates an expected call of GetAddressIndexingJob.

func (*MockAPIHandlerMockRecorder) GetJobStatus added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) GetJobStatus(c any) *gomock.Call

GetJobStatus indicates an expected call of GetJobStatus.

func (*MockAPIHandlerMockRecorder) GetToken 

func (mr *MockAPIHandlerMockRecorder) GetToken(c any) *gomock.Call

GetToken indicates an expected call of GetToken.

func (*MockAPIHandlerMockRecorder) GetWorkflowRun added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) GetWorkflowRun(c any) *gomock.Call

GetWorkflowRun indicates an expected call of GetWorkflowRun.

func (*MockAPIHandlerMockRecorder) HealthCheck 

func (mr *MockAPIHandlerMockRecorder) HealthCheck(c any) *gomock.Call

HealthCheck indicates an expected call of HealthCheck.

func (*MockAPIHandlerMockRecorder) ListTokens 

func (mr *MockAPIHandlerMockRecorder) ListTokens(c any) *gomock.Call

ListTokens indicates an expected call of ListTokens.

func (*MockAPIHandlerMockRecorder) SyncCollection added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) SyncCollection(c any) *gomock.Call

SyncCollection indicates an expected call of SyncCollection.

func (*MockAPIHandlerMockRecorder) TriggerAddressIndexing added in v0.5.0 

func (mr *MockAPIHandlerMockRecorder) TriggerAddressIndexing(c any) *gomock.Call

TriggerAddressIndexing indicates an expected call of TriggerAddressIndexing.

func (*MockAPIHandlerMockRecorder) TriggerMetadataIndexing added in v0.2.0 

func (mr *MockAPIHandlerMockRecorder) TriggerMetadataIndexing(c any) *gomock.Call

TriggerMetadataIndexing indicates an expected call of TriggerMetadataIndexing.

func (*MockAPIHandlerMockRecorder) TriggerTokenIndexing 

func (mr *MockAPIHandlerMockRecorder) TriggerTokenIndexing(c any) *gomock.Call

TriggerTokenIndexing indicates an expected call of TriggerTokenIndexing.

type MockArtBlocksClient 

type MockArtBlocksClient struct {
	// contains filtered or unexported fields
}

MockArtBlocksClient is a mock of Client interface.

func NewMockArtBlocksClient 

func NewMockArtBlocksClient(ctrl *gomock.Controller) *MockArtBlocksClient

NewMockArtBlocksClient creates a new mock instance.

func (*MockArtBlocksClient) EXPECT 

func (m *MockArtBlocksClient) EXPECT() *MockArtBlocksClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockArtBlocksClient) GetProjectMetadata 

func (m *MockArtBlocksClient) GetProjectMetadata(ctx context.Context, chainID int, projectID string) (*artblocks.ProjectMetadata, error)

GetProjectMetadata mocks base method.

type MockArtBlocksClientMockRecorder 

type MockArtBlocksClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockArtBlocksClientMockRecorder is the mock recorder for MockArtBlocksClient.

func (*MockArtBlocksClientMockRecorder) GetProjectMetadata 

func (mr *MockArtBlocksClientMockRecorder) GetProjectMetadata(ctx, chainID, projectID any) *gomock.Call

GetProjectMetadata indicates an expected call of GetProjectMetadata.

type MockBase64 

type MockBase64 struct {
	// contains filtered or unexported fields
}

MockBase64 is a mock of Base64 interface.

func NewMockBase64 

func NewMockBase64(ctrl *gomock.Controller) *MockBase64

NewMockBase64 creates a new mock instance.

func (*MockBase64) Decode 

func (m *MockBase64) Decode(data string) ([]byte, error)

Decode mocks base method.

func (*MockBase64) EXPECT 

func (m *MockBase64) EXPECT() *MockBase64MockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBase64) Encode 

func (m *MockBase64) Encode(data []byte) string

Encode mocks base method.

type MockBase64MockRecorder 

type MockBase64MockRecorder struct {
	// contains filtered or unexported fields
}

MockBase64MockRecorder is the mock recorder for MockBase64.

func (*MockBase64MockRecorder) Decode 

func (mr *MockBase64MockRecorder) Decode(data any) *gomock.Call

Decode indicates an expected call of Decode.

func (*MockBase64MockRecorder) Encode 

func (mr *MockBase64MockRecorder) Encode(data any) *gomock.Call

Encode indicates an expected call of Encode.

type MockBlacklistRegistry 

type MockBlacklistRegistry struct {
	// contains filtered or unexported fields
}

MockBlacklistRegistry is a mock of BlacklistRegistry interface.

func NewMockBlacklistRegistry 

func NewMockBlacklistRegistry(ctrl *gomock.Controller) *MockBlacklistRegistry

NewMockBlacklistRegistry creates a new mock instance.

func (*MockBlacklistRegistry) EXPECT 

func (m *MockBlacklistRegistry) EXPECT() *MockBlacklistRegistryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBlacklistRegistry) IsBlacklisted 

func (m *MockBlacklistRegistry) IsBlacklisted(chainID domain.Chain, contractAddress string) bool

IsBlacklisted mocks base method.

func (*MockBlacklistRegistry) IsTokenCIDBlacklisted 

func (m *MockBlacklistRegistry) IsTokenCIDBlacklisted(tokenCID domain.TokenCID) bool

IsTokenCIDBlacklisted mocks base method.

type MockBlacklistRegistryLoader 

type MockBlacklistRegistryLoader struct {
	// contains filtered or unexported fields
}

MockBlacklistRegistryLoader is a mock of BlacklistRegistryLoader interface.

func NewMockBlacklistRegistryLoader 

func NewMockBlacklistRegistryLoader(ctrl *gomock.Controller) *MockBlacklistRegistryLoader

NewMockBlacklistRegistryLoader creates a new mock instance.

func (*MockBlacklistRegistryLoader) EXPECT 

func (m *MockBlacklistRegistryLoader) EXPECT() *MockBlacklistRegistryLoaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBlacklistRegistryLoader) Load 

func (m *MockBlacklistRegistryLoader) Load(filePath string) (registry.BlacklistRegistry, error)

Load mocks base method.

type MockBlacklistRegistryLoaderMockRecorder 

type MockBlacklistRegistryLoaderMockRecorder struct {
	// contains filtered or unexported fields
}

MockBlacklistRegistryLoaderMockRecorder is the mock recorder for MockBlacklistRegistryLoader.

func (*MockBlacklistRegistryLoaderMockRecorder) Load 

func (mr *MockBlacklistRegistryLoaderMockRecorder) Load(filePath any) *gomock.Call

Load indicates an expected call of Load.

type MockBlacklistRegistryMockRecorder 

type MockBlacklistRegistryMockRecorder struct {
	// contains filtered or unexported fields
}

MockBlacklistRegistryMockRecorder is the mock recorder for MockBlacklistRegistry.

func (*MockBlacklistRegistryMockRecorder) IsBlacklisted 

func (mr *MockBlacklistRegistryMockRecorder) IsBlacklisted(chainID, contractAddress any) *gomock.Call

IsBlacklisted indicates an expected call of IsBlacklisted.

func (*MockBlacklistRegistryMockRecorder) IsTokenCIDBlacklisted 

func (mr *MockBlacklistRegistryMockRecorder) IsTokenCIDBlacklisted(tokenCID any) *gomock.Call

IsTokenCIDBlacklisted indicates an expected call of IsTokenCIDBlacklisted.

type MockBlockFetcher added in v0.4.0 

type MockBlockFetcher struct {
	// contains filtered or unexported fields
}

MockBlockFetcher is a mock of BlockFetcher interface.

func NewMockBlockFetcher added in v0.4.0 

func NewMockBlockFetcher(ctrl *gomock.Controller) *MockBlockFetcher

NewMockBlockFetcher creates a new mock instance.

func (*MockBlockFetcher) EXPECT added in v0.4.0 

func (m *MockBlockFetcher) EXPECT() *MockBlockFetcherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBlockFetcher) FetchBlockTimestamp added in v0.4.0 

func (m *MockBlockFetcher) FetchBlockTimestamp(ctx context.Context, blockNumber uint64) (time.Time, error)

FetchBlockTimestamp mocks base method.

func (*MockBlockFetcher) FetchLatestBlock added in v0.4.0 

func (m *MockBlockFetcher) FetchLatestBlock(ctx context.Context) (uint64, error)

FetchLatestBlock mocks base method.

type MockBlockFetcherMockRecorder added in v0.4.0 

type MockBlockFetcherMockRecorder struct {
	// contains filtered or unexported fields
}

MockBlockFetcherMockRecorder is the mock recorder for MockBlockFetcher.

func (*MockBlockFetcherMockRecorder) FetchBlockTimestamp added in v0.4.0 

func (mr *MockBlockFetcherMockRecorder) FetchBlockTimestamp(ctx, blockNumber any) *gomock.Call

FetchBlockTimestamp indicates an expected call of FetchBlockTimestamp.

func (*MockBlockFetcherMockRecorder) FetchLatestBlock added in v0.4.0 

func (mr *MockBlockFetcherMockRecorder) FetchLatestBlock(ctx any) *gomock.Call

FetchLatestBlock indicates an expected call of FetchLatestBlock.

type MockBlockProvider added in v0.4.0 

type MockBlockProvider struct {
	// contains filtered or unexported fields
}

MockBlockProvider is a mock of BlockProvider interface.

func NewMockBlockProvider added in v0.4.0 

func NewMockBlockProvider(ctrl *gomock.Controller) *MockBlockProvider

NewMockBlockProvider creates a new mock instance.

func (*MockBlockProvider) EXPECT added in v0.4.0 

func (m *MockBlockProvider) EXPECT() *MockBlockProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBlockProvider) GetBlockTimestamp added in v0.4.0 

func (m *MockBlockProvider) GetBlockTimestamp(ctx context.Context, blockNumber uint64) (time.Time, error)

GetBlockTimestamp mocks base method.

func (*MockBlockProvider) GetLatestBlock added in v0.4.0 

func (m *MockBlockProvider) GetLatestBlock(ctx context.Context) (uint64, error)

GetLatestBlock mocks base method.

type MockBlockProviderMockRecorder added in v0.4.0 

type MockBlockProviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockBlockProviderMockRecorder is the mock recorder for MockBlockProvider.

func (*MockBlockProviderMockRecorder) GetBlockTimestamp added in v0.4.0 

func (mr *MockBlockProviderMockRecorder) GetBlockTimestamp(ctx, blockNumber any) *gomock.Call

GetBlockTimestamp indicates an expected call of GetBlockTimestamp.

func (*MockBlockProviderMockRecorder) GetLatestBlock added in v0.4.0 

func (mr *MockBlockProviderMockRecorder) GetLatestBlock(ctx any) *gomock.Call

GetLatestBlock indicates an expected call of GetLatestBlock.

type MockBlockchainEventSource added in v0.5.0 

type MockBlockchainEventSource struct {
	// contains filtered or unexported fields
}

MockBlockchainEventSource is a mock of EventSource interface.

func NewMockBlockchainEventSource added in v0.5.0 

func NewMockBlockchainEventSource(ctrl *gomock.Controller) *MockBlockchainEventSource

NewMockBlockchainEventSource creates a new mock instance.

func (*MockBlockchainEventSource) Close added in v0.5.0 

func (m *MockBlockchainEventSource) Close()

Close mocks base method.

func (*MockBlockchainEventSource) EXPECT added in v0.5.0 

func (m *MockBlockchainEventSource) EXPECT() *MockBlockchainEventSourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBlockchainEventSource) GetLatestBlock added in v0.5.0 

func (m *MockBlockchainEventSource) GetLatestBlock(ctx context.Context) (uint64, error)

GetLatestBlock mocks base method.

func (*MockBlockchainEventSource) SubscribeEvents added in v0.5.0 

func (m *MockBlockchainEventSource) SubscribeEvents(ctx context.Context, fromBlock uint64, handler blockchain.EventHandler) error

SubscribeEvents mocks base method.

type MockBlockchainEventSourceMockRecorder added in v0.5.0 

type MockBlockchainEventSourceMockRecorder struct {
	// contains filtered or unexported fields
}

MockBlockchainEventSourceMockRecorder is the mock recorder for MockBlockchainEventSource.

func (*MockBlockchainEventSourceMockRecorder) Close added in v0.5.0 

func (mr *MockBlockchainEventSourceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockBlockchainEventSourceMockRecorder) GetLatestBlock added in v0.5.0 

func (mr *MockBlockchainEventSourceMockRecorder) GetLatestBlock(ctx any) *gomock.Call

GetLatestBlock indicates an expected call of GetLatestBlock.

func (*MockBlockchainEventSourceMockRecorder) SubscribeEvents added in v0.5.0 

func (mr *MockBlockchainEventSourceMockRecorder) SubscribeEvents(ctx, fromBlock, handler any) *gomock.Call

SubscribeEvents indicates an expected call of SubscribeEvents.

type MockBrowserRasterizer added in v0.5.0 

type MockBrowserRasterizer struct {
	// contains filtered or unexported fields
}

MockBrowserRasterizer is a mock of BrowserRasterizer interface.

func NewMockBrowserRasterizer added in v0.5.0 

func NewMockBrowserRasterizer(ctrl *gomock.Controller) *MockBrowserRasterizer

NewMockBrowserRasterizer creates a new mock instance.

func (*MockBrowserRasterizer) Close added in v0.5.0 

func (m *MockBrowserRasterizer) Close() error

Close mocks base method.

func (*MockBrowserRasterizer) EXPECT added in v0.5.0 

func (m *MockBrowserRasterizer) EXPECT() *MockBrowserRasterizerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBrowserRasterizer) RasterizeSVG added in v0.5.0 

func (m *MockBrowserRasterizer) RasterizeSVG(ctx context.Context, svgData []byte, width int) ([]byte, error)

RasterizeSVG mocks base method.

type MockBrowserRasterizerMockRecorder added in v0.5.0 

type MockBrowserRasterizerMockRecorder struct {
	// contains filtered or unexported fields
}

MockBrowserRasterizerMockRecorder is the mock recorder for MockBrowserRasterizer.

func (*MockBrowserRasterizerMockRecorder) Close added in v0.5.0 

func (mr *MockBrowserRasterizerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockBrowserRasterizerMockRecorder) RasterizeSVG added in v0.5.0 

func (mr *MockBrowserRasterizerMockRecorder) RasterizeSVG(ctx, svgData, width any) *gomock.Call

RasterizeSVG indicates an expected call of RasterizeSVG.

type MockChromedpClient added in v0.5.0 

type MockChromedpClient struct {
	// contains filtered or unexported fields
}

MockChromedpClient is a mock of ChromedpClient interface.

func NewMockChromedpClient added in v0.5.0 

func NewMockChromedpClient(ctrl *gomock.Controller) *MockChromedpClient

NewMockChromedpClient creates a new mock instance.

func (*MockChromedpClient) EXPECT added in v0.5.0 

func (m *MockChromedpClient) EXPECT() *MockChromedpClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockChromedpClient) EmulateViewport added in v0.5.0 

func (m *MockChromedpClient) EmulateViewport(width, height int64) chromedp.EmulateAction

EmulateViewport mocks base method.

func (*MockChromedpClient) Evaluate added in v0.5.0 

func (m *MockChromedpClient) Evaluate(expr string, result any, options ...chromedp.EvaluateOption) chromedp.EvaluateAction

Evaluate mocks base method.

func (*MockChromedpClient) FullScreenshot added in v0.5.0 

func (m *MockChromedpClient) FullScreenshot(result *[]byte, quality int) chromedp.Action

FullScreenshot mocks base method.

func (*MockChromedpClient) Navigate added in v0.5.0 

func (m *MockChromedpClient) Navigate(url string) chromedp.NavigateAction

Navigate mocks base method.

func (*MockChromedpClient) NewContext added in v0.5.0 

func (m *MockChromedpClient) NewContext(ctx context.Context) (context.Context, context.CancelFunc)

NewContext mocks base method.

func (*MockChromedpClient) NewExecAllocator added in v0.5.0 

func (m *MockChromedpClient) NewExecAllocator(ctx context.Context, opts []chromedp.ExecAllocatorOption) (context.Context, context.CancelFunc)

NewExecAllocator mocks base method.

func (*MockChromedpClient) Run added in v0.5.0 

func (m *MockChromedpClient) Run(ctx context.Context, actions ...chromedp.Action) error

Run mocks base method.

func (*MockChromedpClient) Sleep added in v0.5.0 

func (m *MockChromedpClient) Sleep(duration time.Duration) chromedp.Action

Sleep mocks base method.

func (*MockChromedpClient) WaitReady added in v0.5.0 

func (m *MockChromedpClient) WaitReady(sel string, waitReadyOpts ...chromedp.QueryOption) chromedp.QueryAction

WaitReady mocks base method.

type MockChromedpClientMockRecorder added in v0.5.0 

type MockChromedpClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockChromedpClientMockRecorder is the mock recorder for MockChromedpClient.

func (*MockChromedpClientMockRecorder) EmulateViewport added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) EmulateViewport(width, height any) *gomock.Call

EmulateViewport indicates an expected call of EmulateViewport.

func (*MockChromedpClientMockRecorder) Evaluate added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) Evaluate(expr, result any, options ...any) *gomock.Call

Evaluate indicates an expected call of Evaluate.

func (*MockChromedpClientMockRecorder) FullScreenshot added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) FullScreenshot(result, quality any) *gomock.Call

FullScreenshot indicates an expected call of FullScreenshot.

func (*MockChromedpClientMockRecorder) Navigate added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) Navigate(url any) *gomock.Call

Navigate indicates an expected call of Navigate.

func (*MockChromedpClientMockRecorder) NewContext added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) NewContext(ctx any) *gomock.Call

NewContext indicates an expected call of NewContext.

func (*MockChromedpClientMockRecorder) NewExecAllocator added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) NewExecAllocator(ctx, opts any) *gomock.Call

NewExecAllocator indicates an expected call of NewExecAllocator.

func (*MockChromedpClientMockRecorder) Run added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) Run(ctx any, actions ...any) *gomock.Call

Run indicates an expected call of Run.

func (*MockChromedpClientMockRecorder) Sleep added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) Sleep(duration any) *gomock.Call

Sleep indicates an expected call of Sleep.

func (*MockChromedpClientMockRecorder) WaitReady added in v0.5.0 

func (mr *MockChromedpClientMockRecorder) WaitReady(sel any, waitReadyOpts ...any) *gomock.Call

WaitReady indicates an expected call of WaitReady.

type MockClock 

type MockClock struct {
	// contains filtered or unexported fields
}

MockClock is a mock of Clock interface.

func NewMockClock 

func NewMockClock(ctrl *gomock.Controller) *MockClock

NewMockClock creates a new mock instance.

func (*MockClock) After 

func (m *MockClock) After(d time.Duration) <-chan time.Time

After mocks base method.

func (*MockClock) EXPECT 

func (m *MockClock) EXPECT() *MockClockMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClock) NewTicker 

func (m *MockClock) NewTicker(d time.Duration) *time.Ticker

NewTicker mocks base method.

func (*MockClock) Now 

func (m *MockClock) Now() time.Time

Now mocks base method.

func (*MockClock) Parse 

func (m *MockClock) Parse(layout, value string) (time.Time, error)

Parse mocks base method.

func (*MockClock) Since 

func (m *MockClock) Since(t time.Time) time.Duration

Since mocks base method.

func (*MockClock) Sleep 

func (m *MockClock) Sleep(d time.Duration)

Sleep mocks base method.

func (*MockClock) Unix 

func (m *MockClock) Unix(sec, nsec int64) time.Time

Unix mocks base method.

type MockClockMockRecorder 

type MockClockMockRecorder struct {
	// contains filtered or unexported fields
}

MockClockMockRecorder is the mock recorder for MockClock.

func (*MockClockMockRecorder) After 

func (mr *MockClockMockRecorder) After(d any) *gomock.Call

After indicates an expected call of After.

func (*MockClockMockRecorder) NewTicker 

func (mr *MockClockMockRecorder) NewTicker(d any) *gomock.Call

NewTicker indicates an expected call of NewTicker.

func (*MockClockMockRecorder) Now 

func (mr *MockClockMockRecorder) Now() *gomock.Call

Now indicates an expected call of Now.

func (*MockClockMockRecorder) Parse 

func (mr *MockClockMockRecorder) Parse(layout, value any) *gomock.Call

Parse indicates an expected call of Parse.

func (*MockClockMockRecorder) Since 

func (mr *MockClockMockRecorder) Since(t any) *gomock.Call

Since indicates an expected call of Since.

func (*MockClockMockRecorder) Sleep 

func (mr *MockClockMockRecorder) Sleep(d any) *gomock.Call

Sleep indicates an expected call of Sleep.

func (*MockClockMockRecorder) Unix 

func (mr *MockClockMockRecorder) Unix(sec, nsec any) *gomock.Call

Unix indicates an expected call of Unix.

type MockCloudflareClient 

type MockCloudflareClient struct {
	// contains filtered or unexported fields
}

MockCloudflareClient is a mock of CloudflareClient interface.

func NewMockCloudflareClient 

func NewMockCloudflareClient(ctrl *gomock.Controller) *MockCloudflareClient

NewMockCloudflareClient creates a new mock instance.

func (*MockCloudflareClient) EXPECT 

func (m *MockCloudflareClient) EXPECT() *MockCloudflareClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCloudflareClient) GetImage 

func (m *MockCloudflareClient) GetImage(ctx context.Context, rc *cloudflare.ResourceContainer, id string) (cloudflare.Image, error)

GetImage mocks base method.

func (*MockCloudflareClient) GetVideo 

func (m *MockCloudflareClient) GetVideo(ctx context.Context, params cloudflare.StreamParameters) (cloudflare.StreamVideo, error)

GetVideo mocks base method.

func (*MockCloudflareClient) UploadImage 

func (m *MockCloudflareClient) UploadImage(ctx context.Context, rc *cloudflare.ResourceContainer, params cloudflare.UploadImageParams) (cloudflare.Image, error)

UploadImage mocks base method.

func (*MockCloudflareClient) UploadVideoFromFile 

func (m *MockCloudflareClient) UploadVideoFromFile(ctx context.Context, params cloudflare.StreamUploadFileParameters) (cloudflare.StreamVideo, error)

UploadVideoFromFile mocks base method.

func (*MockCloudflareClient) UploadVideoFromURL 

func (m *MockCloudflareClient) UploadVideoFromURL(ctx context.Context, params cloudflare.StreamUploadFromURLParameters) (cloudflare.StreamVideo, error)

UploadVideoFromURL mocks base method.

type MockCloudflareClientMockRecorder 

type MockCloudflareClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockCloudflareClientMockRecorder is the mock recorder for MockCloudflareClient.

func (*MockCloudflareClientMockRecorder) GetImage 

func (mr *MockCloudflareClientMockRecorder) GetImage(ctx, rc, id any) *gomock.Call

GetImage indicates an expected call of GetImage.

func (*MockCloudflareClientMockRecorder) GetVideo 

func (mr *MockCloudflareClientMockRecorder) GetVideo(ctx, params any) *gomock.Call

GetVideo indicates an expected call of GetVideo.

func (*MockCloudflareClientMockRecorder) UploadImage 

func (mr *MockCloudflareClientMockRecorder) UploadImage(ctx, rc, params any) *gomock.Call

UploadImage indicates an expected call of UploadImage.

func (*MockCloudflareClientMockRecorder) UploadVideoFromFile 

func (mr *MockCloudflareClientMockRecorder) UploadVideoFromFile(ctx, params any) *gomock.Call

UploadVideoFromFile indicates an expected call of UploadVideoFromFile.

func (*MockCloudflareClientMockRecorder) UploadVideoFromURL 

func (mr *MockCloudflareClientMockRecorder) UploadVideoFromURL(ctx, params any) *gomock.Call

UploadVideoFromURL indicates an expected call of UploadVideoFromURL.

type MockCoreExecutor added in v0.4.0 

type MockCoreExecutor struct {
	// contains filtered or unexported fields
}

MockCoreExecutor is a mock of CoreExecutor interface.

func NewMockCoreExecutor added in v0.4.0 

func NewMockCoreExecutor(ctrl *gomock.Controller) *MockCoreExecutor

NewMockCoreExecutor creates a new mock instance.

func (*MockCoreExecutor) CheckMediaURLsHealthAndUpdateViewability added in v0.5.0 

func (m *MockCoreExecutor) CheckMediaURLsHealthAndUpdateViewability(ctx context.Context, tokenCID string, mediaURLs []string) (*workflows.MediaHealthCheckResult, error)

CheckMediaURLsHealthAndUpdateViewability mocks base method.

func (*MockCoreExecutor) CheckTokenExists added in v0.4.0 

func (m *MockCoreExecutor) CheckTokenExists(ctx context.Context, tokenCID domain.TokenCID) (bool, error)

CheckTokenExists mocks base method.

func (*MockCoreExecutor) CreateIndexingJob added in v0.5.0 

func (m *MockCoreExecutor) CreateIndexingJob(ctx context.Context, address string, chain domain.Chain, jobID int64) error

CreateIndexingJob mocks base method.

func (*MockCoreExecutor) CreateMetadataUpdate added in v0.4.0 

func (m *MockCoreExecutor) CreateMetadataUpdate(ctx context.Context, event *domain.BlockchainEvent) error

CreateMetadataUpdate mocks base method.

func (*MockCoreExecutor) CreateTokenMint added in v0.4.0 

func (m *MockCoreExecutor) CreateTokenMint(ctx context.Context, event *domain.BlockchainEvent) error

CreateTokenMint mocks base method.

func (*MockCoreExecutor) CreateWebhookDeliveryRecord added in v0.5.0 

func (m *MockCoreExecutor) CreateWebhookDeliveryRecord(ctx context.Context, delivery *schema.WebhookDelivery, event webhook.WebhookEvent) (uint64, error)

CreateWebhookDeliveryRecord mocks base method.

func (*MockCoreExecutor) DeliverWebhookHTTP added in v0.5.0 

func (m *MockCoreExecutor) DeliverWebhookHTTP(ctx context.Context, client *schema.WebhookClient, event webhook.WebhookEvent, deliveryID uint64) (webhook.DeliveryResult, error)

DeliverWebhookHTTP mocks base method.

func (*MockCoreExecutor) EXPECT added in v0.4.0 

func (m *MockCoreExecutor) EXPECT() *MockCoreExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCoreExecutor) EnhanceTokenMetadata added in v0.4.0 

func (m *MockCoreExecutor) EnhanceTokenMetadata(ctx context.Context, tokenCID domain.TokenCID, normalizedMetadata *metadata.NormalizedMetadata) (*metadata.EnhancedMetadata, error)

EnhanceTokenMetadata mocks base method.

func (*MockCoreExecutor) EnsureWatchedAddressExists added in v0.4.0 

func (m *MockCoreExecutor) EnsureWatchedAddressExists(ctx context.Context, address string, chain domain.Chain, dailyQuota int) error

EnsureWatchedAddressExists mocks base method.

func (*MockCoreExecutor) GetActiveWebhookClientsByEventType added in v0.5.0 

func (m *MockCoreExecutor) GetActiveWebhookClientsByEventType(ctx context.Context, eventType string) ([]*schema.WebhookClient, error)

GetActiveWebhookClientsByEventType mocks base method.

func (*MockCoreExecutor) GetEthereumTokenCIDsByOwnerWithinBlockRange added in v0.4.0 

func (m *MockCoreExecutor) GetEthereumTokenCIDsByOwnerWithinBlockRange(ctx context.Context, address string, requestedFromBlock, requestedToBlock uint64, limit int, order domain.BlockScanOrder) (domain.TokenWithBlockRangeResult, error)

GetEthereumTokenCIDsByOwnerWithinBlockRange mocks base method.

func (*MockCoreExecutor) GetIndexingBlockRangeForAddress added in v0.4.0 

func (m *MockCoreExecutor) GetIndexingBlockRangeForAddress(ctx context.Context, address string, chainID domain.Chain) (*workflows.BlockRangeResult, error)

GetIndexingBlockRangeForAddress mocks base method.

func (*MockCoreExecutor) GetLatestEthereumBlock added in v0.4.0 

func (m *MockCoreExecutor) GetLatestEthereumBlock(ctx context.Context) (uint64, error)

GetLatestEthereumBlock mocks base method.

func (*MockCoreExecutor) GetLatestTezosBlock added in v0.4.0 

func (m *MockCoreExecutor) GetLatestTezosBlock(ctx context.Context) (uint64, error)

GetLatestTezosBlock mocks base method.

func (*MockCoreExecutor) GetQuotaInfo added in v0.5.0 

func (m *MockCoreExecutor) GetQuotaInfo(ctx context.Context, address string, chain domain.Chain) (*store.QuotaInfo, error)

GetQuotaInfo mocks base method.

func (*MockCoreExecutor) GetTezosTokenCIDsByAccountWithinBlockRange added in v0.4.0 

func (m *MockCoreExecutor) GetTezosTokenCIDsByAccountWithinBlockRange(ctx context.Context, address string, fromBlock, toBlock uint64) ([]domain.TokenWithBlock, error)

GetTezosTokenCIDsByAccountWithinBlockRange mocks base method.

func (*MockCoreExecutor) GetWebhookClientByID added in v0.5.0 

func (m *MockCoreExecutor) GetWebhookClientByID(ctx context.Context, clientID string) (*schema.WebhookClient, error)

GetWebhookClientByID mocks base method.

func (*MockCoreExecutor) IncrementTokensIndexed added in v0.5.0 

func (m *MockCoreExecutor) IncrementTokensIndexed(ctx context.Context, address string, chain domain.Chain, count int) error

IncrementTokensIndexed mocks base method.

func (*MockCoreExecutor) IndexTokenWithFullProvenancesByTokenCID added in v0.4.0 

func (m *MockCoreExecutor) IndexTokenWithFullProvenancesByTokenCID(ctx context.Context, tokenCID domain.TokenCID) error

IndexTokenWithFullProvenancesByTokenCID mocks base method.

func (*MockCoreExecutor) IndexTokenWithMinimalProvenancesByBlockchainEvent added in v0.4.0 

func (m *MockCoreExecutor) IndexTokenWithMinimalProvenancesByBlockchainEvent(ctx context.Context, event *domain.BlockchainEvent) error

IndexTokenWithMinimalProvenancesByBlockchainEvent mocks base method.

func (*MockCoreExecutor) IndexTokenWithMinimalProvenancesByTokenCID added in v0.4.0 

func (m *MockCoreExecutor) IndexTokenWithMinimalProvenancesByTokenCID(ctx context.Context, tokenCID domain.TokenCID, address *string) error

IndexTokenWithMinimalProvenancesByTokenCID mocks base method.

func (*MockCoreExecutor) ResolveTokenMetadata added in v0.5.0 

func (m *MockCoreExecutor) ResolveTokenMetadata(ctx context.Context, tokenCID domain.TokenCID) (*metadata.NormalizedMetadata, error)

ResolveTokenMetadata mocks base method.

func (*MockCoreExecutor) UpdateIndexingBlockRangeForAddress added in v0.4.0 

func (m *MockCoreExecutor) UpdateIndexingBlockRangeForAddress(ctx context.Context, address string, chainID domain.Chain, minBlock, maxBlock uint64) error

UpdateIndexingBlockRangeForAddress mocks base method.

func (*MockCoreExecutor) UpdateIndexingJobProgress added in v0.5.0 

func (m *MockCoreExecutor) UpdateIndexingJobProgress(ctx context.Context, jobID int64, tokensProcessed int, minBlock, maxBlock uint64) error

UpdateIndexingJobProgress mocks base method.

func (*MockCoreExecutor) UpdateIndexingJobStatus added in v0.5.0 

func (m *MockCoreExecutor) UpdateIndexingJobStatus(ctx context.Context, jobID int64, status schema.IndexingJobStatus, timestamp time.Time) error

UpdateIndexingJobStatus mocks base method.

func (*MockCoreExecutor) UpdateTokenBurn added in v0.4.0 

func (m *MockCoreExecutor) UpdateTokenBurn(ctx context.Context, event *domain.BlockchainEvent) error

UpdateTokenBurn mocks base method.

func (*MockCoreExecutor) UpdateTokenTransfer added in v0.4.0 

func (m *MockCoreExecutor) UpdateTokenTransfer(ctx context.Context, event *domain.BlockchainEvent) error

UpdateTokenTransfer mocks base method.

type MockCoreExecutorMockRecorder added in v0.4.0 

type MockCoreExecutorMockRecorder struct {
	// contains filtered or unexported fields
}

MockCoreExecutorMockRecorder is the mock recorder for MockCoreExecutor.

func (*MockCoreExecutorMockRecorder) CheckMediaURLsHealthAndUpdateViewability added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) CheckMediaURLsHealthAndUpdateViewability(ctx, tokenCID, mediaURLs any) *gomock.Call

CheckMediaURLsHealthAndUpdateViewability indicates an expected call of CheckMediaURLsHealthAndUpdateViewability.

func (*MockCoreExecutorMockRecorder) CheckTokenExists added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) CheckTokenExists(ctx, tokenCID any) *gomock.Call

CheckTokenExists indicates an expected call of CheckTokenExists.

func (*MockCoreExecutorMockRecorder) CreateIndexingJob added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) CreateIndexingJob(ctx, address, chain, jobID any) *gomock.Call

CreateIndexingJob indicates an expected call of CreateIndexingJob.

func (*MockCoreExecutorMockRecorder) CreateMetadataUpdate added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) CreateMetadataUpdate(ctx, event any) *gomock.Call

CreateMetadataUpdate indicates an expected call of CreateMetadataUpdate.

func (*MockCoreExecutorMockRecorder) CreateTokenMint added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) CreateTokenMint(ctx, event any) *gomock.Call

CreateTokenMint indicates an expected call of CreateTokenMint.

func (*MockCoreExecutorMockRecorder) CreateWebhookDeliveryRecord added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) CreateWebhookDeliveryRecord(ctx, delivery, event any) *gomock.Call

CreateWebhookDeliveryRecord indicates an expected call of CreateWebhookDeliveryRecord.

func (*MockCoreExecutorMockRecorder) DeliverWebhookHTTP added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) DeliverWebhookHTTP(ctx, client, event, deliveryID any) *gomock.Call

DeliverWebhookHTTP indicates an expected call of DeliverWebhookHTTP.

func (*MockCoreExecutorMockRecorder) EnhanceTokenMetadata added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) EnhanceTokenMetadata(ctx, tokenCID, normalizedMetadata any) *gomock.Call

EnhanceTokenMetadata indicates an expected call of EnhanceTokenMetadata.

func (*MockCoreExecutorMockRecorder) EnsureWatchedAddressExists added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) EnsureWatchedAddressExists(ctx, address, chain, dailyQuota any) *gomock.Call

EnsureWatchedAddressExists indicates an expected call of EnsureWatchedAddressExists.

func (*MockCoreExecutorMockRecorder) GetActiveWebhookClientsByEventType added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) GetActiveWebhookClientsByEventType(ctx, eventType any) *gomock.Call

GetActiveWebhookClientsByEventType indicates an expected call of GetActiveWebhookClientsByEventType.

func (*MockCoreExecutorMockRecorder) GetEthereumTokenCIDsByOwnerWithinBlockRange added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) GetEthereumTokenCIDsByOwnerWithinBlockRange(ctx, address, requestedFromBlock, requestedToBlock, limit, order any) *gomock.Call

GetEthereumTokenCIDsByOwnerWithinBlockRange indicates an expected call of GetEthereumTokenCIDsByOwnerWithinBlockRange.

func (*MockCoreExecutorMockRecorder) GetIndexingBlockRangeForAddress added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) GetIndexingBlockRangeForAddress(ctx, address, chainID any) *gomock.Call

GetIndexingBlockRangeForAddress indicates an expected call of GetIndexingBlockRangeForAddress.

func (*MockCoreExecutorMockRecorder) GetLatestEthereumBlock added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) GetLatestEthereumBlock(ctx any) *gomock.Call

GetLatestEthereumBlock indicates an expected call of GetLatestEthereumBlock.

func (*MockCoreExecutorMockRecorder) GetLatestTezosBlock added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) GetLatestTezosBlock(ctx any) *gomock.Call

GetLatestTezosBlock indicates an expected call of GetLatestTezosBlock.

func (*MockCoreExecutorMockRecorder) GetQuotaInfo added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) GetQuotaInfo(ctx, address, chain any) *gomock.Call

GetQuotaInfo indicates an expected call of GetQuotaInfo.

func (*MockCoreExecutorMockRecorder) GetTezosTokenCIDsByAccountWithinBlockRange added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) GetTezosTokenCIDsByAccountWithinBlockRange(ctx, address, fromBlock, toBlock any) *gomock.Call

GetTezosTokenCIDsByAccountWithinBlockRange indicates an expected call of GetTezosTokenCIDsByAccountWithinBlockRange.

func (*MockCoreExecutorMockRecorder) GetWebhookClientByID added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) GetWebhookClientByID(ctx, clientID any) *gomock.Call

GetWebhookClientByID indicates an expected call of GetWebhookClientByID.

func (*MockCoreExecutorMockRecorder) IncrementTokensIndexed added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) IncrementTokensIndexed(ctx, address, chain, count any) *gomock.Call

IncrementTokensIndexed indicates an expected call of IncrementTokensIndexed.

func (*MockCoreExecutorMockRecorder) IndexTokenWithFullProvenancesByTokenCID added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) IndexTokenWithFullProvenancesByTokenCID(ctx, tokenCID any) *gomock.Call

IndexTokenWithFullProvenancesByTokenCID indicates an expected call of IndexTokenWithFullProvenancesByTokenCID.

func (*MockCoreExecutorMockRecorder) IndexTokenWithMinimalProvenancesByBlockchainEvent added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) IndexTokenWithMinimalProvenancesByBlockchainEvent(ctx, event any) *gomock.Call

IndexTokenWithMinimalProvenancesByBlockchainEvent indicates an expected call of IndexTokenWithMinimalProvenancesByBlockchainEvent.

func (*MockCoreExecutorMockRecorder) IndexTokenWithMinimalProvenancesByTokenCID added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) IndexTokenWithMinimalProvenancesByTokenCID(ctx, tokenCID, address any) *gomock.Call

IndexTokenWithMinimalProvenancesByTokenCID indicates an expected call of IndexTokenWithMinimalProvenancesByTokenCID.

func (*MockCoreExecutorMockRecorder) ResolveTokenMetadata added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) ResolveTokenMetadata(ctx, tokenCID any) *gomock.Call

ResolveTokenMetadata indicates an expected call of ResolveTokenMetadata.

func (*MockCoreExecutorMockRecorder) UpdateIndexingBlockRangeForAddress added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) UpdateIndexingBlockRangeForAddress(ctx, address, chainID, minBlock, maxBlock any) *gomock.Call

UpdateIndexingBlockRangeForAddress indicates an expected call of UpdateIndexingBlockRangeForAddress.

func (*MockCoreExecutorMockRecorder) UpdateIndexingJobProgress added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) UpdateIndexingJobProgress(ctx, jobID, tokensProcessed, minBlock, maxBlock any) *gomock.Call

UpdateIndexingJobProgress indicates an expected call of UpdateIndexingJobProgress.

func (*MockCoreExecutorMockRecorder) UpdateIndexingJobStatus added in v0.5.0 

func (mr *MockCoreExecutorMockRecorder) UpdateIndexingJobStatus(ctx, jobID, status, timestamp any) *gomock.Call

UpdateIndexingJobStatus indicates an expected call of UpdateIndexingJobStatus.

func (*MockCoreExecutorMockRecorder) UpdateTokenBurn added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) UpdateTokenBurn(ctx, event any) *gomock.Call

UpdateTokenBurn indicates an expected call of UpdateTokenBurn.

func (*MockCoreExecutorMockRecorder) UpdateTokenTransfer added in v0.4.0 

func (mr *MockCoreExecutorMockRecorder) UpdateTokenTransfer(ctx, event any) *gomock.Call

UpdateTokenTransfer indicates an expected call of UpdateTokenTransfer.

type MockCoreWorkflows added in v0.5.0 

type MockCoreWorkflows struct {
	// contains filtered or unexported fields
}

MockCoreWorkflows is a mock of CoreWorkflows interface.

func NewMockCoreWorkflows added in v0.5.0 

func NewMockCoreWorkflows(ctrl *gomock.Controller) *MockCoreWorkflows

NewMockCoreWorkflows creates a new mock instance.

func (*MockCoreWorkflows) DeliverWebhook added in v0.5.0 

func (m *MockCoreWorkflows) DeliverWebhook(ctx context.Context, clientID string, event webhook.WebhookEvent) error

DeliverWebhook mocks base method.

func (*MockCoreWorkflows) EXPECT added in v0.5.0 

func (m *MockCoreWorkflows) EXPECT() *MockCoreWorkflowsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCoreWorkflows) IndexEthereumTokenOwner added in v0.5.0 

func (m *MockCoreWorkflows) IndexEthereumTokenOwner(ctx context.Context, address string, jobID *int64) error

IndexEthereumTokenOwner mocks base method.

func (*MockCoreWorkflows) IndexMetadataUpdate added in v0.5.0 

func (m *MockCoreWorkflows) IndexMetadataUpdate(ctx context.Context, event *domain.BlockchainEvent) error

IndexMetadataUpdate mocks base method.

func (*MockCoreWorkflows) IndexMultipleTokensMetadata added in v0.5.0 

func (m *MockCoreWorkflows) IndexMultipleTokensMetadata(ctx context.Context, tokenCIDs []domain.TokenCID) error

IndexMultipleTokensMetadata mocks base method.

func (*MockCoreWorkflows) IndexTezosTokenOwner added in v0.5.0 

func (m *MockCoreWorkflows) IndexTezosTokenOwner(ctx context.Context, address string, jobID *int64) error

IndexTezosTokenOwner mocks base method.

func (*MockCoreWorkflows) IndexToken added in v0.5.0 

func (m *MockCoreWorkflows) IndexToken(ctx context.Context, tokenCID domain.TokenCID, address *string) error

IndexToken mocks base method.

func (*MockCoreWorkflows) IndexTokenBurn added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenBurn(ctx context.Context, event *domain.BlockchainEvent) error

IndexTokenBurn mocks base method.

func (*MockCoreWorkflows) IndexTokenFromEvent added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenFromEvent(ctx context.Context, event *domain.BlockchainEvent) error

IndexTokenFromEvent mocks base method.

func (*MockCoreWorkflows) IndexTokenMetadata added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenMetadata(ctx context.Context, tokenCID domain.TokenCID, address *string) error

IndexTokenMetadata mocks base method.

func (*MockCoreWorkflows) IndexTokenMint added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenMint(ctx context.Context, event *domain.BlockchainEvent) error

IndexTokenMint mocks base method.

func (*MockCoreWorkflows) IndexTokenOwner added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenOwner(ctx context.Context, address string) error

IndexTokenOwner mocks base method.

func (*MockCoreWorkflows) IndexTokenProvenances added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenProvenances(ctx context.Context, tokenCID domain.TokenCID, address *string) error

IndexTokenProvenances mocks base method.

func (*MockCoreWorkflows) IndexTokenTransfer added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokenTransfer(ctx context.Context, event *domain.BlockchainEvent) error

IndexTokenTransfer mocks base method.

func (*MockCoreWorkflows) IndexTokens added in v0.5.0 

func (m *MockCoreWorkflows) IndexTokens(ctx context.Context, tokenCIDs []domain.TokenCID, address *string) error

IndexTokens mocks base method.

func (*MockCoreWorkflows) NotifyWebhookClients added in v0.5.0 

func (m *MockCoreWorkflows) NotifyWebhookClients(ctx context.Context, event webhook.WebhookEvent) error

NotifyWebhookClients mocks base method.

type MockCoreWorkflowsMockRecorder added in v0.5.0 

type MockCoreWorkflowsMockRecorder struct {
	// contains filtered or unexported fields
}

MockCoreWorkflowsMockRecorder is the mock recorder for MockCoreWorkflows.

func (*MockCoreWorkflowsMockRecorder) DeliverWebhook added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) DeliverWebhook(ctx, clientID, event any) *gomock.Call

DeliverWebhook indicates an expected call of DeliverWebhook.

func (*MockCoreWorkflowsMockRecorder) IndexEthereumTokenOwner added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexEthereumTokenOwner(ctx, address, jobID any) *gomock.Call

IndexEthereumTokenOwner indicates an expected call of IndexEthereumTokenOwner.

func (*MockCoreWorkflowsMockRecorder) IndexMetadataUpdate added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexMetadataUpdate(ctx, event any) *gomock.Call

IndexMetadataUpdate indicates an expected call of IndexMetadataUpdate.

func (*MockCoreWorkflowsMockRecorder) IndexMultipleTokensMetadata added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexMultipleTokensMetadata(ctx, tokenCIDs any) *gomock.Call

IndexMultipleTokensMetadata indicates an expected call of IndexMultipleTokensMetadata.

func (*MockCoreWorkflowsMockRecorder) IndexTezosTokenOwner added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTezosTokenOwner(ctx, address, jobID any) *gomock.Call

IndexTezosTokenOwner indicates an expected call of IndexTezosTokenOwner.

func (*MockCoreWorkflowsMockRecorder) IndexToken added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexToken(ctx, tokenCID, address any) *gomock.Call

IndexToken indicates an expected call of IndexToken.

func (*MockCoreWorkflowsMockRecorder) IndexTokenBurn added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenBurn(ctx, event any) *gomock.Call

IndexTokenBurn indicates an expected call of IndexTokenBurn.

func (*MockCoreWorkflowsMockRecorder) IndexTokenFromEvent added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenFromEvent(ctx, event any) *gomock.Call

IndexTokenFromEvent indicates an expected call of IndexTokenFromEvent.

func (*MockCoreWorkflowsMockRecorder) IndexTokenMetadata added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenMetadata(ctx, tokenCID, address any) *gomock.Call

IndexTokenMetadata indicates an expected call of IndexTokenMetadata.

func (*MockCoreWorkflowsMockRecorder) IndexTokenMint added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenMint(ctx, event any) *gomock.Call

IndexTokenMint indicates an expected call of IndexTokenMint.

func (*MockCoreWorkflowsMockRecorder) IndexTokenOwner added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenOwner(ctx, address any) *gomock.Call

IndexTokenOwner indicates an expected call of IndexTokenOwner.

func (*MockCoreWorkflowsMockRecorder) IndexTokenProvenances added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenProvenances(ctx, tokenCID, address any) *gomock.Call

IndexTokenProvenances indicates an expected call of IndexTokenProvenances.

func (*MockCoreWorkflowsMockRecorder) IndexTokenTransfer added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokenTransfer(ctx, event any) *gomock.Call

IndexTokenTransfer indicates an expected call of IndexTokenTransfer.

func (*MockCoreWorkflowsMockRecorder) IndexTokens added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) IndexTokens(ctx, tokenCIDs, address any) *gomock.Call

IndexTokens indicates an expected call of IndexTokens.

func (*MockCoreWorkflowsMockRecorder) NotifyWebhookClients added in v0.5.0 

func (mr *MockCoreWorkflowsMockRecorder) NotifyWebhookClients(ctx, event any) *gomock.Call

NotifyWebhookClients indicates an expected call of NotifyWebhookClients.

type MockDataURIChecker added in v0.5.0 

type MockDataURIChecker struct {
	// contains filtered or unexported fields
}

MockDataURIChecker is a mock of DataURIChecker interface.

func NewMockDataURIChecker added in v0.5.0 

func NewMockDataURIChecker(ctrl *gomock.Controller) *MockDataURIChecker

NewMockDataURIChecker creates a new mock instance.

func (*MockDataURIChecker) Check added in v0.5.0 

func (m *MockDataURIChecker) Check(dataURI string) uri.DataURICheckResult

Check mocks base method.

func (*MockDataURIChecker) EXPECT added in v0.5.0 

func (m *MockDataURIChecker) EXPECT() *MockDataURICheckerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockDataURICheckerMockRecorder added in v0.5.0 

type MockDataURICheckerMockRecorder struct {
	// contains filtered or unexported fields
}

MockDataURICheckerMockRecorder is the mock recorder for MockDataURIChecker.

func (*MockDataURICheckerMockRecorder) Check added in v0.5.0 

func (mr *MockDataURICheckerMockRecorder) Check(dataURI any) *gomock.Call

Check indicates an expected call of Check.

type MockDownloader 

type MockDownloader struct {
	// contains filtered or unexported fields
}

MockDownloader is a mock of Downloader interface.

func NewMockDownloader 

func NewMockDownloader(ctrl *gomock.Controller) *MockDownloader

NewMockDownloader creates a new mock instance.

func (*MockDownloader) Download 

func (m *MockDownloader) Download(ctx context.Context, url string) (*downloader.DownloadResult, error)

Download mocks base method.

func (*MockDownloader) EXPECT 

func (m *MockDownloader) EXPECT() *MockDownloaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockDownloaderMockRecorder 

type MockDownloaderMockRecorder struct {
	// contains filtered or unexported fields
}

MockDownloaderMockRecorder is the mock recorder for MockDownloader.

func (*MockDownloaderMockRecorder) Download 

func (mr *MockDownloaderMockRecorder) Download(ctx, url any) *gomock.Call

Download indicates an expected call of Download.

type MockEthClient 

type MockEthClient struct {
	// contains filtered or unexported fields
}

MockEthClient is a mock of EthClient interface.

func NewMockEthClient 

func NewMockEthClient(ctrl *gomock.Controller) *MockEthClient

NewMockEthClient creates a new mock instance.

func (*MockEthClient) BlockByNumber 

func (m *MockEthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

BlockByNumber mocks base method.

func (*MockEthClient) CallContract 

func (m *MockEthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

CallContract mocks base method.

func (*MockEthClient) Close 

func (m *MockEthClient) Close()

Close mocks base method.

func (*MockEthClient) CodeAt 

func (m *MockEthClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

CodeAt mocks base method.

func (*MockEthClient) EXPECT 

func (m *MockEthClient) EXPECT() *MockEthClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEthClient) FilterLogs 

func (m *MockEthClient) FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)

FilterLogs mocks base method.

func (*MockEthClient) HeaderByNumber 

func (m *MockEthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

HeaderByNumber mocks base method.

func (*MockEthClient) SubscribeFilterLogs 

func (m *MockEthClient) SubscribeFilterLogs(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)

SubscribeFilterLogs mocks base method.

func (*MockEthClient) TransactionReceipt 

func (m *MockEthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

TransactionReceipt mocks base method.

func (*MockEthClient) TransactionSender 

func (m *MockEthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

TransactionSender mocks base method.

type MockEthClientDialer 

type MockEthClientDialer struct {
	// contains filtered or unexported fields
}

MockEthClientDialer is a mock of EthClientDialer interface.

func NewMockEthClientDialer 

func NewMockEthClientDialer(ctrl *gomock.Controller) *MockEthClientDialer

NewMockEthClientDialer creates a new mock instance.

func (*MockEthClientDialer) Dial 

func (m *MockEthClientDialer) Dial(ctx context.Context, rawurl string) (adapter.EthClient, error)

Dial mocks base method.

func (*MockEthClientDialer) EXPECT 

func (m *MockEthClientDialer) EXPECT() *MockEthClientDialerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockEthClientDialerMockRecorder 

type MockEthClientDialerMockRecorder struct {
	// contains filtered or unexported fields
}

MockEthClientDialerMockRecorder is the mock recorder for MockEthClientDialer.

func (*MockEthClientDialerMockRecorder) Dial 

func (mr *MockEthClientDialerMockRecorder) Dial(ctx, rawurl any) *gomock.Call

Dial indicates an expected call of Dial.

type MockEthClientMockRecorder 

type MockEthClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockEthClientMockRecorder is the mock recorder for MockEthClient.

func (*MockEthClientMockRecorder) BlockByNumber 

func (mr *MockEthClientMockRecorder) BlockByNumber(ctx, number any) *gomock.Call

BlockByNumber indicates an expected call of BlockByNumber.

func (*MockEthClientMockRecorder) CallContract 

func (mr *MockEthClientMockRecorder) CallContract(ctx, msg, blockNumber any) *gomock.Call

CallContract indicates an expected call of CallContract.

func (*MockEthClientMockRecorder) Close 

func (mr *MockEthClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockEthClientMockRecorder) CodeAt 

func (mr *MockEthClientMockRecorder) CodeAt(ctx, account, blockNumber any) *gomock.Call

CodeAt indicates an expected call of CodeAt.

func (*MockEthClientMockRecorder) FilterLogs 

func (mr *MockEthClientMockRecorder) FilterLogs(ctx, query any) *gomock.Call

FilterLogs indicates an expected call of FilterLogs.

func (*MockEthClientMockRecorder) HeaderByNumber 

func (mr *MockEthClientMockRecorder) HeaderByNumber(ctx, number any) *gomock.Call

HeaderByNumber indicates an expected call of HeaderByNumber.

func (*MockEthClientMockRecorder) SubscribeFilterLogs 

func (mr *MockEthClientMockRecorder) SubscribeFilterLogs(ctx, query, ch any) *gomock.Call

SubscribeFilterLogs indicates an expected call of SubscribeFilterLogs.

func (*MockEthClientMockRecorder) TransactionReceipt 

func (mr *MockEthClientMockRecorder) TransactionReceipt(ctx, txHash any) *gomock.Call

TransactionReceipt indicates an expected call of TransactionReceipt.

func (*MockEthClientMockRecorder) TransactionSender 

func (mr *MockEthClientMockRecorder) TransactionSender(ctx, tx, block, index any) *gomock.Call

TransactionSender indicates an expected call of TransactionSender.

type MockEthereumProviderClient 

type MockEthereumProviderClient struct {
	// contains filtered or unexported fields
}

MockEthereumProviderClient is a mock of EthereumClient interface.

func NewMockEthereumProviderClient 

func NewMockEthereumProviderClient(ctrl *gomock.Controller) *MockEthereumProviderClient

NewMockEthereumProviderClient creates a new mock instance.

func (*MockEthereumProviderClient) Close 

func (m *MockEthereumProviderClient) Close()

Close mocks base method.

func (*MockEthereumProviderClient) ERC721OwnerOf 

func (m *MockEthereumProviderClient) ERC721OwnerOf(ctx context.Context, contractAddress, tokenNumber string) (string, error)

ERC721OwnerOf mocks base method.

func (*MockEthereumProviderClient) ERC721TokenURI 

func (m *MockEthereumProviderClient) ERC721TokenURI(ctx context.Context, contractAddress, tokenNumber string) (string, error)

ERC721TokenURI mocks base method.

func (*MockEthereumProviderClient) ERC1155BalanceOf 

func (m *MockEthereumProviderClient) ERC1155BalanceOf(ctx context.Context, contractAddress, ownerAddress, tokenNumber string) (string, error)

ERC1155BalanceOf mocks base method.

func (*MockEthereumProviderClient) ERC1155BalanceOfBatch added in v0.4.0 

func (m *MockEthereumProviderClient) ERC1155BalanceOfBatch(ctx context.Context, contractAddress, tokenNumber string, addresses []string) (map[string]string, error)

ERC1155BalanceOfBatch mocks base method.

func (*MockEthereumProviderClient) ERC1155Balances 

func (m *MockEthereumProviderClient) ERC1155Balances(ctx context.Context, contractAddress, tokenNumber string) (map[string]string, error)

ERC1155Balances mocks base method.

func (*MockEthereumProviderClient) ERC1155URI 

func (m *MockEthereumProviderClient) ERC1155URI(ctx context.Context, contractAddress, tokenNumber string) (string, error)

ERC1155URI mocks base method.

func (*MockEthereumProviderClient) EXPECT 

func (m *MockEthereumProviderClient) EXPECT() *MockEthereumProviderClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEthereumProviderClient) GetContractDeployer 

func (m *MockEthereumProviderClient) GetContractDeployer(ctx context.Context, contractAddress string, minBlock uint64) (string, error)

GetContractDeployer mocks base method.

func (*MockEthereumProviderClient) GetERC1155BalanceAndEventsForOwner added in v0.4.0 

func (m *MockEthereumProviderClient) GetERC1155BalanceAndEventsForOwner(ctx context.Context, contractAddress, tokenNumber, ownerAddress string) (string, []domain.BlockchainEvent, error)

GetERC1155BalanceAndEventsForOwner mocks base method.

func (*MockEthereumProviderClient) GetLatestBlock added in v0.4.0 

func (m *MockEthereumProviderClient) GetLatestBlock(ctx context.Context) (uint64, error)

GetLatestBlock mocks base method.

func (*MockEthereumProviderClient) GetTokenCIDsByOwnerAndBlockRange 

func (m *MockEthereumProviderClient) GetTokenCIDsByOwnerAndBlockRange(ctx context.Context, ownerAddress string, requestedFromBlock, requestedToBlock uint64, limit int, order domain.BlockScanOrder, blacklist registry.BlacklistRegistry) (domain.TokenWithBlockRangeResult, error)

GetTokenCIDsByOwnerAndBlockRange mocks base method.

func (*MockEthereumProviderClient) GetTokenEvents 

func (m *MockEthereumProviderClient) GetTokenEvents(ctx context.Context, contractAddress, tokenNumber string, standard domain.ChainStandard) ([]domain.BlockchainEvent, error)

GetTokenEvents mocks base method.

func (*MockEthereumProviderClient) ParseEventLog 

func (m *MockEthereumProviderClient) ParseEventLog(ctx context.Context, vLog types.Log) (*domain.BlockchainEvent, error)

ParseEventLog mocks base method.

func (*MockEthereumProviderClient) SubscribeFilterLogs 

func (m *MockEthereumProviderClient) SubscribeFilterLogs(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)

SubscribeFilterLogs mocks base method.

func (*MockEthereumProviderClient) TokenExists 

func (m *MockEthereumProviderClient) TokenExists(ctx context.Context, contractAddress, tokenNumber string, standard domain.ChainStandard) (bool, error)

TokenExists mocks base method.

type MockEthereumProviderClientMockRecorder 

type MockEthereumProviderClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockEthereumProviderClientMockRecorder is the mock recorder for MockEthereumProviderClient.

func (*MockEthereumProviderClientMockRecorder) Close 

func (mr *MockEthereumProviderClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockEthereumProviderClientMockRecorder) ERC721OwnerOf 

func (mr *MockEthereumProviderClientMockRecorder) ERC721OwnerOf(ctx, contractAddress, tokenNumber any) *gomock.Call

ERC721OwnerOf indicates an expected call of ERC721OwnerOf.

func (*MockEthereumProviderClientMockRecorder) ERC721TokenURI 

func (mr *MockEthereumProviderClientMockRecorder) ERC721TokenURI(ctx, contractAddress, tokenNumber any) *gomock.Call

ERC721TokenURI indicates an expected call of ERC721TokenURI.

func (*MockEthereumProviderClientMockRecorder) ERC1155BalanceOf 

func (mr *MockEthereumProviderClientMockRecorder) ERC1155BalanceOf(ctx, contractAddress, ownerAddress, tokenNumber any) *gomock.Call

ERC1155BalanceOf indicates an expected call of ERC1155BalanceOf.

func (*MockEthereumProviderClientMockRecorder) ERC1155BalanceOfBatch added in v0.4.0 

func (mr *MockEthereumProviderClientMockRecorder) ERC1155BalanceOfBatch(ctx, contractAddress, tokenNumber, addresses any) *gomock.Call

ERC1155BalanceOfBatch indicates an expected call of ERC1155BalanceOfBatch.

func (*MockEthereumProviderClientMockRecorder) ERC1155Balances 

func (mr *MockEthereumProviderClientMockRecorder) ERC1155Balances(ctx, contractAddress, tokenNumber any) *gomock.Call

ERC1155Balances indicates an expected call of ERC1155Balances.

func (*MockEthereumProviderClientMockRecorder) ERC1155URI 

func (mr *MockEthereumProviderClientMockRecorder) ERC1155URI(ctx, contractAddress, tokenNumber any) *gomock.Call

ERC1155URI indicates an expected call of ERC1155URI.

func (*MockEthereumProviderClientMockRecorder) GetContractDeployer 

func (mr *MockEthereumProviderClientMockRecorder) GetContractDeployer(ctx, contractAddress, minBlock any) *gomock.Call

GetContractDeployer indicates an expected call of GetContractDeployer.

func (*MockEthereumProviderClientMockRecorder) GetERC1155BalanceAndEventsForOwner added in v0.4.0 

func (mr *MockEthereumProviderClientMockRecorder) GetERC1155BalanceAndEventsForOwner(ctx, contractAddress, tokenNumber, ownerAddress any) *gomock.Call

GetERC1155BalanceAndEventsForOwner indicates an expected call of GetERC1155BalanceAndEventsForOwner.

func (*MockEthereumProviderClientMockRecorder) GetLatestBlock added in v0.4.0 

func (mr *MockEthereumProviderClientMockRecorder) GetLatestBlock(ctx any) *gomock.Call

GetLatestBlock indicates an expected call of GetLatestBlock.

func (*MockEthereumProviderClientMockRecorder) GetTokenCIDsByOwnerAndBlockRange 

func (mr *MockEthereumProviderClientMockRecorder) GetTokenCIDsByOwnerAndBlockRange(ctx, ownerAddress, requestedFromBlock, requestedToBlock, limit, order, blacklist any) *gomock.Call

GetTokenCIDsByOwnerAndBlockRange indicates an expected call of GetTokenCIDsByOwnerAndBlockRange.

func (*MockEthereumProviderClientMockRecorder) GetTokenEvents 

func (mr *MockEthereumProviderClientMockRecorder) GetTokenEvents(ctx, contractAddress, tokenNumber, standard any) *gomock.Call

GetTokenEvents indicates an expected call of GetTokenEvents.

func (*MockEthereumProviderClientMockRecorder) ParseEventLog 

func (mr *MockEthereumProviderClientMockRecorder) ParseEventLog(ctx, vLog any) *gomock.Call

ParseEventLog indicates an expected call of ParseEventLog.

func (*MockEthereumProviderClientMockRecorder) SubscribeFilterLogs 

func (mr *MockEthereumProviderClientMockRecorder) SubscribeFilterLogs(ctx, query, ch any) *gomock.Call

SubscribeFilterLogs indicates an expected call of SubscribeFilterLogs.

func (*MockEthereumProviderClientMockRecorder) TokenExists 

func (mr *MockEthereumProviderClientMockRecorder) TokenExists(ctx, contractAddress, tokenNumber, standard any) *gomock.Call

TokenExists indicates an expected call of TokenExists.

type MockFeralFileClient added in v0.2.0 

type MockFeralFileClient struct {
	// contains filtered or unexported fields
}

MockFeralFileClient is a mock of Client interface.

func NewMockFeralFileClient added in v0.2.0 

func NewMockFeralFileClient(ctrl *gomock.Controller) *MockFeralFileClient

NewMockFeralFileClient creates a new mock instance.

func (*MockFeralFileClient) EXPECT added in v0.2.0 

func (m *MockFeralFileClient) EXPECT() *MockFeralFileClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFeralFileClient) GetArtwork added in v0.2.0 

func (m *MockFeralFileClient) GetArtwork(ctx context.Context, tokenID string) (*feralfile.Artwork, error)

GetArtwork mocks base method.

type MockFeralFileClientMockRecorder added in v0.2.0 

type MockFeralFileClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockFeralFileClientMockRecorder is the mock recorder for MockFeralFileClient.

func (*MockFeralFileClientMockRecorder) GetArtwork added in v0.2.0 

func (mr *MockFeralFileClientMockRecorder) GetArtwork(ctx, tokenID any) *gomock.Call

GetArtwork indicates an expected call of GetArtwork.

type MockFileSystem 

type MockFileSystem struct {
	// contains filtered or unexported fields
}

MockFileSystem is a mock of FileSystem interface.

func NewMockFileSystem 

func NewMockFileSystem(ctrl *gomock.Controller) *MockFileSystem

NewMockFileSystem creates a new mock instance.

func (*MockFileSystem) Close added in v0.5.0 

func (m *MockFileSystem) Close(file *os.File) error

Close mocks base method.

func (*MockFileSystem) Create 

func (m *MockFileSystem) Create(name string) (*os.File, error)

Create mocks base method.

func (*MockFileSystem) CreateTemp added in v0.5.0 

func (m *MockFileSystem) CreateTemp(dir, pattern string) (*os.File, error)

CreateTemp mocks base method.

func (*MockFileSystem) EXPECT 

func (m *MockFileSystem) EXPECT() *MockFileSystemMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFileSystem) ReadFile 

func (m *MockFileSystem) ReadFile(filePath string) ([]byte, error)

ReadFile mocks base method.

func (*MockFileSystem) Remove 

func (m *MockFileSystem) Remove(name string) error

Remove mocks base method.

func (*MockFileSystem) TempDir 

func (m *MockFileSystem) TempDir() string

TempDir mocks base method.

func (*MockFileSystem) WriteFile added in v0.5.0 

func (m *MockFileSystem) WriteFile(file *os.File, data []byte) (int, error)

WriteFile mocks base method.

type MockFileSystemMockRecorder 

type MockFileSystemMockRecorder struct {
	// contains filtered or unexported fields
}

MockFileSystemMockRecorder is the mock recorder for MockFileSystem.

func (*MockFileSystemMockRecorder) Close added in v0.5.0 

func (mr *MockFileSystemMockRecorder) Close(file any) *gomock.Call

Close indicates an expected call of Close.

func (*MockFileSystemMockRecorder) Create 

func (mr *MockFileSystemMockRecorder) Create(name any) *gomock.Call

Create indicates an expected call of Create.

func (*MockFileSystemMockRecorder) CreateTemp added in v0.5.0 

func (mr *MockFileSystemMockRecorder) CreateTemp(dir, pattern any) *gomock.Call

CreateTemp indicates an expected call of CreateTemp.

func (*MockFileSystemMockRecorder) ReadFile 

func (mr *MockFileSystemMockRecorder) ReadFile(filePath any) *gomock.Call

ReadFile indicates an expected call of ReadFile.

func (*MockFileSystemMockRecorder) Remove 

func (mr *MockFileSystemMockRecorder) Remove(name any) *gomock.Call

Remove indicates an expected call of Remove.

func (*MockFileSystemMockRecorder) TempDir 

func (mr *MockFileSystemMockRecorder) TempDir() *gomock.Call

TempDir indicates an expected call of TempDir.

func (*MockFileSystemMockRecorder) WriteFile added in v0.5.0 

func (mr *MockFileSystemMockRecorder) WriteFile(file, data any) *gomock.Call

WriteFile indicates an expected call of WriteFile.

type MockHTTPClient 

type MockHTTPClient struct {
	// contains filtered or unexported fields
}

MockHTTPClient is a mock of HTTPClient interface.

func NewMockHTTPClient 

func NewMockHTTPClient(ctrl *gomock.Controller) *MockHTTPClient

NewMockHTTPClient creates a new mock instance.

func (*MockHTTPClient) EXPECT 

func (m *MockHTTPClient) EXPECT() *MockHTTPClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockHTTPClient) GetAndUnmarshal added in v0.5.0 

func (m *MockHTTPClient) GetAndUnmarshal(ctx context.Context, url string, result any) error

GetAndUnmarshal mocks base method.

func (*MockHTTPClient) GetBytes added in v0.5.0 

func (m *MockHTTPClient) GetBytes(ctx context.Context, url string, headers map[string]string) ([]byte, error)

GetBytes mocks base method.

func (*MockHTTPClient) GetPartialBytes added in v0.5.0 

func (m *MockHTTPClient) GetPartialBytes(ctx context.Context, url string, maxBytes int) ([]byte, error)

GetPartialBytes mocks base method.

func (*MockHTTPClient) GetPartialBytesNoRetry added in v0.5.0 

func (m *MockHTTPClient) GetPartialBytesNoRetry(ctx context.Context, url string, maxBytes int) ([]byte, error)

GetPartialBytesNoRetry mocks base method.

func (*MockHTTPClient) GetResponse added in v0.5.0 

func (m *MockHTTPClient) GetResponse(ctx context.Context, url string, headers map[string]string) (*http.Response, error)

GetResponse mocks base method.

func (*MockHTTPClient) GetResponseNoRetry added in v0.5.0 

func (m *MockHTTPClient) GetResponseNoRetry(ctx context.Context, url string, headers map[string]string) (*http.Response, error)

GetResponseNoRetry mocks base method.

func (*MockHTTPClient) Head 

func (m *MockHTTPClient) Head(ctx context.Context, url string) (*http.Response, error)

Head mocks base method.

func (*MockHTTPClient) HeadNoRetry added in v0.5.0 

func (m *MockHTTPClient) HeadNoRetry(ctx context.Context, url string) (*http.Response, error)

HeadNoRetry mocks base method.

func (*MockHTTPClient) PostBytes added in v0.5.0 

func (m *MockHTTPClient) PostBytes(ctx context.Context, url string, headers map[string]string, body io.Reader) ([]byte, error)

PostBytes mocks base method.

func (*MockHTTPClient) PostNoRetry added in v0.5.0 

func (m *MockHTTPClient) PostNoRetry(ctx context.Context, url string, headers map[string]string, body io.Reader) (*http.Response, error)

PostNoRetry mocks base method.

type MockHTTPClientMockRecorder 

type MockHTTPClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockHTTPClientMockRecorder is the mock recorder for MockHTTPClient.

func (*MockHTTPClientMockRecorder) GetAndUnmarshal added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetAndUnmarshal(ctx, url, result any) *gomock.Call

GetAndUnmarshal indicates an expected call of GetAndUnmarshal.

func (*MockHTTPClientMockRecorder) GetBytes added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetBytes(ctx, url, headers any) *gomock.Call

GetBytes indicates an expected call of GetBytes.

func (*MockHTTPClientMockRecorder) GetPartialBytes added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetPartialBytes(ctx, url, maxBytes any) *gomock.Call

GetPartialBytes indicates an expected call of GetPartialBytes.

func (*MockHTTPClientMockRecorder) GetPartialBytesNoRetry added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetPartialBytesNoRetry(ctx, url, maxBytes any) *gomock.Call

GetPartialBytesNoRetry indicates an expected call of GetPartialBytesNoRetry.

func (*MockHTTPClientMockRecorder) GetResponse added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetResponse(ctx, url, headers any) *gomock.Call

GetResponse indicates an expected call of GetResponse.

func (*MockHTTPClientMockRecorder) GetResponseNoRetry added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) GetResponseNoRetry(ctx, url, headers any) *gomock.Call

GetResponseNoRetry indicates an expected call of GetResponseNoRetry.

func (*MockHTTPClientMockRecorder) Head 

func (mr *MockHTTPClientMockRecorder) Head(ctx, url any) *gomock.Call

Head indicates an expected call of Head.

func (*MockHTTPClientMockRecorder) HeadNoRetry added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) HeadNoRetry(ctx, url any) *gomock.Call

HeadNoRetry indicates an expected call of HeadNoRetry.

func (*MockHTTPClientMockRecorder) PostBytes added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) PostBytes(ctx, url, headers, body any) *gomock.Call

PostBytes indicates an expected call of PostBytes.

func (*MockHTTPClientMockRecorder) PostNoRetry added in v0.5.0 

func (mr *MockHTTPClientMockRecorder) PostNoRetry(ctx, url, headers, body any) *gomock.Call

PostNoRetry indicates an expected call of PostNoRetry.

type MockIO added in v0.4.0 

type MockIO struct {
	// contains filtered or unexported fields
}

MockIO is a mock of IO interface.

func NewMockIO added in v0.4.0 

func NewMockIO(ctrl *gomock.Controller) *MockIO

NewMockIO creates a new mock instance.

func (*MockIO) Discard added in v0.5.0 

func (m *MockIO) Discard(r io.Reader) error

Discard mocks base method.

func (*MockIO) EXPECT added in v0.4.0 

func (m *MockIO) EXPECT() *MockIOMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIO) ReadAll added in v0.4.0 

func (m *MockIO) ReadAll(r io.Reader) ([]byte, error)

ReadAll mocks base method.

type MockIOMockRecorder added in v0.4.0 

type MockIOMockRecorder struct {
	// contains filtered or unexported fields
}

MockIOMockRecorder is the mock recorder for MockIO.

func (*MockIOMockRecorder) Discard added in v0.5.0 

func (mr *MockIOMockRecorder) Discard(r any) *gomock.Call

Discard indicates an expected call of Discard.

func (*MockIOMockRecorder) ReadAll added in v0.4.0 

func (mr *MockIOMockRecorder) ReadAll(r any) *gomock.Call

ReadAll indicates an expected call of ReadAll.

type MockImageEncoder added in v0.4.0 

type MockImageEncoder struct {
	// contains filtered or unexported fields
}

MockImageEncoder is a mock of ImageEncoder interface.

func NewMockImageEncoder added in v0.4.0 

func NewMockImageEncoder(ctrl *gomock.Controller) *MockImageEncoder

NewMockImageEncoder creates a new mock instance.

func (*MockImageEncoder) EXPECT added in v0.4.0 

func (m *MockImageEncoder) EXPECT() *MockImageEncoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockImageEncoder) EncodeJPEG added in v0.4.0 

func (m *MockImageEncoder) EncodeJPEG(w io.Writer, img image.Image, quality int) error

EncodeJPEG mocks base method.

func (*MockImageEncoder) EncodePNG added in v0.4.0 

func (m *MockImageEncoder) EncodePNG(w io.Writer, img image.Image) error

EncodePNG mocks base method.

type MockImageEncoderMockRecorder added in v0.4.0 

type MockImageEncoderMockRecorder struct {
	// contains filtered or unexported fields
}

MockImageEncoderMockRecorder is the mock recorder for MockImageEncoder.

func (*MockImageEncoderMockRecorder) EncodeJPEG added in v0.4.0 

func (mr *MockImageEncoderMockRecorder) EncodeJPEG(w, img, quality any) *gomock.Call

EncodeJPEG indicates an expected call of EncodeJPEG.

func (*MockImageEncoderMockRecorder) EncodePNG added in v0.4.0 

func (mr *MockImageEncoderMockRecorder) EncodePNG(w, img any) *gomock.Call

EncodePNG indicates an expected call of EncodePNG.

type MockIngestionRunner added in v0.5.0 

type MockIngestionRunner struct {
	// contains filtered or unexported fields
}

MockIngestionRunner is a mock of Runner interface.

func NewMockIngestionRunner added in v0.5.0 

func NewMockIngestionRunner(ctrl *gomock.Controller) *MockIngestionRunner

NewMockIngestionRunner creates a new mock instance.

func (*MockIngestionRunner) Close added in v0.5.0 

func (m *MockIngestionRunner) Close() error

Close mocks base method.

func (*MockIngestionRunner) EXPECT added in v0.5.0 

func (m *MockIngestionRunner) EXPECT() *MockIngestionRunnerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIngestionRunner) Run added in v0.5.0 

func (m *MockIngestionRunner) Run(ctx context.Context) error

Run mocks base method.

type MockIngestionRunnerMockRecorder added in v0.5.0 

type MockIngestionRunnerMockRecorder struct {
	// contains filtered or unexported fields
}

MockIngestionRunnerMockRecorder is the mock recorder for MockIngestionRunner.

func (*MockIngestionRunnerMockRecorder) Close added in v0.5.0 

func (mr *MockIngestionRunnerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockIngestionRunnerMockRecorder) Run added in v0.5.0 

func (mr *MockIngestionRunnerMockRecorder) Run(ctx any) *gomock.Call

Run indicates an expected call of Run.

type MockJCS 

type MockJCS struct {
	// contains filtered or unexported fields
}

MockJCS is a mock of JCS interface.

func NewMockJCS 

func NewMockJCS(ctrl *gomock.Controller) *MockJCS

NewMockJCS creates a new mock instance.

func (*MockJCS) EXPECT 

func (m *MockJCS) EXPECT() *MockJCSMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJCS) Transform 

func (m *MockJCS) Transform(data []byte) ([]byte, error)

Transform mocks base method.

type MockJCSMockRecorder 

type MockJCSMockRecorder struct {
	// contains filtered or unexported fields
}

MockJCSMockRecorder is the mock recorder for MockJCS.

func (*MockJCSMockRecorder) Transform 

func (mr *MockJCSMockRecorder) Transform(data any) *gomock.Call

Transform indicates an expected call of Transform.

type MockJSON 

type MockJSON struct {
	// contains filtered or unexported fields
}

MockJSON is a mock of JSON interface.

func NewMockJSON 

func NewMockJSON(ctrl *gomock.Controller) *MockJSON

NewMockJSON creates a new mock instance.

func (*MockJSON) EXPECT 

func (m *MockJSON) EXPECT() *MockJSONMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJSON) Marshal 

func (m *MockJSON) Marshal(v any) ([]byte, error)

Marshal mocks base method.

func (*MockJSON) Unmarshal 

func (m *MockJSON) Unmarshal(data []byte, v any) error

Unmarshal mocks base method.

type MockJSONMockRecorder 

type MockJSONMockRecorder struct {
	// contains filtered or unexported fields
}

MockJSONMockRecorder is the mock recorder for MockJSON.

func (*MockJSONMockRecorder) Marshal 

func (mr *MockJSONMockRecorder) Marshal(v any) *gomock.Call

Marshal indicates an expected call of Marshal.

func (*MockJSONMockRecorder) Unmarshal 

func (mr *MockJSONMockRecorder) Unmarshal(data, v any) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

type MockJobQueue added in v0.5.0 

type MockJobQueue struct {
	// contains filtered or unexported fields
}

MockJobQueue is a mock of JobQueue interface.

func NewMockJobQueue added in v0.5.0 

func NewMockJobQueue(ctrl *gomock.Controller) *MockJobQueue

NewMockJobQueue creates a new mock instance.

func (*MockJobQueue) Cancel added in v0.5.0 

func (m *MockJobQueue) Cancel(ctx context.Context, id int64) error

Cancel mocks base method.

func (*MockJobQueue) EXPECT added in v0.5.0 

func (m *MockJobQueue) EXPECT() *MockJobQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJobQueue) Enqueue added in v0.5.0 

func (m *MockJobQueue) Enqueue(ctx context.Context, opts jobs.EnqueueOptions) (*schema.Job, bool, error)

Enqueue mocks base method.

func (*MockJobQueue) GetStatus added in v0.5.0 

func (m *MockJobQueue) GetStatus(ctx context.Context, id int64) (*schema.Job, error)

GetStatus mocks base method.

type MockJobQueueMockRecorder added in v0.5.0 

type MockJobQueueMockRecorder struct {
	// contains filtered or unexported fields
}

MockJobQueueMockRecorder is the mock recorder for MockJobQueue.

func (*MockJobQueueMockRecorder) Cancel added in v0.5.0 

func (mr *MockJobQueueMockRecorder) Cancel(ctx, id any) *gomock.Call

Cancel indicates an expected call of Cancel.

func (*MockJobQueueMockRecorder) Enqueue added in v0.5.0 

func (mr *MockJobQueueMockRecorder) Enqueue(ctx, opts any) *gomock.Call

Enqueue indicates an expected call of Enqueue.

func (*MockJobQueueMockRecorder) GetStatus added in v0.5.0 

func (mr *MockJobQueueMockRecorder) GetStatus(ctx, id any) *gomock.Call

GetStatus indicates an expected call of GetStatus.

type MockLimiter added in v0.5.0 

type MockLimiter struct {
	// contains filtered or unexported fields
}

MockLimiter is a mock of Limiter interface.

func NewMockLimiter added in v0.5.0 

func NewMockLimiter(ctrl *gomock.Controller) *MockLimiter

NewMockLimiter creates a new mock instance.

func (*MockLimiter) Close added in v0.5.0 

func (m *MockLimiter) Close() error

Close mocks base method.

func (*MockLimiter) Do added in v0.5.0 

func (m *MockLimiter) Do(ctx context.Context, providerName string, fn ratelimit.Func) (any, error)

Do mocks base method.

func (*MockLimiter) EXPECT added in v0.5.0 

func (m *MockLimiter) EXPECT() *MockLimiterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockLimiterMockRecorder added in v0.5.0 

type MockLimiterMockRecorder struct {
	// contains filtered or unexported fields
}

MockLimiterMockRecorder is the mock recorder for MockLimiter.

func (*MockLimiterMockRecorder) Close added in v0.5.0 

func (mr *MockLimiterMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockLimiterMockRecorder) Do added in v0.5.0 

func (mr *MockLimiterMockRecorder) Do(ctx, providerName, fn any) *gomock.Call

Do indicates an expected call of Do.

type MockMediaExecutor added in v0.4.0 

type MockMediaExecutor struct {
	// contains filtered or unexported fields
}

MockMediaExecutor is a mock of MediaExecutor interface.

func NewMockMediaExecutor added in v0.4.0 

func NewMockMediaExecutor(ctrl *gomock.Controller) *MockMediaExecutor

NewMockMediaExecutor creates a new mock instance.

func (*MockMediaExecutor) EXPECT added in v0.4.0 

func (m *MockMediaExecutor) EXPECT() *MockMediaExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMediaExecutor) IndexMediaFile added in v0.4.0 

func (m *MockMediaExecutor) IndexMediaFile(ctx context.Context, url string) error

IndexMediaFile mocks base method.

type MockMediaExecutorMockRecorder added in v0.4.0 

type MockMediaExecutorMockRecorder struct {
	// contains filtered or unexported fields
}

MockMediaExecutorMockRecorder is the mock recorder for MockMediaExecutor.

func (*MockMediaExecutorMockRecorder) IndexMediaFile added in v0.4.0 

func (mr *MockMediaExecutorMockRecorder) IndexMediaFile(ctx, url any) *gomock.Call

IndexMediaFile indicates an expected call of IndexMediaFile.

type MockMediaProcessor added in v0.3.1 

type MockMediaProcessor struct {
	// contains filtered or unexported fields
}

MockMediaProcessor is a mock of Processor interface.

func NewMockMediaProcessor added in v0.3.1 

func NewMockMediaProcessor(ctrl *gomock.Controller) *MockMediaProcessor

NewMockMediaProcessor creates a new mock instance.

func (*MockMediaProcessor) EXPECT added in v0.3.1 

func (m *MockMediaProcessor) EXPECT() *MockMediaProcessorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMediaProcessor) Process added in v0.3.1 

func (m *MockMediaProcessor) Process(ctx context.Context, sourceURL string) error

Process mocks base method.

func (*MockMediaProcessor) Provider added in v0.3.1 

func (m *MockMediaProcessor) Provider() string

Provider mocks base method.

type MockMediaProcessorMockRecorder added in v0.3.1 

type MockMediaProcessorMockRecorder struct {
	// contains filtered or unexported fields
}

MockMediaProcessorMockRecorder is the mock recorder for MockMediaProcessor.

func (*MockMediaProcessorMockRecorder) Process added in v0.3.1 

func (mr *MockMediaProcessorMockRecorder) Process(ctx, sourceURL any) *gomock.Call

Process indicates an expected call of Process.

func (*MockMediaProcessorMockRecorder) Provider added in v0.3.1 

func (mr *MockMediaProcessorMockRecorder) Provider() *gomock.Call

Provider indicates an expected call of Provider.

type MockMediaProvider added in v0.5.0 

type MockMediaProvider struct {
	// contains filtered or unexported fields
}

MockMediaProvider is a mock of Provider interface.

func NewMockMediaProvider added in v0.5.0 

func NewMockMediaProvider(ctrl *gomock.Controller) *MockMediaProvider

NewMockMediaProvider creates a new mock instance.

func (*MockMediaProvider) EXPECT added in v0.5.0 

func (m *MockMediaProvider) EXPECT() *MockMediaProviderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMediaProvider) Name added in v0.5.0 

func (m *MockMediaProvider) Name() string

Name mocks base method.

func (*MockMediaProvider) UploadImageFromReader added in v0.5.0 

func (m *MockMediaProvider) UploadImageFromReader(ctx context.Context, reader io.Reader, filename, contentType string, metadata map[string]any) (*mediaprovider.UploadResult, error)

UploadImageFromReader mocks base method.

func (*MockMediaProvider) UploadImageFromURL added in v0.5.0 

func (m *MockMediaProvider) UploadImageFromURL(ctx context.Context, sourceURL string, metadata map[string]any) (*mediaprovider.UploadResult, error)

UploadImageFromURL mocks base method.

func (*MockMediaProvider) UploadVideo added in v0.5.0 

func (m *MockMediaProvider) UploadVideo(ctx context.Context, sourceURL string, metadata map[string]any) (*mediaprovider.UploadResult, error)

UploadVideo mocks base method.

type MockMediaProviderMockRecorder added in v0.5.0 

type MockMediaProviderMockRecorder struct {
	// contains filtered or unexported fields
}

MockMediaProviderMockRecorder is the mock recorder for MockMediaProvider.

func (*MockMediaProviderMockRecorder) Name added in v0.5.0 

func (mr *MockMediaProviderMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockMediaProviderMockRecorder) UploadImageFromReader added in v0.5.0 

func (mr *MockMediaProviderMockRecorder) UploadImageFromReader(ctx, reader, filename, contentType, metadata any) *gomock.Call

UploadImageFromReader indicates an expected call of UploadImageFromReader.

func (*MockMediaProviderMockRecorder) UploadImageFromURL added in v0.5.0 

func (mr *MockMediaProviderMockRecorder) UploadImageFromURL(ctx, sourceURL, metadata any) *gomock.Call

UploadImageFromURL indicates an expected call of UploadImageFromURL.

func (*MockMediaProviderMockRecorder) UploadVideo added in v0.5.0 

func (mr *MockMediaProviderMockRecorder) UploadVideo(ctx, sourceURL, metadata any) *gomock.Call

UploadVideo indicates an expected call of UploadVideo.

type MockMediaWorkflows added in v0.5.0 

type MockMediaWorkflows struct {
	// contains filtered or unexported fields
}

MockMediaWorkflows is a mock of MediaWorkflows interface.

func NewMockMediaWorkflows added in v0.5.0 

func NewMockMediaWorkflows(ctrl *gomock.Controller) *MockMediaWorkflows

NewMockMediaWorkflows creates a new mock instance.

func (*MockMediaWorkflows) EXPECT added in v0.5.0 

func (m *MockMediaWorkflows) EXPECT() *MockMediaWorkflowsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMediaWorkflows) IndexMediaWorkflow added in v0.5.0 

func (m *MockMediaWorkflows) IndexMediaWorkflow(ctx context.Context, url string) error

IndexMediaWorkflow mocks base method.

func (*MockMediaWorkflows) IndexMultipleMediaWorkflow added in v0.5.0 

func (m *MockMediaWorkflows) IndexMultipleMediaWorkflow(ctx context.Context, urls []string) error

IndexMultipleMediaWorkflow mocks base method.

type MockMediaWorkflowsMockRecorder added in v0.5.0 

type MockMediaWorkflowsMockRecorder struct {
	// contains filtered or unexported fields
}

MockMediaWorkflowsMockRecorder is the mock recorder for MockMediaWorkflows.

func (*MockMediaWorkflowsMockRecorder) IndexMediaWorkflow added in v0.5.0 

func (mr *MockMediaWorkflowsMockRecorder) IndexMediaWorkflow(ctx, url any) *gomock.Call

IndexMediaWorkflow indicates an expected call of IndexMediaWorkflow.

func (*MockMediaWorkflowsMockRecorder) IndexMultipleMediaWorkflow added in v0.5.0 

func (mr *MockMediaWorkflowsMockRecorder) IndexMultipleMediaWorkflow(ctx, urls any) *gomock.Call

IndexMultipleMediaWorkflow indicates an expected call of IndexMultipleMediaWorkflow.

type MockMetadataEnhancer 

type MockMetadataEnhancer struct {
	// contains filtered or unexported fields
}

MockMetadataEnhancer is a mock of Enhancer interface.

func NewMockMetadataEnhancer 

func NewMockMetadataEnhancer(ctrl *gomock.Controller) *MockMetadataEnhancer

NewMockMetadataEnhancer creates a new mock instance.

func (*MockMetadataEnhancer) EXPECT 

func (m *MockMetadataEnhancer) EXPECT() *MockMetadataEnhancerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataEnhancer) Enhance 

func (m *MockMetadataEnhancer) Enhance(ctx context.Context, tokenCID domain.TokenCID, meta *metadata.NormalizedMetadata) (*metadata.EnhancedMetadata, error)

Enhance mocks base method.

func (*MockMetadataEnhancer) VendorJsonHash 

func (m *MockMetadataEnhancer) VendorJsonHash(arg0 *metadata.EnhancedMetadata) ([]byte, error)

VendorJsonHash mocks base method.

type MockMetadataEnhancerMockRecorder 

type MockMetadataEnhancerMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetadataEnhancerMockRecorder is the mock recorder for MockMetadataEnhancer.

func (*MockMetadataEnhancerMockRecorder) Enhance 

func (mr *MockMetadataEnhancerMockRecorder) Enhance(ctx, tokenCID, meta any) *gomock.Call

Enhance indicates an expected call of Enhance.

func (*MockMetadataEnhancerMockRecorder) VendorJsonHash 

func (mr *MockMetadataEnhancerMockRecorder) VendorJsonHash(arg0 any) *gomock.Call

VendorJsonHash indicates an expected call of VendorJsonHash.

type MockMetadataResolver 

type MockMetadataResolver struct {
	// contains filtered or unexported fields
}

MockMetadataResolver is a mock of Resolver interface.

func NewMockMetadataResolver 

func NewMockMetadataResolver(ctrl *gomock.Controller) *MockMetadataResolver

NewMockMetadataResolver creates a new mock instance.

func (*MockMetadataResolver) EXPECT 

func (m *MockMetadataResolver) EXPECT() *MockMetadataResolverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataResolver) LoadDeployerCacheFromDB 

func (m *MockMetadataResolver) LoadDeployerCacheFromDB(ctx context.Context) error

LoadDeployerCacheFromDB mocks base method.

func (*MockMetadataResolver) RawHash 

func (m *MockMetadataResolver) RawHash(arg0 *metadata.NormalizedMetadata) ([]byte, []byte, error)

RawHash mocks base method.

func (*MockMetadataResolver) Resolve 

func (m *MockMetadataResolver) Resolve(ctx context.Context, tokenCID domain.TokenCID) (*metadata.NormalizedMetadata, error)

Resolve mocks base method.

type MockMetadataResolverMockRecorder 

type MockMetadataResolverMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetadataResolverMockRecorder is the mock recorder for MockMetadataResolver.

func (*MockMetadataResolverMockRecorder) LoadDeployerCacheFromDB 

func (mr *MockMetadataResolverMockRecorder) LoadDeployerCacheFromDB(ctx any) *gomock.Call

LoadDeployerCacheFromDB indicates an expected call of LoadDeployerCacheFromDB.

func (*MockMetadataResolverMockRecorder) RawHash 

func (mr *MockMetadataResolverMockRecorder) RawHash(arg0 any) *gomock.Call

RawHash indicates an expected call of RawHash.

func (*MockMetadataResolverMockRecorder) Resolve 

func (mr *MockMetadataResolverMockRecorder) Resolve(ctx, tokenCID any) *gomock.Call

Resolve indicates an expected call of Resolve.

type MockObjktClient added in v0.2.0 

type MockObjktClient struct {
	// contains filtered or unexported fields
}

MockObjktClient is a mock of Client interface.

func NewMockObjktClient added in v0.2.0 

func NewMockObjktClient(ctrl *gomock.Controller) *MockObjktClient

NewMockObjktClient creates a new mock instance.

func (*MockObjktClient) EXPECT added in v0.2.0 

func (m *MockObjktClient) EXPECT() *MockObjktClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockObjktClient) GetToken added in v0.2.0 

func (m *MockObjktClient) GetToken(ctx context.Context, contractAddress, tokenID string) (*objkt.Token, error)

GetToken mocks base method.

type MockObjktClientMockRecorder added in v0.2.0 

type MockObjktClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockObjktClientMockRecorder is the mock recorder for MockObjktClient.

func (*MockObjktClientMockRecorder) GetToken added in v0.2.0 

func (mr *MockObjktClientMockRecorder) GetToken(ctx, contractAddress, tokenID any) *gomock.Call

GetToken indicates an expected call of GetToken.

type MockOpenSeaClient added in v0.4.0 

type MockOpenSeaClient struct {
	// contains filtered or unexported fields
}

MockOpenSeaClient is a mock of Client interface.

func NewMockOpenSeaClient added in v0.4.0 

func NewMockOpenSeaClient(ctrl *gomock.Controller) *MockOpenSeaClient

NewMockOpenSeaClient creates a new mock instance.

func (*MockOpenSeaClient) EXPECT added in v0.4.0 

func (m *MockOpenSeaClient) EXPECT() *MockOpenSeaClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOpenSeaClient) GetNFT added in v0.4.0 

func (m *MockOpenSeaClient) GetNFT(ctx context.Context, contractAddress, tokenID string) (*opensea.NFTMetadata, error)

GetNFT mocks base method.

type MockOpenSeaClientMockRecorder added in v0.4.0 

type MockOpenSeaClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockOpenSeaClientMockRecorder is the mock recorder for MockOpenSeaClient.

func (*MockOpenSeaClientMockRecorder) GetNFT added in v0.4.0 

func (mr *MockOpenSeaClientMockRecorder) GetNFT(ctx, contractAddress, tokenID any) *gomock.Call

GetNFT indicates an expected call of GetNFT.

type MockPublisherRegistry 

type MockPublisherRegistry struct {
	// contains filtered or unexported fields
}

MockPublisherRegistry is a mock of PublisherRegistry interface.

func NewMockPublisherRegistry 

func NewMockPublisherRegistry(ctrl *gomock.Controller) *MockPublisherRegistry

NewMockPublisherRegistry creates a new mock instance.

func (*MockPublisherRegistry) EXPECT 

func (m *MockPublisherRegistry) EXPECT() *MockPublisherRegistryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPublisherRegistry) GetMinBlock 

func (m *MockPublisherRegistry) GetMinBlock(chainID domain.Chain) (uint64, bool)

GetMinBlock mocks base method.

func (*MockPublisherRegistry) LookupPublisherByCollection 

func (m *MockPublisherRegistry) LookupPublisherByCollection(chainID domain.Chain, contractAddress string) *registry.PublisherInfo

LookupPublisherByCollection mocks base method.

func (*MockPublisherRegistry) LookupPublisherByDeployer 

func (m *MockPublisherRegistry) LookupPublisherByDeployer(chainID domain.Chain, deployerAddress string) *registry.PublisherInfo

LookupPublisherByDeployer mocks base method.

type MockPublisherRegistryLoader 

type MockPublisherRegistryLoader struct {
	// contains filtered or unexported fields
}

MockPublisherRegistryLoader is a mock of PublisherRegistryLoader interface.

func NewMockPublisherRegistryLoader 

func NewMockPublisherRegistryLoader(ctrl *gomock.Controller) *MockPublisherRegistryLoader

NewMockPublisherRegistryLoader creates a new mock instance.

func (*MockPublisherRegistryLoader) EXPECT 

func (m *MockPublisherRegistryLoader) EXPECT() *MockPublisherRegistryLoaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPublisherRegistryLoader) Load 

func (m *MockPublisherRegistryLoader) Load(filePath string) (registry.PublisherRegistry, error)

Load mocks base method.

type MockPublisherRegistryLoaderMockRecorder 

type MockPublisherRegistryLoaderMockRecorder struct {
	// contains filtered or unexported fields
}

MockPublisherRegistryLoaderMockRecorder is the mock recorder for MockPublisherRegistryLoader.

func (*MockPublisherRegistryLoaderMockRecorder) Load 

func (mr *MockPublisherRegistryLoaderMockRecorder) Load(filePath any) *gomock.Call

Load indicates an expected call of Load.

type MockPublisherRegistryMockRecorder 

type MockPublisherRegistryMockRecorder struct {
	// contains filtered or unexported fields
}

MockPublisherRegistryMockRecorder is the mock recorder for MockPublisherRegistry.

func (*MockPublisherRegistryMockRecorder) GetMinBlock 

func (mr *MockPublisherRegistryMockRecorder) GetMinBlock(chainID any) *gomock.Call

GetMinBlock indicates an expected call of GetMinBlock.

func (*MockPublisherRegistryMockRecorder) LookupPublisherByCollection 

func (mr *MockPublisherRegistryMockRecorder) LookupPublisherByCollection(chainID, contractAddress any) *gomock.Call

LookupPublisherByCollection indicates an expected call of LookupPublisherByCollection.

func (*MockPublisherRegistryMockRecorder) LookupPublisherByDeployer 

func (mr *MockPublisherRegistryMockRecorder) LookupPublisherByDeployer(chainID, deployerAddress any) *gomock.Call

LookupPublisherByDeployer indicates an expected call of LookupPublisherByDeployer.

type MockRasterizer added in v0.4.0 

type MockRasterizer struct {
	// contains filtered or unexported fields
}

MockRasterizer is a mock of Rasterizer interface.

func NewMockRasterizer added in v0.4.0 

func NewMockRasterizer(ctrl *gomock.Controller) *MockRasterizer

NewMockRasterizer creates a new mock instance.

func (*MockRasterizer) EXPECT added in v0.4.0 

func (m *MockRasterizer) EXPECT() *MockRasterizerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRasterizer) Rasterize added in v0.4.0 

func (m *MockRasterizer) Rasterize(ctx context.Context, svgData []byte) ([]byte, error)

Rasterize mocks base method.

type MockRasterizerMockRecorder added in v0.4.0 

type MockRasterizerMockRecorder struct {
	// contains filtered or unexported fields
}

MockRasterizerMockRecorder is the mock recorder for MockRasterizer.

func (*MockRasterizerMockRecorder) Rasterize added in v0.4.0 

func (mr *MockRasterizerMockRecorder) Rasterize(ctx, svgData any) *gomock.Call

Rasterize indicates an expected call of Rasterize.

type MockResvgClient added in v0.4.0 

type MockResvgClient struct {
	// contains filtered or unexported fields
}

MockResvgClient is a mock of ResvgClient interface.

func NewMockResvgClient added in v0.4.0 

func NewMockResvgClient(ctrl *gomock.Controller) *MockResvgClient

NewMockResvgClient creates a new mock instance.

func (*MockResvgClient) EXPECT added in v0.4.0 

func (m *MockResvgClient) EXPECT() *MockResvgClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockResvgClient) Render added in v0.4.0 

func (m *MockResvgClient) Render(data []byte, width int) (image.Image, error)

Render mocks base method.

type MockResvgClientMockRecorder added in v0.4.0 

type MockResvgClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockResvgClientMockRecorder is the mock recorder for MockResvgClient.

func (*MockResvgClientMockRecorder) Render added in v0.4.0 

func (mr *MockResvgClientMockRecorder) Render(data, width any) *gomock.Call

Render indicates an expected call of Render.

type MockSignalR 

type MockSignalR struct {
	// contains filtered or unexported fields
}

MockSignalR is a mock of SignalR interface.

func NewMockSignalR 

func NewMockSignalR(ctrl *gomock.Controller) *MockSignalR

NewMockSignalR creates a new mock instance.

func (*MockSignalR) EXPECT 

func (m *MockSignalR) EXPECT() *MockSignalRMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSignalR) NewClient 

func (m *MockSignalR) NewClient(ctx context.Context, address string, receiver any) (adapter.SignalRClient, error)

NewClient mocks base method.

type MockSignalRClient 

type MockSignalRClient struct {
	// contains filtered or unexported fields
}

MockSignalRClient is a mock of SignalRClient interface.

func NewMockSignalRClient 

func NewMockSignalRClient(ctrl *gomock.Controller) *MockSignalRClient

NewMockSignalRClient creates a new mock instance.

func (*MockSignalRClient) EXPECT 

func (m *MockSignalRClient) EXPECT() *MockSignalRClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSignalRClient) Send 

func (m *MockSignalRClient) Send(target string, args ...any) <-chan error

Send mocks base method.

func (*MockSignalRClient) Start 

func (m *MockSignalRClient) Start()

Start mocks base method.

func (*MockSignalRClient) Stop 

func (m *MockSignalRClient) Stop()

Stop mocks base method.

type MockSignalRClientMockRecorder 

type MockSignalRClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSignalRClientMockRecorder is the mock recorder for MockSignalRClient.

func (*MockSignalRClientMockRecorder) Send 

func (mr *MockSignalRClientMockRecorder) Send(target any, args ...any) *gomock.Call

Send indicates an expected call of Send.

func (*MockSignalRClientMockRecorder) Start 

func (mr *MockSignalRClientMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockSignalRClientMockRecorder) Stop 

func (mr *MockSignalRClientMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type MockSignalRMockRecorder 

type MockSignalRMockRecorder struct {
	// contains filtered or unexported fields
}

MockSignalRMockRecorder is the mock recorder for MockSignalR.

func (*MockSignalRMockRecorder) NewClient 

func (mr *MockSignalRMockRecorder) NewClient(ctx, address, receiver any) *gomock.Call

NewClient indicates an expected call of NewClient.

type MockStore 

type MockStore struct {
	// contains filtered or unexported fields
}

MockStore is a mock of Store interface.

func NewMockStore 

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance.

func (*MockStore) AcquireJobQueueLock added in v0.5.0 

func (m *MockStore) AcquireJobQueueLock(ctx context.Context, queue string) (bool, func(), error)

AcquireJobQueueLock mocks base method.

func (*MockStore) BatchUpdateTokensViewability added in v0.5.0 

func (m *MockStore) BatchUpdateTokensViewability(ctx context.Context, tokenIDs []uint64) ([]store.TokenViewabilityChange, error)

BatchUpdateTokensViewability mocks base method.

func (*MockStore) ClaimJobs added in v0.5.0 

func (m *MockStore) ClaimJobs(ctx context.Context, queue string, limit int) ([]*schema.Job, error)

ClaimJobs mocks base method.

func (*MockStore) CreateAddressIndexingJob added in v0.5.0 

func (m *MockStore) CreateAddressIndexingJob(ctx context.Context, input store.CreateAddressIndexingJobInput) error

CreateAddressIndexingJob mocks base method.

func (*MockStore) CreateMediaAsset 

func (m *MockStore) CreateMediaAsset(ctx context.Context, input store.CreateMediaAssetInput) (*schema.MediaAsset, error)

CreateMediaAsset mocks base method.

func (*MockStore) CreateMetadataUpdate 

func (m *MockStore) CreateMetadataUpdate(ctx context.Context, input store.CreateMetadataUpdateInput) error

CreateMetadataUpdate mocks base method.

func (*MockStore) CreateTokenMint 

func (m *MockStore) CreateTokenMint(ctx context.Context, input store.CreateTokenMintInput) error

CreateTokenMint mocks base method.

func (*MockStore) CreateTokenWithProvenances 

func (m *MockStore) CreateTokenWithProvenances(ctx context.Context, input store.CreateTokenWithProvenancesInput) error

CreateTokenWithProvenances mocks base method.

func (*MockStore) CreateWebhookClient added in v0.5.0 

func (m *MockStore) CreateWebhookClient(ctx context.Context, input store.CreateWebhookClientInput) (*schema.WebhookClient, error)

CreateWebhookClient mocks base method.

func (*MockStore) CreateWebhookDelivery added in v0.5.0 

func (m *MockStore) CreateWebhookDelivery(ctx context.Context, delivery *schema.WebhookDelivery) error

CreateWebhookDelivery mocks base method.

func (*MockStore) EXPECT 

func (m *MockStore) EXPECT() *MockStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStore) EnqueueJob added in v0.5.0 

func (m *MockStore) EnqueueJob(ctx context.Context, input store.EnqueueJobInput) (*schema.Job, bool, error)

EnqueueJob mocks base method.

func (*MockStore) EnsureWatchedAddressExists 

func (m *MockStore) EnsureWatchedAddressExists(ctx context.Context, address string, chain domain.Chain, dailyQuota int) error

EnsureWatchedAddressExists mocks base method.

func (*MockStore) GetActiveIndexingJobForAddress added in v0.5.0 

func (m *MockStore) GetActiveIndexingJobForAddress(ctx context.Context, address string, chainID domain.Chain) (*schema.AddressIndexingJob, error)

GetActiveIndexingJobForAddress mocks base method.

func (*MockStore) GetActiveWebhookClientsByEventType added in v0.5.0 

func (m *MockStore) GetActiveWebhookClientsByEventType(ctx context.Context, eventType string) ([]*schema.WebhookClient, error)

GetActiveWebhookClientsByEventType mocks base method.

func (*MockStore) GetAddressIndexingJobByJobID added in v0.5.0 

func (m *MockStore) GetAddressIndexingJobByJobID(ctx context.Context, jobID int64) (*schema.AddressIndexingJob, error)

GetAddressIndexingJobByJobID mocks base method.

func (*MockStore) GetAddressIndexingJobByWorkflowID added in v0.5.0 

func (m *MockStore) GetAddressIndexingJobByWorkflowID(ctx context.Context, workflowID string) (*schema.AddressIndexingJob, error)

GetAddressIndexingJobByWorkflowID mocks base method.

func (*MockStore) GetAllKeyValuesByPrefix 

func (m *MockStore) GetAllKeyValuesByPrefix(ctx context.Context, prefix string) (map[string]string, error)

GetAllKeyValuesByPrefix mocks base method.

func (*MockStore) GetBlockCursor 

func (m *MockStore) GetBlockCursor(ctx context.Context, chain string) (uint64, error)

GetBlockCursor mocks base method.

func (*MockStore) GetEnrichmentSourceByTokenCID 

func (m *MockStore) GetEnrichmentSourceByTokenCID(ctx context.Context, tokenCID string) (*schema.EnrichmentSource, error)

GetEnrichmentSourceByTokenCID mocks base method.

func (*MockStore) GetEnrichmentSourceByTokenID 

func (m *MockStore) GetEnrichmentSourceByTokenID(ctx context.Context, tokenID uint64) (*schema.EnrichmentSource, error)

GetEnrichmentSourceByTokenID mocks base method.

func (*MockStore) GetEnrichmentSourcesByTokenIDs added in v0.3.1 

func (m *MockStore) GetEnrichmentSourcesByTokenIDs(ctx context.Context, tokenIDs []uint64) (map[uint64]*schema.EnrichmentSource, error)

GetEnrichmentSourcesByTokenIDs mocks base method.

func (*MockStore) GetIndexingBlockRangeForAddress 

func (m *MockStore) GetIndexingBlockRangeForAddress(ctx context.Context, address string, chainID domain.Chain) (uint64, uint64, error)

GetIndexingBlockRangeForAddress mocks base method.

func (*MockStore) GetJob added in v0.5.0 

func (m *MockStore) GetJob(ctx context.Context, id int64) (*schema.Job, error)

GetJob mocks base method.

func (*MockStore) GetKeyValue 

func (m *MockStore) GetKeyValue(ctx context.Context, key string) (string, error)

GetKeyValue mocks base method.

func (*MockStore) GetMediaAssetByID 

func (m *MockStore) GetMediaAssetByID(ctx context.Context, id int64) (*schema.MediaAsset, error)

GetMediaAssetByID mocks base method.

func (*MockStore) GetMediaAssetBySourceURL 

func (m *MockStore) GetMediaAssetBySourceURL(ctx context.Context, sourceURL string, provider schema.StorageProvider) (*schema.MediaAsset, error)

GetMediaAssetBySourceURL mocks base method.

func (*MockStore) GetMediaAssetsBySourceURLs 

func (m *MockStore) GetMediaAssetsBySourceURLs(ctx context.Context, sourceURLs []string) ([]schema.MediaAsset, error)

GetMediaAssetsBySourceURLs mocks base method.

func (*MockStore) GetProvenanceEventByID 

func (m *MockStore) GetProvenanceEventByID(ctx context.Context, id uint64) (*schema.ProvenanceEvent, error)

GetProvenanceEventByID mocks base method.

func (*MockStore) GetQuotaInfo added in v0.5.0 

func (m *MockStore) GetQuotaInfo(ctx context.Context, address string, chain domain.Chain) (*store.QuotaInfo, error)

GetQuotaInfo mocks base method.

func (*MockStore) GetTokenByID 

func (m *MockStore) GetTokenByID(ctx context.Context, tokenID uint64) (*schema.Token, error)

GetTokenByID mocks base method.

func (*MockStore) GetTokenByTokenCID 

func (m *MockStore) GetTokenByTokenCID(ctx context.Context, tokenCID string) (*schema.Token, error)

GetTokenByTokenCID mocks base method.

func (*MockStore) GetTokenCIDsByOwner 

func (m *MockStore) GetTokenCIDsByOwner(ctx context.Context, ownerAddress string) ([]domain.TokenCID, error)

GetTokenCIDsByOwner mocks base method.

func (*MockStore) GetTokenChangesByOwnerSinceCheckpoint added in v0.5.0 

func (m *MockStore) GetTokenChangesByOwnerSinceCheckpoint(ctx context.Context, ownerAddress string, sinceTimestamp time.Time, sinceEventID uint64, limit int) ([]schema.TokenEvent, error)

GetTokenChangesByOwnerSinceCheckpoint mocks base method.

func (*MockStore) GetTokenCountsByAddress added in v0.5.0 

func (m *MockStore) GetTokenCountsByAddress(ctx context.Context, address string, chain domain.Chain) (*store.TokenCountsByAddress, error)

GetTokenCountsByAddress mocks base method.

func (*MockStore) GetTokenIDsByMediaURL added in v0.5.0 

func (m *MockStore) GetTokenIDsByMediaURL(ctx context.Context, url string) ([]uint64, error)

GetTokenIDsByMediaURL mocks base method.

func (*MockStore) GetTokenMetadataByTokenCID 

func (m *MockStore) GetTokenMetadataByTokenCID(ctx context.Context, tokenCID string) (*schema.TokenMetadata, error)

GetTokenMetadataByTokenCID mocks base method.

func (*MockStore) GetTokenMetadataByTokenID added in v0.5.0 

func (m *MockStore) GetTokenMetadataByTokenID(ctx context.Context, tokenID uint64) (*schema.TokenMetadata, error)

GetTokenMetadataByTokenID mocks base method.

func (*MockStore) GetTokenMetadataByTokenIDs added in v0.5.0 

func (m *MockStore) GetTokenMetadataByTokenIDs(ctx context.Context, tokenIDs []uint64) (map[uint64]*schema.TokenMetadata, error)

GetTokenMetadataByTokenIDs mocks base method.

func (*MockStore) GetTokenOwnerProvenancesBulk added in v0.5.0 

func (m *MockStore) GetTokenOwnerProvenancesBulk(ctx context.Context, tokenIDs []uint64, ownerAddresses []string, maxPerToken int) (map[uint64][]schema.TokenOwnershipProvenance, map[uint64]uint64, error)

GetTokenOwnerProvenancesBulk mocks base method.

func (*MockStore) GetTokenOwners 

func (m *MockStore) GetTokenOwners(ctx context.Context, tokenID uint64, limit int, offset uint64) ([]schema.Balance, uint64, error)

GetTokenOwners mocks base method.

func (*MockStore) GetTokenOwnersBulk added in v0.3.1 

func (m *MockStore) GetTokenOwnersBulk(ctx context.Context, tokenIDs []uint64, limit int) (map[uint64][]schema.Balance, map[uint64]uint64, error)

GetTokenOwnersBulk mocks base method.

func (*MockStore) GetTokenProvenanceEvents 

func (m *MockStore) GetTokenProvenanceEvents(ctx context.Context, tokenID uint64, limit int, offset uint64, orderDesc bool) ([]schema.ProvenanceEvent, uint64, error)

GetTokenProvenanceEvents mocks base method.

func (*MockStore) GetTokenProvenanceEventsBulk added in v0.3.1 

func (m *MockStore) GetTokenProvenanceEventsBulk(ctx context.Context, tokenIDs []uint64, limit int) (map[uint64][]schema.ProvenanceEvent, map[uint64]uint64, error)

GetTokenProvenanceEventsBulk mocks base method.

func (*MockStore) GetTokenWithMetadataByTokenCID 

func (m *MockStore) GetTokenWithMetadataByTokenCID(ctx context.Context, tokenCID string) (*store.TokensWithMetadataResult, error)

GetTokenWithMetadataByTokenCID mocks base method.

func (*MockStore) GetTokensByCIDs added in v0.2.0 

func (m *MockStore) GetTokensByCIDs(ctx context.Context, tokenCIDs []string) ([]*schema.Token, error)

GetTokensByCIDs mocks base method.

func (*MockStore) GetTokensByFilter 

func (m *MockStore) GetTokensByFilter(ctx context.Context, filter store.TokenQueryFilter) ([]schema.Token, error)

GetTokensByFilter mocks base method.

func (*MockStore) GetTokensByIDs added in v0.2.0 

func (m *MockStore) GetTokensByIDs(ctx context.Context, tokenIDs []uint64) ([]*schema.Token, error)

GetTokensByIDs mocks base method.

func (*MockStore) GetTokensViewabilityByIDs added in v0.5.0 

func (m *MockStore) GetTokensViewabilityByIDs(ctx context.Context, tokenIDs []uint64) ([]store.TokenViewabilityInfo, error)

GetTokensViewabilityByIDs mocks base method.

func (*MockStore) GetURLsForChecking added in v0.5.0 

func (m *MockStore) GetURLsForChecking(ctx context.Context, recheckAfter time.Duration, limit int) ([]string, error)

GetURLsForChecking mocks base method.

func (*MockStore) GetWebhookClientByID added in v0.5.0 

func (m *MockStore) GetWebhookClientByID(ctx context.Context, clientID string) (*schema.WebhookClient, error)

GetWebhookClientByID mocks base method.

func (*MockStore) IncrementTokensIndexed added in v0.5.0 

func (m *MockStore) IncrementTokensIndexed(ctx context.Context, address string, chain domain.Chain, count int) error

IncrementTokensIndexed mocks base method.

func (*MockStore) IsAnyAddressWatched 

func (m *MockStore) IsAnyAddressWatched(ctx context.Context, chain domain.Chain, addresses []string) (bool, error)

IsAnyAddressWatched mocks base method.

func (*MockStore) ListInFlightJobsWithCancelRequest added in v0.5.0 

func (m *MockStore) ListInFlightJobsWithCancelRequest(ctx context.Context, queue string, ids []int64) ([]*schema.Job, error)

ListInFlightJobsWithCancelRequest mocks base method.

func (*MockStore) MarkJobCanceled added in v0.5.0 

func (m *MockStore) MarkJobCanceled(ctx context.Context, id int64) error

MarkJobCanceled mocks base method.

func (*MockStore) MarkJobFailed added in v0.5.0 

func (m *MockStore) MarkJobFailed(ctx context.Context, id int64, lastErr string) error

MarkJobFailed mocks base method.

func (*MockStore) MarkJobSucceeded added in v0.5.0 

func (m *MockStore) MarkJobSucceeded(ctx context.Context, id int64) error

MarkJobSucceeded mocks base method.

func (*MockStore) RequestJobCancel added in v0.5.0 

func (m *MockStore) RequestJobCancel(ctx context.Context, id int64) error

RequestJobCancel mocks base method.

func (*MockStore) RescheduleJob added in v0.5.0 

func (m *MockStore) RescheduleJob(ctx context.Context, id int64, runAfter time.Time) error

RescheduleJob mocks base method.

func (*MockStore) SetBlockCursor 

func (m *MockStore) SetBlockCursor(ctx context.Context, chain string, blockNumber uint64) error

SetBlockCursor mocks base method.

func (*MockStore) SetKeyValue 

func (m *MockStore) SetKeyValue(ctx context.Context, key, value string) error

SetKeyValue mocks base method.

func (*MockStore) SweepCanceledPendingJobs added in v0.5.0 

func (m *MockStore) SweepCanceledPendingJobs(ctx context.Context, queue string) (int64, error)

SweepCanceledPendingJobs mocks base method.

func (*MockStore) SweepOrphanedJobs added in v0.5.0 

func (m *MockStore) SweepOrphanedJobs(ctx context.Context, queue string) (int64, error)

SweepOrphanedJobs mocks base method.

func (*MockStore) UpdateAddressIndexingJobProgress added in v0.5.0 

func (m *MockStore) UpdateAddressIndexingJobProgress(ctx context.Context, jobID int64, tokensProcessed int, minBlock, maxBlock uint64) error

UpdateAddressIndexingJobProgress mocks base method.

func (*MockStore) UpdateAddressIndexingJobStatus added in v0.5.0 

func (m *MockStore) UpdateAddressIndexingJobStatus(ctx context.Context, jobID int64, status schema.IndexingJobStatus, timestamp time.Time) error

UpdateAddressIndexingJobStatus mocks base method.

func (*MockStore) UpdateIndexingBlockRangeForAddress 

func (m *MockStore) UpdateIndexingBlockRangeForAddress(ctx context.Context, address string, chainID domain.Chain, minBlock, maxBlock uint64) error

UpdateIndexingBlockRangeForAddress mocks base method.

func (*MockStore) UpdateMediaURLAndPropagate added in v0.5.0 

func (m *MockStore) UpdateMediaURLAndPropagate(ctx context.Context, oldURL, newURL string) error

UpdateMediaURLAndPropagate mocks base method.

func (*MockStore) UpdateTokenBurn 

func (m *MockStore) UpdateTokenBurn(ctx context.Context, input store.CreateTokenBurnInput) error

UpdateTokenBurn mocks base method.

func (*MockStore) UpdateTokenMediaHealthByURL added in v0.5.0 

func (m *MockStore) UpdateTokenMediaHealthByURL(ctx context.Context, url string, status schema.MediaHealthStatus, lastError *string) error

UpdateTokenMediaHealthByURL mocks base method.

func (*MockStore) UpdateTokenTransfer 

func (m *MockStore) UpdateTokenTransfer(ctx context.Context, input store.UpdateTokenTransferInput) error

UpdateTokenTransfer mocks base method.

func (*MockStore) UpdateWebhookDeliveryStatus added in v0.5.0 

func (m *MockStore) UpdateWebhookDeliveryStatus(ctx context.Context, deliveryID uint64, status schema.WebhookDeliveryStatus, attempts int, responseStatus *int, responseBody, errorMessage string) error

UpdateWebhookDeliveryStatus mocks base method.

func (*MockStore) UpsertEnrichmentSource 

func (m *MockStore) UpsertEnrichmentSource(ctx context.Context, input store.CreateEnrichmentSourceInput) error

UpsertEnrichmentSource mocks base method.

func (*MockStore) UpsertTokenBalanceForOwner added in v0.4.0 

func (m *MockStore) UpsertTokenBalanceForOwner(ctx context.Context, input store.UpsertTokenBalanceForOwnerInput) error

UpsertTokenBalanceForOwner mocks base method.

func (*MockStore) UpsertTokenMetadata 

func (m *MockStore) UpsertTokenMetadata(ctx context.Context, input store.CreateTokenMetadataInput) error

UpsertTokenMetadata mocks base method.

type MockStoreMockRecorder 

type MockStoreMockRecorder struct {
	// contains filtered or unexported fields
}

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder) AcquireJobQueueLock added in v0.5.0 

func (mr *MockStoreMockRecorder) AcquireJobQueueLock(ctx, queue any) *gomock.Call

AcquireJobQueueLock indicates an expected call of AcquireJobQueueLock.

func (*MockStoreMockRecorder) BatchUpdateTokensViewability added in v0.5.0 

func (mr *MockStoreMockRecorder) BatchUpdateTokensViewability(ctx, tokenIDs any) *gomock.Call

BatchUpdateTokensViewability indicates an expected call of BatchUpdateTokensViewability.

func (*MockStoreMockRecorder) ClaimJobs added in v0.5.0 

func (mr *MockStoreMockRecorder) ClaimJobs(ctx, queue, limit any) *gomock.Call

ClaimJobs indicates an expected call of ClaimJobs.

func (*MockStoreMockRecorder) CreateAddressIndexingJob added in v0.5.0 

func (mr *MockStoreMockRecorder) CreateAddressIndexingJob(ctx, input any) *gomock.Call

CreateAddressIndexingJob indicates an expected call of CreateAddressIndexingJob.

func (*MockStoreMockRecorder) CreateMediaAsset 

func (mr *MockStoreMockRecorder) CreateMediaAsset(ctx, input any) *gomock.Call

CreateMediaAsset indicates an expected call of CreateMediaAsset.

func (*MockStoreMockRecorder) CreateMetadataUpdate 

func (mr *MockStoreMockRecorder) CreateMetadataUpdate(ctx, input any) *gomock.Call

CreateMetadataUpdate indicates an expected call of CreateMetadataUpdate.

func (*MockStoreMockRecorder) CreateTokenMint 

func (mr *MockStoreMockRecorder) CreateTokenMint(ctx, input any) *gomock.Call

CreateTokenMint indicates an expected call of CreateTokenMint.

func (*MockStoreMockRecorder) CreateTokenWithProvenances 

func (mr *MockStoreMockRecorder) CreateTokenWithProvenances(ctx, input any) *gomock.Call

CreateTokenWithProvenances indicates an expected call of CreateTokenWithProvenances.

func (*MockStoreMockRecorder) CreateWebhookClient added in v0.5.0 

func (mr *MockStoreMockRecorder) CreateWebhookClient(ctx, input any) *gomock.Call

CreateWebhookClient indicates an expected call of CreateWebhookClient.

func (*MockStoreMockRecorder) CreateWebhookDelivery added in v0.5.0 

func (mr *MockStoreMockRecorder) CreateWebhookDelivery(ctx, delivery any) *gomock.Call

CreateWebhookDelivery indicates an expected call of CreateWebhookDelivery.

func (*MockStoreMockRecorder) EnqueueJob added in v0.5.0 

func (mr *MockStoreMockRecorder) EnqueueJob(ctx, input any) *gomock.Call

EnqueueJob indicates an expected call of EnqueueJob.

func (*MockStoreMockRecorder) EnsureWatchedAddressExists 

func (mr *MockStoreMockRecorder) EnsureWatchedAddressExists(ctx, address, chain, dailyQuota any) *gomock.Call

EnsureWatchedAddressExists indicates an expected call of EnsureWatchedAddressExists.

func (*MockStoreMockRecorder) GetActiveIndexingJobForAddress added in v0.5.0 

func (mr *MockStoreMockRecorder) GetActiveIndexingJobForAddress(ctx, address, chainID any) *gomock.Call

GetActiveIndexingJobForAddress indicates an expected call of GetActiveIndexingJobForAddress.

func (*MockStoreMockRecorder) GetActiveWebhookClientsByEventType added in v0.5.0 

func (mr *MockStoreMockRecorder) GetActiveWebhookClientsByEventType(ctx, eventType any) *gomock.Call

GetActiveWebhookClientsByEventType indicates an expected call of GetActiveWebhookClientsByEventType.

func (*MockStoreMockRecorder) GetAddressIndexingJobByJobID added in v0.5.0 

func (mr *MockStoreMockRecorder) GetAddressIndexingJobByJobID(ctx, jobID any) *gomock.Call

GetAddressIndexingJobByJobID indicates an expected call of GetAddressIndexingJobByJobID.

func (*MockStoreMockRecorder) GetAddressIndexingJobByWorkflowID added in v0.5.0 

func (mr *MockStoreMockRecorder) GetAddressIndexingJobByWorkflowID(ctx, workflowID any) *gomock.Call

GetAddressIndexingJobByWorkflowID indicates an expected call of GetAddressIndexingJobByWorkflowID.

func (*MockStoreMockRecorder) GetAllKeyValuesByPrefix 

func (mr *MockStoreMockRecorder) GetAllKeyValuesByPrefix(ctx, prefix any) *gomock.Call

GetAllKeyValuesByPrefix indicates an expected call of GetAllKeyValuesByPrefix.

func (*MockStoreMockRecorder) GetBlockCursor 

func (mr *MockStoreMockRecorder) GetBlockCursor(ctx, chain any) *gomock.Call

GetBlockCursor indicates an expected call of GetBlockCursor.

func (*MockStoreMockRecorder) GetEnrichmentSourceByTokenCID 

func (mr *MockStoreMockRecorder) GetEnrichmentSourceByTokenCID(ctx, tokenCID any) *gomock.Call

GetEnrichmentSourceByTokenCID indicates an expected call of GetEnrichmentSourceByTokenCID.

func (*MockStoreMockRecorder) GetEnrichmentSourceByTokenID 

func (mr *MockStoreMockRecorder) GetEnrichmentSourceByTokenID(ctx, tokenID any) *gomock.Call

GetEnrichmentSourceByTokenID indicates an expected call of GetEnrichmentSourceByTokenID.

func (*MockStoreMockRecorder) GetEnrichmentSourcesByTokenIDs added in v0.3.1 

func (mr *MockStoreMockRecorder) GetEnrichmentSourcesByTokenIDs(ctx, tokenIDs any) *gomock.Call

GetEnrichmentSourcesByTokenIDs indicates an expected call of GetEnrichmentSourcesByTokenIDs.

func (*MockStoreMockRecorder) GetIndexingBlockRangeForAddress 

func (mr *MockStoreMockRecorder) GetIndexingBlockRangeForAddress(ctx, address, chainID any) *gomock.Call

GetIndexingBlockRangeForAddress indicates an expected call of GetIndexingBlockRangeForAddress.

func (*MockStoreMockRecorder) GetJob added in v0.5.0 

func (mr *MockStoreMockRecorder) GetJob(ctx, id any) *gomock.Call

GetJob indicates an expected call of GetJob.

func (*MockStoreMockRecorder) GetKeyValue 

func (mr *MockStoreMockRecorder) GetKeyValue(ctx, key any) *gomock.Call

GetKeyValue indicates an expected call of GetKeyValue.

func (*MockStoreMockRecorder) GetMediaAssetByID 

func (mr *MockStoreMockRecorder) GetMediaAssetByID(ctx, id any) *gomock.Call

GetMediaAssetByID indicates an expected call of GetMediaAssetByID.

func (*MockStoreMockRecorder) GetMediaAssetBySourceURL 

func (mr *MockStoreMockRecorder) GetMediaAssetBySourceURL(ctx, sourceURL, provider any) *gomock.Call

GetMediaAssetBySourceURL indicates an expected call of GetMediaAssetBySourceURL.

func (*MockStoreMockRecorder) GetMediaAssetsBySourceURLs 

func (mr *MockStoreMockRecorder) GetMediaAssetsBySourceURLs(ctx, sourceURLs any) *gomock.Call

GetMediaAssetsBySourceURLs indicates an expected call of GetMediaAssetsBySourceURLs.

func (*MockStoreMockRecorder) GetProvenanceEventByID 

func (mr *MockStoreMockRecorder) GetProvenanceEventByID(ctx, id any) *gomock.Call

GetProvenanceEventByID indicates an expected call of GetProvenanceEventByID.

func (*MockStoreMockRecorder) GetQuotaInfo added in v0.5.0 

func (mr *MockStoreMockRecorder) GetQuotaInfo(ctx, address, chain any) *gomock.Call

GetQuotaInfo indicates an expected call of GetQuotaInfo.

func (*MockStoreMockRecorder) GetTokenByID 

func (mr *MockStoreMockRecorder) GetTokenByID(ctx, tokenID any) *gomock.Call

GetTokenByID indicates an expected call of GetTokenByID.

func (*MockStoreMockRecorder) GetTokenByTokenCID 

func (mr *MockStoreMockRecorder) GetTokenByTokenCID(ctx, tokenCID any) *gomock.Call

GetTokenByTokenCID indicates an expected call of GetTokenByTokenCID.

func (*MockStoreMockRecorder) GetTokenCIDsByOwner 

func (mr *MockStoreMockRecorder) GetTokenCIDsByOwner(ctx, ownerAddress any) *gomock.Call

GetTokenCIDsByOwner indicates an expected call of GetTokenCIDsByOwner.

func (*MockStoreMockRecorder) GetTokenChangesByOwnerSinceCheckpoint added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenChangesByOwnerSinceCheckpoint(ctx, ownerAddress, sinceTimestamp, sinceEventID, limit any) *gomock.Call

GetTokenChangesByOwnerSinceCheckpoint indicates an expected call of GetTokenChangesByOwnerSinceCheckpoint.

func (*MockStoreMockRecorder) GetTokenCountsByAddress added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenCountsByAddress(ctx, address, chain any) *gomock.Call

GetTokenCountsByAddress indicates an expected call of GetTokenCountsByAddress.

func (*MockStoreMockRecorder) GetTokenIDsByMediaURL added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenIDsByMediaURL(ctx, url any) *gomock.Call

GetTokenIDsByMediaURL indicates an expected call of GetTokenIDsByMediaURL.

func (*MockStoreMockRecorder) GetTokenMetadataByTokenCID 

func (mr *MockStoreMockRecorder) GetTokenMetadataByTokenCID(ctx, tokenCID any) *gomock.Call

GetTokenMetadataByTokenCID indicates an expected call of GetTokenMetadataByTokenCID.

func (*MockStoreMockRecorder) GetTokenMetadataByTokenID added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenMetadataByTokenID(ctx, tokenID any) *gomock.Call

GetTokenMetadataByTokenID indicates an expected call of GetTokenMetadataByTokenID.

func (*MockStoreMockRecorder) GetTokenMetadataByTokenIDs added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenMetadataByTokenIDs(ctx, tokenIDs any) *gomock.Call

GetTokenMetadataByTokenIDs indicates an expected call of GetTokenMetadataByTokenIDs.

func (*MockStoreMockRecorder) GetTokenOwnerProvenancesBulk added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokenOwnerProvenancesBulk(ctx, tokenIDs, ownerAddresses, maxPerToken any) *gomock.Call

GetTokenOwnerProvenancesBulk indicates an expected call of GetTokenOwnerProvenancesBulk.

func (*MockStoreMockRecorder) GetTokenOwners 

func (mr *MockStoreMockRecorder) GetTokenOwners(ctx, tokenID, limit, offset any) *gomock.Call

GetTokenOwners indicates an expected call of GetTokenOwners.

func (*MockStoreMockRecorder) GetTokenOwnersBulk added in v0.3.1 

func (mr *MockStoreMockRecorder) GetTokenOwnersBulk(ctx, tokenIDs, limit any) *gomock.Call

GetTokenOwnersBulk indicates an expected call of GetTokenOwnersBulk.

func (*MockStoreMockRecorder) GetTokenProvenanceEvents 

func (mr *MockStoreMockRecorder) GetTokenProvenanceEvents(ctx, tokenID, limit, offset, orderDesc any) *gomock.Call

GetTokenProvenanceEvents indicates an expected call of GetTokenProvenanceEvents.

func (*MockStoreMockRecorder) GetTokenProvenanceEventsBulk added in v0.3.1 

func (mr *MockStoreMockRecorder) GetTokenProvenanceEventsBulk(ctx, tokenIDs, limit any) *gomock.Call

GetTokenProvenanceEventsBulk indicates an expected call of GetTokenProvenanceEventsBulk.

func (*MockStoreMockRecorder) GetTokenWithMetadataByTokenCID 

func (mr *MockStoreMockRecorder) GetTokenWithMetadataByTokenCID(ctx, tokenCID any) *gomock.Call

GetTokenWithMetadataByTokenCID indicates an expected call of GetTokenWithMetadataByTokenCID.

func (*MockStoreMockRecorder) GetTokensByCIDs added in v0.2.0 

func (mr *MockStoreMockRecorder) GetTokensByCIDs(ctx, tokenCIDs any) *gomock.Call

GetTokensByCIDs indicates an expected call of GetTokensByCIDs.

func (*MockStoreMockRecorder) GetTokensByFilter 

func (mr *MockStoreMockRecorder) GetTokensByFilter(ctx, filter any) *gomock.Call

GetTokensByFilter indicates an expected call of GetTokensByFilter.

func (*MockStoreMockRecorder) GetTokensByIDs added in v0.2.0 

func (mr *MockStoreMockRecorder) GetTokensByIDs(ctx, tokenIDs any) *gomock.Call

GetTokensByIDs indicates an expected call of GetTokensByIDs.

func (*MockStoreMockRecorder) GetTokensViewabilityByIDs added in v0.5.0 

func (mr *MockStoreMockRecorder) GetTokensViewabilityByIDs(ctx, tokenIDs any) *gomock.Call

GetTokensViewabilityByIDs indicates an expected call of GetTokensViewabilityByIDs.

func (*MockStoreMockRecorder) GetURLsForChecking added in v0.5.0 

func (mr *MockStoreMockRecorder) GetURLsForChecking(ctx, recheckAfter, limit any) *gomock.Call

GetURLsForChecking indicates an expected call of GetURLsForChecking.

func (*MockStoreMockRecorder) GetWebhookClientByID added in v0.5.0 

func (mr *MockStoreMockRecorder) GetWebhookClientByID(ctx, clientID any) *gomock.Call

GetWebhookClientByID indicates an expected call of GetWebhookClientByID.

func (*MockStoreMockRecorder) IncrementTokensIndexed added in v0.5.0 

func (mr *MockStoreMockRecorder) IncrementTokensIndexed(ctx, address, chain, count any) *gomock.Call

IncrementTokensIndexed indicates an expected call of IncrementTokensIndexed.

func (*MockStoreMockRecorder) IsAnyAddressWatched 

func (mr *MockStoreMockRecorder) IsAnyAddressWatched(ctx, chain, addresses any) *gomock.Call

IsAnyAddressWatched indicates an expected call of IsAnyAddressWatched.

func (*MockStoreMockRecorder) ListInFlightJobsWithCancelRequest added in v0.5.0 

func (mr *MockStoreMockRecorder) ListInFlightJobsWithCancelRequest(ctx, queue, ids any) *gomock.Call

ListInFlightJobsWithCancelRequest indicates an expected call of ListInFlightJobsWithCancelRequest.

func (*MockStoreMockRecorder) MarkJobCanceled added in v0.5.0 

func (mr *MockStoreMockRecorder) MarkJobCanceled(ctx, id any) *gomock.Call

MarkJobCanceled indicates an expected call of MarkJobCanceled.

func (*MockStoreMockRecorder) MarkJobFailed added in v0.5.0 

func (mr *MockStoreMockRecorder) MarkJobFailed(ctx, id, lastErr any) *gomock.Call

MarkJobFailed indicates an expected call of MarkJobFailed.

func (*MockStoreMockRecorder) MarkJobSucceeded added in v0.5.0 

func (mr *MockStoreMockRecorder) MarkJobSucceeded(ctx, id any) *gomock.Call

MarkJobSucceeded indicates an expected call of MarkJobSucceeded.

func (*MockStoreMockRecorder) RequestJobCancel added in v0.5.0 

func (mr *MockStoreMockRecorder) RequestJobCancel(ctx, id any) *gomock.Call

RequestJobCancel indicates an expected call of RequestJobCancel.

func (*MockStoreMockRecorder) RescheduleJob added in v0.5.0 

func (mr *MockStoreMockRecorder) RescheduleJob(ctx, id, runAfter any) *gomock.Call

RescheduleJob indicates an expected call of RescheduleJob.

func (*MockStoreMockRecorder) SetBlockCursor 

func (mr *MockStoreMockRecorder) SetBlockCursor(ctx, chain, blockNumber any) *gomock.Call

SetBlockCursor indicates an expected call of SetBlockCursor.

func (*MockStoreMockRecorder) SetKeyValue 

func (mr *MockStoreMockRecorder) SetKeyValue(ctx, key, value any) *gomock.Call

SetKeyValue indicates an expected call of SetKeyValue.

func (*MockStoreMockRecorder) SweepCanceledPendingJobs added in v0.5.0 

func (mr *MockStoreMockRecorder) SweepCanceledPendingJobs(ctx, queue any) *gomock.Call

SweepCanceledPendingJobs indicates an expected call of SweepCanceledPendingJobs.

func (*MockStoreMockRecorder) SweepOrphanedJobs added in v0.5.0 

func (mr *MockStoreMockRecorder) SweepOrphanedJobs(ctx, queue any) *gomock.Call

SweepOrphanedJobs indicates an expected call of SweepOrphanedJobs.

func (*MockStoreMockRecorder) UpdateAddressIndexingJobProgress added in v0.5.0 

func (mr *MockStoreMockRecorder) UpdateAddressIndexingJobProgress(ctx, jobID, tokensProcessed, minBlock, maxBlock any) *gomock.Call

UpdateAddressIndexingJobProgress indicates an expected call of UpdateAddressIndexingJobProgress.

func (*MockStoreMockRecorder) UpdateAddressIndexingJobStatus added in v0.5.0 

func (mr *MockStoreMockRecorder) UpdateAddressIndexingJobStatus(ctx, jobID, status, timestamp any) *gomock.Call

UpdateAddressIndexingJobStatus indicates an expected call of UpdateAddressIndexingJobStatus.

func (*MockStoreMockRecorder) UpdateIndexingBlockRangeForAddress 

func (mr *MockStoreMockRecorder) UpdateIndexingBlockRangeForAddress(ctx, address, chainID, minBlock, maxBlock any) *gomock.Call

UpdateIndexingBlockRangeForAddress indicates an expected call of UpdateIndexingBlockRangeForAddress.

func (*MockStoreMockRecorder) UpdateMediaURLAndPropagate added in v0.5.0 

func (mr *MockStoreMockRecorder) UpdateMediaURLAndPropagate(ctx, oldURL, newURL any) *gomock.Call

UpdateMediaURLAndPropagate indicates an expected call of UpdateMediaURLAndPropagate.

func (*MockStoreMockRecorder) UpdateTokenBurn 

func (mr *MockStoreMockRecorder) UpdateTokenBurn(ctx, input any) *gomock.Call

UpdateTokenBurn indicates an expected call of UpdateTokenBurn.

func (*MockStoreMockRecorder) UpdateTokenMediaHealthByURL added in v0.5.0 

func (mr *MockStoreMockRecorder) UpdateTokenMediaHealthByURL(ctx, url, status, lastError any) *gomock.Call

UpdateTokenMediaHealthByURL indicates an expected call of UpdateTokenMediaHealthByURL.

func (*MockStoreMockRecorder) UpdateTokenTransfer 

func (mr *MockStoreMockRecorder) UpdateTokenTransfer(ctx, input any) *gomock.Call

UpdateTokenTransfer indicates an expected call of UpdateTokenTransfer.

func (*MockStoreMockRecorder) UpdateWebhookDeliveryStatus added in v0.5.0 

func (mr *MockStoreMockRecorder) UpdateWebhookDeliveryStatus(ctx, deliveryID, status, attempts, responseStatus, responseBody, errorMessage any) *gomock.Call

UpdateWebhookDeliveryStatus indicates an expected call of UpdateWebhookDeliveryStatus.

func (*MockStoreMockRecorder) UpsertEnrichmentSource 

func (mr *MockStoreMockRecorder) UpsertEnrichmentSource(ctx, input any) *gomock.Call

UpsertEnrichmentSource indicates an expected call of UpsertEnrichmentSource.

func (*MockStoreMockRecorder) UpsertTokenBalanceForOwner added in v0.4.0 

func (mr *MockStoreMockRecorder) UpsertTokenBalanceForOwner(ctx, input any) *gomock.Call

UpsertTokenBalanceForOwner indicates an expected call of UpsertTokenBalanceForOwner.

func (*MockStoreMockRecorder) UpsertTokenMetadata 

func (mr *MockStoreMockRecorder) UpsertTokenMetadata(ctx, input any) *gomock.Call

UpsertTokenMetadata indicates an expected call of UpsertTokenMetadata.

type MockSweeper added in v0.5.0 

type MockSweeper struct {
	// contains filtered or unexported fields
}

MockSweeper is a mock of Sweeper interface.

func NewMockSweeper added in v0.5.0 

func NewMockSweeper(ctrl *gomock.Controller) *MockSweeper

NewMockSweeper creates a new mock instance.

func (*MockSweeper) EXPECT added in v0.5.0 

func (m *MockSweeper) EXPECT() *MockSweeperMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSweeper) Name added in v0.5.0 

func (m *MockSweeper) Name() string

Name mocks base method.

func (*MockSweeper) Start added in v0.5.0 

func (m *MockSweeper) Start(ctx context.Context) error

Start mocks base method.

func (*MockSweeper) Stop added in v0.5.0 

func (m *MockSweeper) Stop(ctx context.Context) error

Stop mocks base method.

type MockSweeperMockRecorder added in v0.5.0 

type MockSweeperMockRecorder struct {
	// contains filtered or unexported fields
}

MockSweeperMockRecorder is the mock recorder for MockSweeper.

func (*MockSweeperMockRecorder) Name added in v0.5.0 

func (mr *MockSweeperMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockSweeperMockRecorder) Start added in v0.5.0 

func (mr *MockSweeperMockRecorder) Start(ctx any) *gomock.Call

Start indicates an expected call of Start.

func (*MockSweeperMockRecorder) Stop added in v0.5.0 

func (mr *MockSweeperMockRecorder) Stop(ctx any) *gomock.Call

Stop indicates an expected call of Stop.

type MockTransformer added in v0.5.0 

type MockTransformer struct {
	// contains filtered or unexported fields
}

MockTransformer is a mock of Transformer interface.

func NewMockTransformer added in v0.5.0 

func NewMockTransformer(ctrl *gomock.Controller) *MockTransformer

NewMockTransformer creates a new mock instance.

func (*MockTransformer) Close added in v0.5.0 

func (m *MockTransformer) Close() error

Close mocks base method.

func (*MockTransformer) EXPECT added in v0.5.0 

func (m *MockTransformer) EXPECT() *MockTransformerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTransformer) Transform added in v0.5.0 

func (m *MockTransformer) Transform(ctx context.Context, input *transformer.TransformInput) (*transformer.TransformResult, error)

Transform mocks base method.

type MockTransformerMockRecorder added in v0.5.0 

type MockTransformerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTransformerMockRecorder is the mock recorder for MockTransformer.

func (*MockTransformerMockRecorder) Close added in v0.5.0 

func (mr *MockTransformerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTransformerMockRecorder) Transform added in v0.5.0 

func (mr *MockTransformerMockRecorder) Transform(ctx, input any) *gomock.Call

Transform indicates an expected call of Transform.

type MockTzKTClient 

type MockTzKTClient struct {
	// contains filtered or unexported fields
}

MockTzKTClient is a mock of TzKTClient interface.

func NewMockTzKTClient 

func NewMockTzKTClient(ctrl *gomock.Controller) *MockTzKTClient

NewMockTzKTClient creates a new mock instance.

func (*MockTzKTClient) ChainID 

func (m *MockTzKTClient) ChainID() domain.Chain

ChainID mocks base method.

func (*MockTzKTClient) EXPECT 

func (m *MockTzKTClient) EXPECT() *MockTzKTClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTzKTClient) GetContractDeployer 

func (m *MockTzKTClient) GetContractDeployer(ctx context.Context, contractAddress string) (string, error)

GetContractDeployer mocks base method.

func (*MockTzKTClient) GetLatestBlock 

func (m *MockTzKTClient) GetLatestBlock(ctx context.Context) (uint64, error)

GetLatestBlock mocks base method.

func (*MockTzKTClient) GetTokenBalances 

func (m *MockTzKTClient) GetTokenBalances(ctx context.Context, contractAddress, tokenID string) ([]tezos.TzKTTokenBalance, error)

GetTokenBalances mocks base method.

func (*MockTzKTClient) GetTokenBalancesByAccountWithinBlockRange 

func (m *MockTzKTClient) GetTokenBalancesByAccountWithinBlockRange(ctx context.Context, accountAddress string, fromBlock, toBlock uint64, limit, offset int) ([]tezos.TzKTTokenBalance, error)

GetTokenBalancesByAccountWithinBlockRange mocks base method.

func (*MockTzKTClient) GetTokenEvents 

func (m *MockTzKTClient) GetTokenEvents(ctx context.Context, contractAddress, tokenID string) ([]domain.BlockchainEvent, error)

GetTokenEvents mocks base method.

func (*MockTzKTClient) GetTokenMetadata 

func (m *MockTzKTClient) GetTokenMetadata(ctx context.Context, contractAddress, tokenID string) (map[string]any, error)

GetTokenMetadata mocks base method.

func (*MockTzKTClient) GetTokenMetadataUpdates 

func (m *MockTzKTClient) GetTokenMetadataUpdates(ctx context.Context, contractAddress, tokenID string) ([]tezos.TzKTBigMapUpdate, error)

GetTokenMetadataUpdates mocks base method.

func (*MockTzKTClient) GetTokenOwnerBalance 

func (m *MockTzKTClient) GetTokenOwnerBalance(ctx context.Context, contractAddress, tokenID, ownerAddress string) (string, error)

GetTokenOwnerBalance mocks base method.

func (*MockTzKTClient) GetTokenTransfers 

func (m *MockTzKTClient) GetTokenTransfers(ctx context.Context, contractAddress, tokenID string) ([]tezos.TzKTTokenTransfer, error)

GetTokenTransfers mocks base method.

func (*MockTzKTClient) GetTransactionsByID 

func (m *MockTzKTClient) GetTransactionsByID(ctx context.Context, txID uint64) ([]tezos.TzKTTransaction, error)

GetTransactionsByID mocks base method.

func (*MockTzKTClient) ParseBigMapUpdate 

func (m *MockTzKTClient) ParseBigMapUpdate(ctx context.Context, update *tezos.TzKTBigMapUpdate) (*domain.BlockchainEvent, error)

ParseBigMapUpdate mocks base method.

func (*MockTzKTClient) ParseTransfer 

func (m *MockTzKTClient) ParseTransfer(ctx context.Context, transfer *tezos.TzKTTokenTransfer) (*domain.BlockchainEvent, error)

ParseTransfer mocks base method.

type MockTzKTClientMockRecorder 

type MockTzKTClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockTzKTClientMockRecorder is the mock recorder for MockTzKTClient.

func (*MockTzKTClientMockRecorder) ChainID 

func (mr *MockTzKTClientMockRecorder) ChainID() *gomock.Call

ChainID indicates an expected call of ChainID.

func (*MockTzKTClientMockRecorder) GetContractDeployer 

func (mr *MockTzKTClientMockRecorder) GetContractDeployer(ctx, contractAddress any) *gomock.Call

GetContractDeployer indicates an expected call of GetContractDeployer.

func (*MockTzKTClientMockRecorder) GetLatestBlock 

func (mr *MockTzKTClientMockRecorder) GetLatestBlock(ctx any) *gomock.Call

GetLatestBlock indicates an expected call of GetLatestBlock.

func (*MockTzKTClientMockRecorder) GetTokenBalances 

func (mr *MockTzKTClientMockRecorder) GetTokenBalances(ctx, contractAddress, tokenID any) *gomock.Call

GetTokenBalances indicates an expected call of GetTokenBalances.

func (*MockTzKTClientMockRecorder) GetTokenBalancesByAccountWithinBlockRange 

func (mr *MockTzKTClientMockRecorder) GetTokenBalancesByAccountWithinBlockRange(ctx, accountAddress, fromBlock, toBlock, limit, offset any) *gomock.Call

GetTokenBalancesByAccountWithinBlockRange indicates an expected call of GetTokenBalancesByAccountWithinBlockRange.

func (*MockTzKTClientMockRecorder) GetTokenEvents 

func (mr *MockTzKTClientMockRecorder) GetTokenEvents(ctx, contractAddress, tokenID any) *gomock.Call

GetTokenEvents indicates an expected call of GetTokenEvents.

func (*MockTzKTClientMockRecorder) GetTokenMetadata 

func (mr *MockTzKTClientMockRecorder) GetTokenMetadata(ctx, contractAddress, tokenID any) *gomock.Call

GetTokenMetadata indicates an expected call of GetTokenMetadata.

func (*MockTzKTClientMockRecorder) GetTokenMetadataUpdates 

func (mr *MockTzKTClientMockRecorder) GetTokenMetadataUpdates(ctx, contractAddress, tokenID any) *gomock.Call

GetTokenMetadataUpdates indicates an expected call of GetTokenMetadataUpdates.

func (*MockTzKTClientMockRecorder) GetTokenOwnerBalance 

func (mr *MockTzKTClientMockRecorder) GetTokenOwnerBalance(ctx, contractAddress, tokenID, ownerAddress any) *gomock.Call

GetTokenOwnerBalance indicates an expected call of GetTokenOwnerBalance.

func (*MockTzKTClientMockRecorder) GetTokenTransfers 

func (mr *MockTzKTClientMockRecorder) GetTokenTransfers(ctx, contractAddress, tokenID any) *gomock.Call

GetTokenTransfers indicates an expected call of GetTokenTransfers.

func (*MockTzKTClientMockRecorder) GetTransactionsByID 

func (mr *MockTzKTClientMockRecorder) GetTransactionsByID(ctx, txID any) *gomock.Call

GetTransactionsByID indicates an expected call of GetTransactionsByID.

func (*MockTzKTClientMockRecorder) ParseBigMapUpdate 

func (mr *MockTzKTClientMockRecorder) ParseBigMapUpdate(ctx, update any) *gomock.Call

ParseBigMapUpdate indicates an expected call of ParseBigMapUpdate.

func (*MockTzKTClientMockRecorder) ParseTransfer 

func (mr *MockTzKTClientMockRecorder) ParseTransfer(ctx, transfer any) *gomock.Call

ParseTransfer indicates an expected call of ParseTransfer.

type MockURIResolver 

type MockURIResolver struct {
	// contains filtered or unexported fields
}

MockURIResolver is a mock of Resolver interface.

func NewMockURIResolver 

func NewMockURIResolver(ctrl *gomock.Controller) *MockURIResolver

NewMockURIResolver creates a new mock instance.

func (*MockURIResolver) EXPECT 

func (m *MockURIResolver) EXPECT() *MockURIResolverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockURIResolver) Resolve 

func (m *MockURIResolver) Resolve(ctx context.Context, uri string) (string, error)

Resolve mocks base method.

type MockURIResolverMockRecorder 

type MockURIResolverMockRecorder struct {
	// contains filtered or unexported fields
}

MockURIResolverMockRecorder is the mock recorder for MockURIResolver.

func (*MockURIResolverMockRecorder) Resolve 

func (mr *MockURIResolverMockRecorder) Resolve(ctx, uri any) *gomock.Call

Resolve indicates an expected call of Resolve.

type MockURLChecker added in v0.5.0 

type MockURLChecker struct {
	// contains filtered or unexported fields
}

MockURLChecker is a mock of URLChecker interface.

func NewMockURLChecker added in v0.5.0 

func NewMockURLChecker(ctrl *gomock.Controller) *MockURLChecker

NewMockURLChecker creates a new mock instance.

func (*MockURLChecker) Check added in v0.5.0 

func (m *MockURLChecker) Check(ctx context.Context, url string) uri.HealthCheckResult

Check mocks base method.

func (*MockURLChecker) EXPECT added in v0.5.0 

func (m *MockURLChecker) EXPECT() *MockURLCheckerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockURLCheckerMockRecorder added in v0.5.0 

type MockURLCheckerMockRecorder struct {
	// contains filtered or unexported fields
}

MockURLCheckerMockRecorder is the mock recorder for MockURLChecker.

func (*MockURLCheckerMockRecorder) Check added in v0.5.0 

func (mr *MockURLCheckerMockRecorder) Check(ctx, url any) *gomock.Call

Check indicates an expected call of Check.

type MockVipsClient added in v0.5.0 

type MockVipsClient struct {
	// contains filtered or unexported fields
}

MockVipsClient is a mock of VipsClient interface.

func NewMockVipsClient added in v0.5.0 

func NewMockVipsClient(ctrl *gomock.Controller) *MockVipsClient

NewMockVipsClient creates a new mock instance.

func (*MockVipsClient) EXPECT added in v0.5.0 

func (m *MockVipsClient) EXPECT() *MockVipsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockVipsClient) NewImageFromSource added in v0.5.0 

func (m *MockVipsClient) NewImageFromSource(source adapter.VipsSource, options *vips.LoadOptions) (adapter.VipsImage, error)

NewImageFromSource mocks base method.

func (*MockVipsClient) NewSource added in v0.5.0 

func (m *MockVipsClient) NewSource(reader io.ReadCloser) adapter.VipsSource

NewSource mocks base method.

func (*MockVipsClient) Shutdown added in v0.5.0 

func (m *MockVipsClient) Shutdown()

Shutdown mocks base method.

func (*MockVipsClient) Startup added in v0.5.0 

func (m *MockVipsClient) Startup(config *vips.Config)

Startup mocks base method.

type MockVipsClientMockRecorder added in v0.5.0 

type MockVipsClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockVipsClientMockRecorder is the mock recorder for MockVipsClient.

func (*MockVipsClientMockRecorder) NewImageFromSource added in v0.5.0 

func (mr *MockVipsClientMockRecorder) NewImageFromSource(source, options any) *gomock.Call

NewImageFromSource indicates an expected call of NewImageFromSource.

func (*MockVipsClientMockRecorder) NewSource added in v0.5.0 

func (mr *MockVipsClientMockRecorder) NewSource(reader any) *gomock.Call

NewSource indicates an expected call of NewSource.

func (*MockVipsClientMockRecorder) Shutdown added in v0.5.0 

func (mr *MockVipsClientMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockVipsClientMockRecorder) Startup added in v0.5.0 

func (mr *MockVipsClientMockRecorder) Startup(config any) *gomock.Call

Startup indicates an expected call of Startup.

type MockVipsImage added in v0.5.0 

type MockVipsImage struct {
	// contains filtered or unexported fields
}

MockVipsImage is a mock of VipsImage interface.

func NewMockVipsImage added in v0.5.0 

func NewMockVipsImage(ctrl *gomock.Controller) *MockVipsImage

NewMockVipsImage creates a new mock instance.

func (*MockVipsImage) Close added in v0.5.0 

func (m *MockVipsImage) Close()

Close mocks base method.

func (*MockVipsImage) EXPECT added in v0.5.0 

func (m *MockVipsImage) EXPECT() *MockVipsImageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockVipsImage) ExtractArea added in v0.5.0 

func (m *MockVipsImage) ExtractArea(left, top, width, height int) error

ExtractArea mocks base method.

func (*MockVipsImage) GetArrayInt added in v0.5.0 

func (m *MockVipsImage) GetArrayInt(name string) ([]int, error)

GetArrayInt mocks base method.

func (*MockVipsImage) GetFields added in v0.5.0 

func (m *MockVipsImage) GetFields() []string

GetFields mocks base method.

func (*MockVipsImage) GetInt added in v0.5.0 

func (m *MockVipsImage) GetInt(name string) (int, error)

GetInt mocks base method.

func (*MockVipsImage) HasAlpha added in v0.5.0 

func (m *MockVipsImage) HasAlpha() bool

HasAlpha mocks base method.

func (*MockVipsImage) Height added in v0.5.0 

func (m *MockVipsImage) Height() int

Height mocks base method.

func (*MockVipsImage) JpegsaveBuffer added in v0.5.0 

func (m *MockVipsImage) JpegsaveBuffer(options *vips.JpegsaveBufferOptions) ([]byte, error)

JpegsaveBuffer mocks base method.

func (*MockVipsImage) PageHeight added in v0.5.0 

func (m *MockVipsImage) PageHeight() int

PageHeight mocks base method.

func (*MockVipsImage) Pages added in v0.5.0 

func (m *MockVipsImage) Pages() int

Pages mocks base method.

func (*MockVipsImage) Resize added in v0.5.0 

func (m *MockVipsImage) Resize(scale float64, options *vips.ResizeOptions) error

Resize mocks base method.

func (*MockVipsImage) SetArrayInt added in v0.5.0 

func (m *MockVipsImage) SetArrayInt(name string, values []int) error

SetArrayInt mocks base method.

func (*MockVipsImage) SetInt added in v0.5.0 

func (m *MockVipsImage) SetInt(name string, i int)

SetInt mocks base method.

func (*MockVipsImage) SetPageHeight added in v0.5.0 

func (m *MockVipsImage) SetPageHeight(height int) error

SetPageHeight mocks base method.

func (*MockVipsImage) WebpsaveBuffer added in v0.5.0 

func (m *MockVipsImage) WebpsaveBuffer(options *vips.WebpsaveBufferOptions) ([]byte, error)

WebpsaveBuffer mocks base method.

func (*MockVipsImage) Width added in v0.5.0 

func (m *MockVipsImage) Width() int

Width mocks base method.

type MockVipsImageMockRecorder added in v0.5.0 

type MockVipsImageMockRecorder struct {
	// contains filtered or unexported fields
}

MockVipsImageMockRecorder is the mock recorder for MockVipsImage.

func (*MockVipsImageMockRecorder) Close added in v0.5.0 

func (mr *MockVipsImageMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockVipsImageMockRecorder) ExtractArea added in v0.5.0 

func (mr *MockVipsImageMockRecorder) ExtractArea(left, top, width, height any) *gomock.Call

ExtractArea indicates an expected call of ExtractArea.

func (*MockVipsImageMockRecorder) GetArrayInt added in v0.5.0 

func (mr *MockVipsImageMockRecorder) GetArrayInt(name any) *gomock.Call

GetArrayInt indicates an expected call of GetArrayInt.

func (*MockVipsImageMockRecorder) GetFields added in v0.5.0 

func (mr *MockVipsImageMockRecorder) GetFields() *gomock.Call

GetFields indicates an expected call of GetFields.

func (*MockVipsImageMockRecorder) GetInt added in v0.5.0 

func (mr *MockVipsImageMockRecorder) GetInt(name any) *gomock.Call

GetInt indicates an expected call of GetInt.

func (*MockVipsImageMockRecorder) HasAlpha added in v0.5.0 

func (mr *MockVipsImageMockRecorder) HasAlpha() *gomock.Call

HasAlpha indicates an expected call of HasAlpha.

func (*MockVipsImageMockRecorder) Height added in v0.5.0 

func (mr *MockVipsImageMockRecorder) Height() *gomock.Call

Height indicates an expected call of Height.

func (*MockVipsImageMockRecorder) JpegsaveBuffer added in v0.5.0 

func (mr *MockVipsImageMockRecorder) JpegsaveBuffer(options any) *gomock.Call

JpegsaveBuffer indicates an expected call of JpegsaveBuffer.

func (*MockVipsImageMockRecorder) PageHeight added in v0.5.0 

func (mr *MockVipsImageMockRecorder) PageHeight() *gomock.Call

PageHeight indicates an expected call of PageHeight.

func (*MockVipsImageMockRecorder) Pages added in v0.5.0 

func (mr *MockVipsImageMockRecorder) Pages() *gomock.Call

Pages indicates an expected call of Pages.

func (*MockVipsImageMockRecorder) Resize added in v0.5.0 

func (mr *MockVipsImageMockRecorder) Resize(scale, options any) *gomock.Call

Resize indicates an expected call of Resize.

func (*MockVipsImageMockRecorder) SetArrayInt added in v0.5.0 

func (mr *MockVipsImageMockRecorder) SetArrayInt(name, values any) *gomock.Call

SetArrayInt indicates an expected call of SetArrayInt.

func (*MockVipsImageMockRecorder) SetInt added in v0.5.0 

func (mr *MockVipsImageMockRecorder) SetInt(name, i any) *gomock.Call

SetInt indicates an expected call of SetInt.

func (*MockVipsImageMockRecorder) SetPageHeight added in v0.5.0 

func (mr *MockVipsImageMockRecorder) SetPageHeight(height any) *gomock.Call

SetPageHeight indicates an expected call of SetPageHeight.

func (*MockVipsImageMockRecorder) WebpsaveBuffer added in v0.5.0 

func (mr *MockVipsImageMockRecorder) WebpsaveBuffer(options any) *gomock.Call

WebpsaveBuffer indicates an expected call of WebpsaveBuffer.

func (*MockVipsImageMockRecorder) Width added in v0.5.0 

func (mr *MockVipsImageMockRecorder) Width() *gomock.Call

Width indicates an expected call of Width.

type MockVipsSource added in v0.5.0 

type MockVipsSource struct {
	// contains filtered or unexported fields
}

MockVipsSource is a mock of VipsSource interface.

func NewMockVipsSource added in v0.5.0 

func NewMockVipsSource(ctrl *gomock.Controller) *MockVipsSource

NewMockVipsSource creates a new mock instance.

func (*MockVipsSource) Close added in v0.5.0 

func (m *MockVipsSource) Close()

Close mocks base method.

func (*MockVipsSource) EXPECT added in v0.5.0 

func (m *MockVipsSource) EXPECT() *MockVipsSourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockVipsSourceMockRecorder added in v0.5.0 

type MockVipsSourceMockRecorder struct {
	// contains filtered or unexported fields
}

MockVipsSourceMockRecorder is the mock recorder for MockVipsSource.

func (*MockVipsSourceMockRecorder) Close added in v0.5.0 

func (mr *MockVipsSourceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

type MockXML added in v0.5.0 

type MockXML struct {
	// contains filtered or unexported fields
}

MockXML is a mock of XML interface.

func NewMockXML added in v0.5.0 

func NewMockXML(ctrl *gomock.Controller) *MockXML

NewMockXML creates a new mock instance.

func (*MockXML) EXPECT added in v0.5.0 

func (m *MockXML) EXPECT() *MockXMLMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockXML) Unmarshal added in v0.5.0 

func (m *MockXML) Unmarshal(data []byte, v any) error

Unmarshal mocks base method.

type MockXMLMockRecorder added in v0.5.0 

type MockXMLMockRecorder struct {
	// contains filtered or unexported fields
}

MockXMLMockRecorder is the mock recorder for MockXML.

func (*MockXMLMockRecorder) Unmarshal added in v0.5.0 

func (mr *MockXMLMockRecorder) Unmarshal(data, v any) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

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.