mocks

Aug 19, 2024

Changes in this version

type BridgeAccessor

+ func (_m *BridgeAccessor) EXPECT() *BridgeAccessor_Expecter

+ type BridgeAccessor_Expecter struct

+ func (_e *BridgeAccessor_Expecter) NewExternalAdapterClient(_a0 interface{}) *BridgeAccessor_NewExternalAdapterClient_Call

+ type BridgeAccessor_NewExternalAdapterClient_Call struct

+ func (_c *BridgeAccessor_NewExternalAdapterClient_Call) Return(_a0 functions.ExternalAdapterClient, _a1 error) *BridgeAccessor_NewExternalAdapterClient_Call

+ func (_c *BridgeAccessor_NewExternalAdapterClient_Call) Run(run func(_a0 context.Context)) *BridgeAccessor_NewExternalAdapterClient_Call

+ func (_c *BridgeAccessor_NewExternalAdapterClient_Call) RunAndReturn(run func(context.Context) (functions.ExternalAdapterClient, error)) *BridgeAccessor_NewExternalAdapterClient_Call

type ExternalAdapterClient

+ func (_m *ExternalAdapterClient) EXPECT() *ExternalAdapterClient_Expecter

+ type ExternalAdapterClient_Expecter struct

+ func (_e *ExternalAdapterClient_Expecter) FetchEncryptedSecrets(ctx interface{}, encryptedSecretsUrls interface{}, requestId interface{}, ...) *ExternalAdapterClient_FetchEncryptedSecrets_Call

+ func (_e *ExternalAdapterClient_Expecter) RunComputation(ctx interface{}, requestId interface{}, jobName interface{}, ...) *ExternalAdapterClient_RunComputation_Call

+ type ExternalAdapterClient_FetchEncryptedSecrets_Call struct

+ func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) Return(encryptedSecrets []byte, userError []byte, err error) *ExternalAdapterClient_FetchEncryptedSecrets_Call

+ func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) Run(...) *ExternalAdapterClient_FetchEncryptedSecrets_Call

+ func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) RunAndReturn(run func(context.Context, []byte, string, string) ([]byte, []byte, error)) *ExternalAdapterClient_FetchEncryptedSecrets_Call

+ type ExternalAdapterClient_RunComputation_Call struct

+ func (_c *ExternalAdapterClient_RunComputation_Call) Return(userResult []byte, userError []byte, domains []string, err error) *ExternalAdapterClient_RunComputation_Call

+ func (_c *ExternalAdapterClient_RunComputation_Call) Run(run func(ctx context.Context, requestId string, jobName string, ...)) *ExternalAdapterClient_RunComputation_Call

+ func (_c *ExternalAdapterClient_RunComputation_Call) RunAndReturn(...) *ExternalAdapterClient_RunComputation_Call

type FunctionsListener

+ func (_m *FunctionsListener) EXPECT() *FunctionsListener_Expecter

+ type FunctionsListener_Close_Call struct

+ func (_c *FunctionsListener_Close_Call) Return(_a0 error) *FunctionsListener_Close_Call

+ func (_c *FunctionsListener_Close_Call) Run(run func()) *FunctionsListener_Close_Call

+ func (_c *FunctionsListener_Close_Call) RunAndReturn(run func() error) *FunctionsListener_Close_Call

+ type FunctionsListener_Expecter struct

+ func (_e *FunctionsListener_Expecter) Close() *FunctionsListener_Close_Call

+ func (_e *FunctionsListener_Expecter) HandleOffchainRequest(ctx interface{}, request interface{}) *FunctionsListener_HandleOffchainRequest_Call

+ func (_e *FunctionsListener_Expecter) Start(_a0 interface{}) *FunctionsListener_Start_Call

+ type FunctionsListener_HandleOffchainRequest_Call struct

+ func (_c *FunctionsListener_HandleOffchainRequest_Call) Return(_a0 error) *FunctionsListener_HandleOffchainRequest_Call

+ func (_c *FunctionsListener_HandleOffchainRequest_Call) Run(run func(ctx context.Context, request *functions.OffchainRequest)) *FunctionsListener_HandleOffchainRequest_Call

+ func (_c *FunctionsListener_HandleOffchainRequest_Call) RunAndReturn(run func(context.Context, *functions.OffchainRequest) error) *FunctionsListener_HandleOffchainRequest_Call

+ type FunctionsListener_Start_Call struct

+ func (_c *FunctionsListener_Start_Call) Return(_a0 error) *FunctionsListener_Start_Call

+ func (_c *FunctionsListener_Start_Call) Run(run func(_a0 context.Context)) *FunctionsListener_Start_Call

+ func (_c *FunctionsListener_Start_Call) RunAndReturn(run func(context.Context) error) *FunctionsListener_Start_Call

type ORM

+ func (_m *ORM) EXPECT() *ORM_Expecter

+ type ORM_CreateRequest_Call struct

+ func (_c *ORM_CreateRequest_Call) Return(_a0 error) *ORM_CreateRequest_Call

+ func (_c *ORM_CreateRequest_Call) Run(run func(ctx context.Context, request *functions.Request)) *ORM_CreateRequest_Call

