mocks

Documentation

Index

• type ExternalAdapterClient
  • 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 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) PruneOldestRequests(maxRequestsInDB uint32, batchSize uint32, qopts ...pg.QOpt) (uint32, uint32, 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)

Types

type ExternalAdapterClient

type ExternalAdapterClient struct {
	mock.Mock
}

ExternalAdapterClient is an autogenerated mock type for the ExternalAdapterClient type

func NewExternalAdapterClient

func NewExternalAdapterClient(t mockConstructorTestingTNewExternalAdapterClient) *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.

func (*ExternalAdapterClient) FetchEncryptedSecrets

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

func (_m *ExternalAdapterClient) RunComputation(ctx context.Context, requestId string, jobName string, subscriptionOwner string, subscriptionId uint64, nodeProvidedSecrets string, jsonData json.RawMessage) ([]byte, []byte, []string, error)

RunComputation provides a mock function with given fields: ctx, requestId, jobName, subscriptionOwner, subscriptionId, nodeProvidedSecrets, jsonData

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

func NewORM(t mockConstructorTestingTNewORM) *ORM

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.

func (*ORM) CreateRequest

func (_m *ORM) CreateRequest(requestID functions.RequestID, receivedAt time.Time, requestTxHash *common.Hash, qopts ...pg.QOpt) error

CreateRequest provides a mock function with given fields: requestID, receivedAt, requestTxHash, qopts

func (*ORM) FindById

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

FindById provides a mock function with given fields: requestID, qopts

func (*ORM) FindOldestEntriesByState

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

FindOldestEntriesByState provides a mock function with given fields: state, limit, qopts

func (*ORM) PruneOldestRequests

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

PruneOldestRequests provides a mock function with given fields: maxRequestsInDB, batchSize, qopts

func (*ORM) SetConfirmed

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

SetConfirmed provides a mock function with given fields: requestID, qopts

func (*ORM) SetError

func (_m *ORM) SetError(requestID functions.RequestID, runID int64, errorType functions.ErrType, computationError []byte, readyAt time.Time, readyForProcessing bool, qopts ...pg.QOpt) error

SetError provides a mock function with given fields: requestID, runID, errorType, computationError, readyAt, readyForProcessing, qopts

func (*ORM) SetFinalized

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

SetFinalized provides a mock function with given fields: requestID, reportedResult, reportedError, qopts

func (*ORM) SetResult

func (_m *ORM) SetResult(requestID functions.RequestID, runID int64, computationResult []byte, readyAt time.Time, qopts ...pg.QOpt) error

SetResult provides a mock function with given fields: requestID, runID, computationResult, readyAt, qopts

func (*ORM) TimeoutExpiredResults

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

TimeoutExpiredResults provides a mock function with given fields: cutoff, limit, qopts