Documentation ¶
Index ¶
- type BridgeAccessor
- type BridgeAccessor_Expecter
- type BridgeAccessor_NewExternalAdapterClient_Call
- 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
- 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 ExternalAdapterClient_Expecter
- 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
- 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
- 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
- type FunctionsListener_Close_Call
- type FunctionsListener_Expecter
- 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
- 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
- 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) CreateRequest(ctx context.Context, request *functions.Request) error
- func (_m *ORM) EXPECT() *ORM_Expecter
- func (_m *ORM) FindById(ctx context.Context, requestID functions.RequestID) (*functions.Request, error)
- func (_m *ORM) FindOldestEntriesByState(ctx context.Context, state functions.RequestState, limit uint32) ([]functions.Request, error)
- func (_m *ORM) PruneOldestRequests(ctx context.Context, maxRequestsInDB uint32, batchSize uint32) (uint32, uint32, error)
- func (_m *ORM) SetConfirmed(ctx context.Context, requestID functions.RequestID) error
- func (_m *ORM) SetError(ctx context.Context, requestID functions.RequestID, ...) error
- func (_m *ORM) SetFinalized(ctx context.Context, requestID functions.RequestID, reportedResult []byte, ...) error
- func (_m *ORM) SetResult(ctx context.Context, requestID functions.RequestID, computationResult []byte, ...) error
- func (_m *ORM) TimeoutExpiredResults(ctx context.Context, cutoff time.Time, limit uint32) ([]functions.RequestID, error)
- type ORM_CreateRequest_Call
- 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
- 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
- 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
- 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
- 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
- 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
- type ORM_SetFinalized_Call
- type ORM_SetResult_Call
- type ORM_TimeoutExpiredResults_Call
- 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
- type OffchainTransmitter_Expecter
- type OffchainTransmitter_ReportChannel_Call
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BridgeAccessor ¶ added in v2.3.0
BridgeAccessor is an autogenerated mock type for the BridgeAccessor type
func NewBridgeAccessor ¶ added in v2.3.0
func NewBridgeAccessor(t interface { mock.TestingT Cleanup(func()) }) *BridgeAccessor
NewBridgeAccessor creates a new instance of BridgeAccessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*BridgeAccessor) EXPECT ¶ added in v2.15.0
func (_m *BridgeAccessor) EXPECT() *BridgeAccessor_Expecter
func (*BridgeAccessor) NewExternalAdapterClient ¶ added in v2.3.0
func (_m *BridgeAccessor) NewExternalAdapterClient(_a0 context.Context) (functions.ExternalAdapterClient, error)
NewExternalAdapterClient provides a mock function with given fields: _a0
type BridgeAccessor_Expecter ¶ added in v2.15.0
type BridgeAccessor_Expecter struct {
// contains filtered or unexported fields
}
func (*BridgeAccessor_Expecter) NewExternalAdapterClient ¶ added in v2.15.0
func (_e *BridgeAccessor_Expecter) NewExternalAdapterClient(_a0 interface{}) *BridgeAccessor_NewExternalAdapterClient_Call
NewExternalAdapterClient is a helper method to define mock.On call
- _a0 context.Context
type BridgeAccessor_NewExternalAdapterClient_Call ¶ added in v2.15.0
BridgeAccessor_NewExternalAdapterClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewExternalAdapterClient'
func (*BridgeAccessor_NewExternalAdapterClient_Call) Return ¶ added in v2.15.0
func (_c *BridgeAccessor_NewExternalAdapterClient_Call) Return(_a0 functions.ExternalAdapterClient, _a1 error) *BridgeAccessor_NewExternalAdapterClient_Call
func (*BridgeAccessor_NewExternalAdapterClient_Call) Run ¶ added in v2.15.0
func (_c *BridgeAccessor_NewExternalAdapterClient_Call) Run(run func(_a0 context.Context)) *BridgeAccessor_NewExternalAdapterClient_Call
func (*BridgeAccessor_NewExternalAdapterClient_Call) RunAndReturn ¶ added in v2.15.0
func (_c *BridgeAccessor_NewExternalAdapterClient_Call) RunAndReturn(run func(context.Context) (functions.ExternalAdapterClient, error)) *BridgeAccessor_NewExternalAdapterClient_Call
type ExternalAdapterClient ¶ added in v2.3.0
ExternalAdapterClient is an autogenerated mock type for the ExternalAdapterClient type
func NewExternalAdapterClient ¶ added in v2.3.0
func NewExternalAdapterClient(t interface { mock.TestingT Cleanup(func()) }) *ExternalAdapterClient
NewExternalAdapterClient creates a new instance of ExternalAdapterClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ExternalAdapterClient) EXPECT ¶ added in v2.15.0
func (_m *ExternalAdapterClient) EXPECT() *ExternalAdapterClient_Expecter
func (*ExternalAdapterClient) FetchEncryptedSecrets ¶ added in v2.3.0
func (_m *ExternalAdapterClient) FetchEncryptedSecrets(ctx context.Context, encryptedSecretsUrls []byte, requestId string, jobName string) ([]byte, []byte, error)
FetchEncryptedSecrets provides a mock function with given fields: ctx, encryptedSecretsUrls, requestId, jobName
func (*ExternalAdapterClient) RunComputation ¶ added in v2.3.0
func (_m *ExternalAdapterClient) RunComputation(ctx context.Context, requestId string, jobName string, subscriptionOwner string, subscriptionId uint64, flags functions.RequestFlags, nodeProvidedSecrets string, requestData *functions.RequestData) ([]byte, []byte, []string, error)
RunComputation provides a mock function with given fields: ctx, requestId, jobName, subscriptionOwner, subscriptionId, flags, nodeProvidedSecrets, requestData
type ExternalAdapterClient_Expecter ¶ added in v2.15.0
type ExternalAdapterClient_Expecter struct {
// contains filtered or unexported fields
}
func (*ExternalAdapterClient_Expecter) FetchEncryptedSecrets ¶ added in v2.15.0
func (_e *ExternalAdapterClient_Expecter) FetchEncryptedSecrets(ctx interface{}, encryptedSecretsUrls interface{}, requestId interface{}, jobName interface{}) *ExternalAdapterClient_FetchEncryptedSecrets_Call
FetchEncryptedSecrets is a helper method to define mock.On call
- ctx context.Context
- encryptedSecretsUrls []byte
- requestId string
- jobName string
func (*ExternalAdapterClient_Expecter) RunComputation ¶ added in v2.15.0
func (_e *ExternalAdapterClient_Expecter) RunComputation(ctx interface{}, requestId interface{}, jobName interface{}, subscriptionOwner interface{}, subscriptionId interface{}, flags interface{}, nodeProvidedSecrets interface{}, requestData interface{}) *ExternalAdapterClient_RunComputation_Call
RunComputation is a helper method to define mock.On call
- ctx context.Context
- requestId string
- jobName string
- subscriptionOwner string
- subscriptionId uint64
- flags functions.RequestFlags
- nodeProvidedSecrets string
- requestData *functions.RequestData
type ExternalAdapterClient_FetchEncryptedSecrets_Call ¶ added in v2.15.0
ExternalAdapterClient_FetchEncryptedSecrets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FetchEncryptedSecrets'
func (*ExternalAdapterClient_FetchEncryptedSecrets_Call) Return ¶ added in v2.15.0
func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) Return(encryptedSecrets []byte, userError []byte, err error) *ExternalAdapterClient_FetchEncryptedSecrets_Call
func (*ExternalAdapterClient_FetchEncryptedSecrets_Call) Run ¶ added in v2.15.0
func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) Run(run func(ctx context.Context, encryptedSecretsUrls []byte, requestId string, jobName string)) *ExternalAdapterClient_FetchEncryptedSecrets_Call
func (*ExternalAdapterClient_FetchEncryptedSecrets_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ExternalAdapterClient_FetchEncryptedSecrets_Call) RunAndReturn(run func(context.Context, []byte, string, string) ([]byte, []byte, error)) *ExternalAdapterClient_FetchEncryptedSecrets_Call
type ExternalAdapterClient_RunComputation_Call ¶ added in v2.15.0
ExternalAdapterClient_RunComputation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RunComputation'
func (*ExternalAdapterClient_RunComputation_Call) Return ¶ added in v2.15.0
func (_c *ExternalAdapterClient_RunComputation_Call) Return(userResult []byte, userError []byte, domains []string, err error) *ExternalAdapterClient_RunComputation_Call
func (*ExternalAdapterClient_RunComputation_Call) Run ¶ added in v2.15.0
func (_c *ExternalAdapterClient_RunComputation_Call) Run(run func(ctx context.Context, requestId string, jobName string, subscriptionOwner string, subscriptionId uint64, flags functions.RequestFlags, nodeProvidedSecrets string, requestData *functions.RequestData)) *ExternalAdapterClient_RunComputation_Call
func (*ExternalAdapterClient_RunComputation_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ExternalAdapterClient_RunComputation_Call) RunAndReturn(run func(context.Context, string, string, string, uint64, functions.RequestFlags, string, *functions.RequestData) ([]byte, []byte, []string, error)) *ExternalAdapterClient_RunComputation_Call
type FunctionsListener ¶ added in v2.8.0
FunctionsListener is an autogenerated mock type for the FunctionsListener type
func NewFunctionsListener ¶ added in v2.8.0
func NewFunctionsListener(t interface { mock.TestingT Cleanup(func()) }) *FunctionsListener
NewFunctionsListener creates a new instance of FunctionsListener. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*FunctionsListener) Close ¶ added in v2.8.0
func (_m *FunctionsListener) Close() error
Close provides a mock function with given fields:
func (*FunctionsListener) EXPECT ¶ added in v2.15.0
func (_m *FunctionsListener) EXPECT() *FunctionsListener_Expecter
func (*FunctionsListener) HandleOffchainRequest ¶ added in v2.8.0
func (_m *FunctionsListener) HandleOffchainRequest(ctx context.Context, request *functions.OffchainRequest) error
HandleOffchainRequest provides a mock function with given fields: ctx, request
type FunctionsListener_Close_Call ¶ added in v2.15.0
FunctionsListener_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*FunctionsListener_Close_Call) Return ¶ added in v2.15.0
func (_c *FunctionsListener_Close_Call) Return(_a0 error) *FunctionsListener_Close_Call
func (*FunctionsListener_Close_Call) Run ¶ added in v2.15.0
func (_c *FunctionsListener_Close_Call) Run(run func()) *FunctionsListener_Close_Call
func (*FunctionsListener_Close_Call) RunAndReturn ¶ added in v2.15.0
func (_c *FunctionsListener_Close_Call) RunAndReturn(run func() error) *FunctionsListener_Close_Call
type FunctionsListener_Expecter ¶ added in v2.15.0
type FunctionsListener_Expecter struct {
// contains filtered or unexported fields
}
func (*FunctionsListener_Expecter) Close ¶ added in v2.15.0
func (_e *FunctionsListener_Expecter) Close() *FunctionsListener_Close_Call
Close is a helper method to define mock.On call
func (*FunctionsListener_Expecter) HandleOffchainRequest ¶ added in v2.15.0
func (_e *FunctionsListener_Expecter) HandleOffchainRequest(ctx interface{}, request interface{}) *FunctionsListener_HandleOffchainRequest_Call
HandleOffchainRequest is a helper method to define mock.On call
- ctx context.Context
- request *functions.OffchainRequest
func (*FunctionsListener_Expecter) Start ¶ added in v2.15.0
func (_e *FunctionsListener_Expecter) Start(_a0 interface{}) *FunctionsListener_Start_Call
Start is a helper method to define mock.On call
- _a0 context.Context
type FunctionsListener_HandleOffchainRequest_Call ¶ added in v2.15.0
FunctionsListener_HandleOffchainRequest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleOffchainRequest'
func (*FunctionsListener_HandleOffchainRequest_Call) Return ¶ added in v2.15.0
func (_c *FunctionsListener_HandleOffchainRequest_Call) Return(_a0 error) *FunctionsListener_HandleOffchainRequest_Call
func (*FunctionsListener_HandleOffchainRequest_Call) Run ¶ added in v2.15.0
func (_c *FunctionsListener_HandleOffchainRequest_Call) Run(run func(ctx context.Context, request *functions.OffchainRequest)) *FunctionsListener_HandleOffchainRequest_Call
func (*FunctionsListener_HandleOffchainRequest_Call) RunAndReturn ¶ added in v2.15.0
func (_c *FunctionsListener_HandleOffchainRequest_Call) RunAndReturn(run func(context.Context, *functions.OffchainRequest) error) *FunctionsListener_HandleOffchainRequest_Call
type FunctionsListener_Start_Call ¶ added in v2.15.0
FunctionsListener_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*FunctionsListener_Start_Call) Return ¶ added in v2.15.0
func (_c *FunctionsListener_Start_Call) Return(_a0 error) *FunctionsListener_Start_Call
func (*FunctionsListener_Start_Call) Run ¶ added in v2.15.0
func (_c *FunctionsListener_Start_Call) Run(run func(_a0 context.Context)) *FunctionsListener_Start_Call
func (*FunctionsListener_Start_Call) RunAndReturn ¶ added in v2.15.0
func (_c *FunctionsListener_Start_Call) RunAndReturn(run func(context.Context) error) *FunctionsListener_Start_Call
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶
NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ORM) CreateRequest ¶
CreateRequest provides a mock function with given fields: ctx, request
func (*ORM) EXPECT ¶ added in v2.15.0
func (_m *ORM) EXPECT() *ORM_Expecter
func (*ORM) FindById ¶
func (_m *ORM) FindById(ctx context.Context, requestID functions.RequestID) (*functions.Request, error)
FindById provides a mock function with given fields: ctx, requestID
func (*ORM) FindOldestEntriesByState ¶
func (_m *ORM) FindOldestEntriesByState(ctx context.Context, state functions.RequestState, limit uint32) ([]functions.Request, error)
FindOldestEntriesByState provides a mock function with given fields: ctx, state, limit
func (*ORM) PruneOldestRequests ¶ added in v2.3.0
func (_m *ORM) PruneOldestRequests(ctx context.Context, maxRequestsInDB uint32, batchSize uint32) (uint32, uint32, error)
PruneOldestRequests provides a mock function with given fields: ctx, maxRequestsInDB, batchSize
func (*ORM) SetConfirmed ¶
SetConfirmed provides a mock function with given fields: ctx, requestID
func (*ORM) SetError ¶
func (_m *ORM) SetError(ctx context.Context, requestID functions.RequestID, errorType functions.ErrType, computationError []byte, readyAt time.Time, readyForProcessing bool) error
SetError provides a mock function with given fields: ctx, requestID, errorType, computationError, readyAt, readyForProcessing
func (*ORM) SetFinalized ¶
func (_m *ORM) SetFinalized(ctx context.Context, requestID functions.RequestID, reportedResult []byte, reportedError []byte) error
SetFinalized provides a mock function with given fields: ctx, requestID, reportedResult, reportedError
type ORM_CreateRequest_Call ¶ added in v2.15.0
ORM_CreateRequest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRequest'
func (*ORM_CreateRequest_Call) Return ¶ added in v2.15.0
func (_c *ORM_CreateRequest_Call) Return(_a0 error) *ORM_CreateRequest_Call
func (*ORM_CreateRequest_Call) Run ¶ added in v2.15.0
func (_c *ORM_CreateRequest_Call) Run(run func(ctx context.Context, request *functions.Request)) *ORM_CreateRequest_Call
func (*ORM_CreateRequest_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_CreateRequest_Call) RunAndReturn(run func(context.Context, *functions.Request) error) *ORM_CreateRequest_Call
type ORM_Expecter ¶ added in v2.15.0
type ORM_Expecter struct {
// contains filtered or unexported fields
}
func (*ORM_Expecter) CreateRequest ¶ added in v2.15.0
func (_e *ORM_Expecter) CreateRequest(ctx interface{}, request interface{}) *ORM_CreateRequest_Call
CreateRequest is a helper method to define mock.On call
- ctx context.Context
- request *functions.Request
func (*ORM_Expecter) FindById ¶ added in v2.15.0
func (_e *ORM_Expecter) FindById(ctx interface{}, requestID interface{}) *ORM_FindById_Call
FindById is a helper method to define mock.On call
- ctx context.Context
- requestID functions.RequestID
func (*ORM_Expecter) FindOldestEntriesByState ¶ added in v2.15.0
func (_e *ORM_Expecter) FindOldestEntriesByState(ctx interface{}, state interface{}, limit interface{}) *ORM_FindOldestEntriesByState_Call
FindOldestEntriesByState is a helper method to define mock.On call
- ctx context.Context
- state functions.RequestState
- limit uint32
func (*ORM_Expecter) PruneOldestRequests ¶ added in v2.15.0
func (_e *ORM_Expecter) PruneOldestRequests(ctx interface{}, maxRequestsInDB interface{}, batchSize interface{}) *ORM_PruneOldestRequests_Call
PruneOldestRequests is a helper method to define mock.On call
- ctx context.Context
- maxRequestsInDB uint32
- batchSize uint32
func (*ORM_Expecter) SetConfirmed ¶ added in v2.15.0
func (_e *ORM_Expecter) SetConfirmed(ctx interface{}, requestID interface{}) *ORM_SetConfirmed_Call
SetConfirmed is a helper method to define mock.On call
- ctx context.Context
- requestID functions.RequestID
func (*ORM_Expecter) SetError ¶ added in v2.15.0
func (_e *ORM_Expecter) SetError(ctx interface{}, requestID interface{}, errorType interface{}, computationError interface{}, readyAt interface{}, readyForProcessing interface{}) *ORM_SetError_Call
SetError is a helper method to define mock.On call
- ctx context.Context
- requestID functions.RequestID
- errorType functions.ErrType
- computationError []byte
- readyAt time.Time
- readyForProcessing bool
func (*ORM_Expecter) SetFinalized ¶ added in v2.15.0
func (_e *ORM_Expecter) SetFinalized(ctx interface{}, requestID interface{}, reportedResult interface{}, reportedError interface{}) *ORM_SetFinalized_Call
SetFinalized is a helper method to define mock.On call
- ctx context.Context
- requestID functions.RequestID
- reportedResult []byte
- reportedError []byte
func (*ORM_Expecter) SetResult ¶ added in v2.15.0
func (_e *ORM_Expecter) SetResult(ctx interface{}, requestID interface{}, computationResult interface{}, readyAt interface{}) *ORM_SetResult_Call
SetResult is a helper method to define mock.On call
- ctx context.Context
- requestID functions.RequestID
- computationResult []byte
- readyAt time.Time
func (*ORM_Expecter) TimeoutExpiredResults ¶ added in v2.15.0
func (_e *ORM_Expecter) TimeoutExpiredResults(ctx interface{}, cutoff interface{}, limit interface{}) *ORM_TimeoutExpiredResults_Call
TimeoutExpiredResults is a helper method to define mock.On call
- ctx context.Context
- cutoff time.Time
- limit uint32
type ORM_FindById_Call ¶ added in v2.15.0
ORM_FindById_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindById'
func (*ORM_FindById_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindById_Call) Return(_a0 *functions.Request, _a1 error) *ORM_FindById_Call
func (*ORM_FindById_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindById_Call) Run(run func(ctx context.Context, requestID functions.RequestID)) *ORM_FindById_Call
func (*ORM_FindById_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindById_Call) RunAndReturn(run func(context.Context, functions.RequestID) (*functions.Request, error)) *ORM_FindById_Call
type ORM_FindOldestEntriesByState_Call ¶ added in v2.15.0
ORM_FindOldestEntriesByState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindOldestEntriesByState'
func (*ORM_FindOldestEntriesByState_Call) Return ¶ added in v2.15.0
func (_c *ORM_FindOldestEntriesByState_Call) Return(_a0 []functions.Request, _a1 error) *ORM_FindOldestEntriesByState_Call
func (*ORM_FindOldestEntriesByState_Call) Run ¶ added in v2.15.0
func (_c *ORM_FindOldestEntriesByState_Call) Run(run func(ctx context.Context, state functions.RequestState, limit uint32)) *ORM_FindOldestEntriesByState_Call
func (*ORM_FindOldestEntriesByState_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_FindOldestEntriesByState_Call) RunAndReturn(run func(context.Context, functions.RequestState, uint32) ([]functions.Request, error)) *ORM_FindOldestEntriesByState_Call
type ORM_PruneOldestRequests_Call ¶ added in v2.15.0
ORM_PruneOldestRequests_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PruneOldestRequests'
func (*ORM_PruneOldestRequests_Call) Return ¶ added in v2.15.0
func (_c *ORM_PruneOldestRequests_Call) Return(total uint32, pruned uint32, err error) *ORM_PruneOldestRequests_Call
func (*ORM_PruneOldestRequests_Call) Run ¶ added in v2.15.0
func (_c *ORM_PruneOldestRequests_Call) Run(run func(ctx context.Context, maxRequestsInDB uint32, batchSize uint32)) *ORM_PruneOldestRequests_Call
func (*ORM_PruneOldestRequests_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_PruneOldestRequests_Call) RunAndReturn(run func(context.Context, uint32, uint32) (uint32, uint32, error)) *ORM_PruneOldestRequests_Call
type ORM_SetConfirmed_Call ¶ added in v2.15.0
ORM_SetConfirmed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetConfirmed'
func (*ORM_SetConfirmed_Call) Return ¶ added in v2.15.0
func (_c *ORM_SetConfirmed_Call) Return(_a0 error) *ORM_SetConfirmed_Call
func (*ORM_SetConfirmed_Call) Run ¶ added in v2.15.0
func (_c *ORM_SetConfirmed_Call) Run(run func(ctx context.Context, requestID functions.RequestID)) *ORM_SetConfirmed_Call
func (*ORM_SetConfirmed_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_SetConfirmed_Call) RunAndReturn(run func(context.Context, functions.RequestID) error) *ORM_SetConfirmed_Call
type ORM_SetError_Call ¶ added in v2.15.0
ORM_SetError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetError'
func (*ORM_SetError_Call) Return ¶ added in v2.15.0
func (_c *ORM_SetError_Call) Return(_a0 error) *ORM_SetError_Call
func (*ORM_SetError_Call) RunAndReturn ¶ added in v2.15.0
type ORM_SetFinalized_Call ¶ added in v2.15.0
ORM_SetFinalized_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetFinalized'
func (*ORM_SetFinalized_Call) Return ¶ added in v2.15.0
func (_c *ORM_SetFinalized_Call) Return(_a0 error) *ORM_SetFinalized_Call
func (*ORM_SetFinalized_Call) Run ¶ added in v2.15.0
func (_c *ORM_SetFinalized_Call) Run(run func(ctx context.Context, requestID functions.RequestID, reportedResult []byte, reportedError []byte)) *ORM_SetFinalized_Call
func (*ORM_SetFinalized_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_SetFinalized_Call) RunAndReturn(run func(context.Context, functions.RequestID, []byte, []byte) error) *ORM_SetFinalized_Call
type ORM_SetResult_Call ¶ added in v2.15.0
ORM_SetResult_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetResult'
func (*ORM_SetResult_Call) Return ¶ added in v2.15.0
func (_c *ORM_SetResult_Call) Return(_a0 error) *ORM_SetResult_Call
func (*ORM_SetResult_Call) Run ¶ added in v2.15.0
func (_c *ORM_SetResult_Call) Run(run func(ctx context.Context, requestID functions.RequestID, computationResult []byte, readyAt time.Time)) *ORM_SetResult_Call
func (*ORM_SetResult_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_SetResult_Call) RunAndReturn(run func(context.Context, functions.RequestID, []byte, time.Time) error) *ORM_SetResult_Call
type ORM_TimeoutExpiredResults_Call ¶ added in v2.15.0
ORM_TimeoutExpiredResults_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TimeoutExpiredResults'
func (*ORM_TimeoutExpiredResults_Call) Return ¶ added in v2.15.0
func (_c *ORM_TimeoutExpiredResults_Call) Return(_a0 []functions.RequestID, _a1 error) *ORM_TimeoutExpiredResults_Call
func (*ORM_TimeoutExpiredResults_Call) Run ¶ added in v2.15.0
func (_c *ORM_TimeoutExpiredResults_Call) Run(run func(ctx context.Context, cutoff time.Time, limit uint32)) *ORM_TimeoutExpiredResults_Call
func (*ORM_TimeoutExpiredResults_Call) RunAndReturn ¶ added in v2.15.0
func (_c *ORM_TimeoutExpiredResults_Call) RunAndReturn(run func(context.Context, time.Time, uint32) ([]functions.RequestID, error)) *ORM_TimeoutExpiredResults_Call
type OffchainTransmitter ¶ added in v2.8.0
OffchainTransmitter is an autogenerated mock type for the OffchainTransmitter type
func NewOffchainTransmitter ¶ added in v2.8.0
func NewOffchainTransmitter(t interface { mock.TestingT Cleanup(func()) }) *OffchainTransmitter
NewOffchainTransmitter creates a new instance of OffchainTransmitter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*OffchainTransmitter) EXPECT ¶ added in v2.15.0
func (_m *OffchainTransmitter) EXPECT() *OffchainTransmitter_Expecter
func (*OffchainTransmitter) ReportChannel ¶ added in v2.8.0
func (_m *OffchainTransmitter) ReportChannel() chan *functions.OffchainResponse
ReportChannel provides a mock function with given fields:
func (*OffchainTransmitter) TransmitReport ¶ added in v2.8.0
func (_m *OffchainTransmitter) TransmitReport(ctx context.Context, report *functions.OffchainResponse) error
TransmitReport provides a mock function with given fields: ctx, report
type OffchainTransmitter_Expecter ¶ added in v2.15.0
type OffchainTransmitter_Expecter struct {
// contains filtered or unexported fields
}
func (*OffchainTransmitter_Expecter) ReportChannel ¶ added in v2.15.0
func (_e *OffchainTransmitter_Expecter) ReportChannel() *OffchainTransmitter_ReportChannel_Call
ReportChannel is a helper method to define mock.On call
func (*OffchainTransmitter_Expecter) TransmitReport ¶ added in v2.15.0
func (_e *OffchainTransmitter_Expecter) TransmitReport(ctx interface{}, report interface{}) *OffchainTransmitter_TransmitReport_Call
TransmitReport is a helper method to define mock.On call
- ctx context.Context
- report *functions.OffchainResponse
type OffchainTransmitter_ReportChannel_Call ¶ added in v2.15.0
OffchainTransmitter_ReportChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportChannel'
func (*OffchainTransmitter_ReportChannel_Call) Return ¶ added in v2.15.0
func (_c *OffchainTransmitter_ReportChannel_Call) Return(_a0 chan *functions.OffchainResponse) *OffchainTransmitter_ReportChannel_Call
func (*OffchainTransmitter_ReportChannel_Call) Run ¶ added in v2.15.0
func (_c *OffchainTransmitter_ReportChannel_Call) Run(run func()) *OffchainTransmitter_ReportChannel_Call
func (*OffchainTransmitter_ReportChannel_Call) RunAndReturn ¶ added in v2.15.0
func (_c *OffchainTransmitter_ReportChannel_Call) RunAndReturn(run func() chan *functions.OffchainResponse) *OffchainTransmitter_ReportChannel_Call
type OffchainTransmitter_TransmitReport_Call ¶ added in v2.15.0
OffchainTransmitter_TransmitReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransmitReport'
func (*OffchainTransmitter_TransmitReport_Call) Return ¶ added in v2.15.0
func (_c *OffchainTransmitter_TransmitReport_Call) Return(_a0 error) *OffchainTransmitter_TransmitReport_Call
func (*OffchainTransmitter_TransmitReport_Call) Run ¶ added in v2.15.0
func (_c *OffchainTransmitter_TransmitReport_Call) Run(run func(ctx context.Context, report *functions.OffchainResponse)) *OffchainTransmitter_TransmitReport_Call
func (*OffchainTransmitter_TransmitReport_Call) RunAndReturn ¶ added in v2.15.0
func (_c *OffchainTransmitter_TransmitReport_Call) RunAndReturn(run func(context.Context, *functions.OffchainResponse) error) *OffchainTransmitter_TransmitReport_Call