+ func (_c *ORM_CreateRequest_Call) RunAndReturn(run func(context.Context, *functions.Request) error) *ORM_CreateRequest_Call

+ type ORM_Expecter struct

+ func (_e *ORM_Expecter) CreateRequest(ctx interface{}, request interface{}) *ORM_CreateRequest_Call

+ func (_e *ORM_Expecter) FindById(ctx interface{}, requestID interface{}) *ORM_FindById_Call

+ func (_e *ORM_Expecter) FindOldestEntriesByState(ctx interface{}, state interface{}, limit interface{}) *ORM_FindOldestEntriesByState_Call

+ func (_e *ORM_Expecter) PruneOldestRequests(ctx interface{}, maxRequestsInDB interface{}, batchSize interface{}) *ORM_PruneOldestRequests_Call

+ func (_e *ORM_Expecter) SetConfirmed(ctx interface{}, requestID interface{}) *ORM_SetConfirmed_Call

+ func (_e *ORM_Expecter) SetError(ctx interface{}, requestID interface{}, errorType interface{}, ...) *ORM_SetError_Call

+ func (_e *ORM_Expecter) SetFinalized(ctx interface{}, requestID interface{}, reportedResult interface{}, ...) *ORM_SetFinalized_Call

+ func (_e *ORM_Expecter) SetResult(ctx interface{}, requestID interface{}, computationResult interface{}, ...) *ORM_SetResult_Call

+ func (_e *ORM_Expecter) TimeoutExpiredResults(ctx interface{}, cutoff interface{}, limit interface{}) *ORM_TimeoutExpiredResults_Call

+ type ORM_FindById_Call struct

+ func (_c *ORM_FindById_Call) Return(_a0 *functions.Request, _a1 error) *ORM_FindById_Call

+ func (_c *ORM_FindById_Call) Run(run func(ctx context.Context, requestID functions.RequestID)) *ORM_FindById_Call

+ func (_c *ORM_FindById_Call) RunAndReturn(run func(context.Context, functions.RequestID) (*functions.Request, error)) *ORM_FindById_Call

+ type ORM_FindOldestEntriesByState_Call struct

+ func (_c *ORM_FindOldestEntriesByState_Call) Return(_a0 []functions.Request, _a1 error) *ORM_FindOldestEntriesByState_Call

+ func (_c *ORM_FindOldestEntriesByState_Call) Run(run func(ctx context.Context, state functions.RequestState, limit uint32)) *ORM_FindOldestEntriesByState_Call

+ func (_c *ORM_FindOldestEntriesByState_Call) RunAndReturn(...) *ORM_FindOldestEntriesByState_Call

+ type ORM_PruneOldestRequests_Call struct

+ func (_c *ORM_PruneOldestRequests_Call) Return(total uint32, pruned uint32, err error) *ORM_PruneOldestRequests_Call

+ func (_c *ORM_PruneOldestRequests_Call) Run(run func(ctx context.Context, maxRequestsInDB uint32, batchSize uint32)) *ORM_PruneOldestRequests_Call

+ func (_c *ORM_PruneOldestRequests_Call) RunAndReturn(run func(context.Context, uint32, uint32) (uint32, uint32, error)) *ORM_PruneOldestRequests_Call

+ type ORM_SetConfirmed_Call struct

+ func (_c *ORM_SetConfirmed_Call) Return(_a0 error) *ORM_SetConfirmed_Call

+ func (_c *ORM_SetConfirmed_Call) Run(run func(ctx context.Context, requestID functions.RequestID)) *ORM_SetConfirmed_Call

+ func (_c *ORM_SetConfirmed_Call) RunAndReturn(run func(context.Context, functions.RequestID) error) *ORM_SetConfirmed_Call

+ type ORM_SetError_Call struct

+ func (_c *ORM_SetError_Call) Return(_a0 error) *ORM_SetError_Call

+ func (_c *ORM_SetError_Call) Run(run func(ctx context.Context, requestID functions.RequestID, ...)) *ORM_SetError_Call

+ func (_c *ORM_SetError_Call) RunAndReturn(...) *ORM_SetError_Call

+ type ORM_SetFinalized_Call struct

+ func (_c *ORM_SetFinalized_Call) Return(_a0 error) *ORM_SetFinalized_Call

+ func (_c *ORM_SetFinalized_Call) Run(...) *ORM_SetFinalized_Call

+ func (_c *ORM_SetFinalized_Call) RunAndReturn(run func(context.Context, functions.RequestID, []byte, []byte) error) *ORM_SetFinalized_Call

+ type ORM_SetResult_Call struct

+ func (_c *ORM_SetResult_Call) Return(_a0 error) *ORM_SetResult_Call

+ func (_c *ORM_SetResult_Call) Run(...) *ORM_SetResult_Call

+ func (_c *ORM_SetResult_Call) RunAndReturn(run func(context.Context, functions.RequestID, []byte, time.Time) error) *ORM_SetResult_Call

+ type ORM_TimeoutExpiredResults_Call struct

+ func (_c *ORM_TimeoutExpiredResults_Call) Return(_a0 []functions.RequestID, _a1 error) *ORM_TimeoutExpiredResults_Call

+ func (_c *ORM_TimeoutExpiredResults_Call) Run(run func(ctx context.Context, cutoff time.Time, limit uint32)) *ORM_TimeoutExpiredResults_Call

+ func (_c *ORM_TimeoutExpiredResults_Call) RunAndReturn(run func(context.Context, time.Time, uint32) ([]functions.RequestID, error)) *ORM_TimeoutExpiredResults_Call

type OffchainTransmitter

+ func (_m *OffchainTransmitter) EXPECT() *OffchainTransmitter_Expecter

+ type OffchainTransmitter_Expecter struct

+ func (_e *OffchainTransmitter_Expecter) ReportChannel() *OffchainTransmitter_ReportChannel_Call

+ func (_e *OffchainTransmitter_Expecter) TransmitReport(ctx interface{}, report interface{}) *OffchainTransmitter_TransmitReport_Call

+ type OffchainTransmitter_ReportChannel_Call struct

+ func (_c *OffchainTransmitter_ReportChannel_Call) Return(_a0 chan *functions.OffchainResponse) *OffchainTransmitter_ReportChannel_Call

+ func (_c *OffchainTransmitter_ReportChannel_Call) Run(run func()) *OffchainTransmitter_ReportChannel_Call

+ func (_c *OffchainTransmitter_ReportChannel_Call) RunAndReturn(run func() chan *functions.OffchainResponse) *OffchainTransmitter_ReportChannel_Call

+ type OffchainTransmitter_TransmitReport_Call struct

+ func (_c *OffchainTransmitter_TransmitReport_Call) Return(_a0 error) *OffchainTransmitter_TransmitReport_Call

+ func (_c *OffchainTransmitter_TransmitReport_Call) Run(run func(ctx context.Context, report *functions.OffchainResponse)) *OffchainTransmitter_TransmitReport_Call

+ func (_c *OffchainTransmitter_TransmitReport_Call) RunAndReturn(run func(context.Context, *functions.OffchainResponse) error) *OffchainTransmitter_TransmitReport_Call

Jan 24, 2024

Changes in this version

+ type FunctionsListener struct

+ func NewFunctionsListener(t interface{ ... }) *FunctionsListener

+ func (_m *FunctionsListener) Close() error

+ func (_m *FunctionsListener) HandleOffchainRequest(ctx context.Context, request *functions.OffchainRequest) error

+ func (_m *FunctionsListener) Start(_a0 context.Context) error

+ type OffchainTransmitter struct

+ func NewOffchainTransmitter(t interface{ ... }) *OffchainTransmitter

+ func (_m *OffchainTransmitter) ReportChannel() chan *functions.OffchainResponse

+ func (_m *OffchainTransmitter) TransmitReport(ctx context.Context, report *functions.OffchainResponse) error

Jul 28, 2023

Changes in this version

+ type BridgeAccessor struct

+ func NewBridgeAccessor(t mockConstructorTestingTNewBridgeAccessor) *BridgeAccessor

+ func (_m *BridgeAccessor) NewExternalAdapterClient() (functions.ExternalAdapterClient, error)

+ type ExternalAdapterClient struct

+ func NewExternalAdapterClient(t mockConstructorTestingTNewExternalAdapterClient) *ExternalAdapterClient

+ func (_m *ExternalAdapterClient) FetchEncryptedSecrets(ctx context.Context, encryptedSecretsUrls []byte, requestId string, ...) ([]byte, []byte, error)

+ func (_m *ExternalAdapterClient) RunComputation(ctx context.Context, requestId string, jobName string, ...) ([]byte, []byte, []string, error)

type ORM

+ func (_m *ORM) PruneOldestRequests(maxRequestsInDB uint32, batchSize uint32, qopts ...pg.QOpt) (uint32, uint32, error)

Apr 21, 2023

Changes in this version

+ type ORM struct

+ func NewORM(t mockConstructorTestingTNewORM) *ORM

+ func (_m *ORM) CreateRequest(requestID functions.RequestID, receivedAt time.Time, ...) error

+ func (_m *ORM) FindById(requestID functions.RequestID, qopts ...pg.QOpt) (*functions.Request, error)

+ func (_m *ORM) FindOldestEntriesByState(state functions.RequestState, limit uint32, qopts ...pg.QOpt) ([]functions.Request, error)

+ func (_m *ORM) SetConfirmed(requestID functions.RequestID, qopts ...pg.QOpt) error

+ func (_m *ORM) SetError(requestID functions.RequestID, runID int64, errorType functions.ErrType, ...) error

+ func (_m *ORM) SetFinalized(requestID functions.RequestID, reportedResult []byte, reportedError []byte, ...) error

+ func (_m *ORM) SetResult(requestID functions.RequestID, runID int64, computationResult []byte, ...) error

+ func (_m *ORM) TimeoutExpiredResults(cutoff time.Time, limit uint32, qopts ...pg.QOpt) ([]functions.RequestID, error)