mocks

Documentation

Index

• type BridgeAccessor
  • func NewBridgeAccessor(t interface{ ... }) *BridgeAccessor
  • func (_m *BridgeAccessor) NewExternalAdapterClient(_a0 context.Context) (functions.ExternalAdapterClient, error)
• type ExternalAdapterClient
  • func NewExternalAdapterClient(t interface{ ... }) *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 FunctionsListener
  • 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 ORM
  • func NewORM(t interface{ ... }) *ORM
  • func (_m *ORM) CreateRequest(ctx context.Context, request *functions.Request) error
  • 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 OffchainTransmitter
  • func NewOffchainTransmitter(t interface{ ... }) *OffchainTransmitter
  • func (_m *OffchainTransmitter) ReportChannel() chan *functions.OffchainResponse
  • func (_m *OffchainTransmitter) TransmitReport(ctx context.Context, report *functions.OffchainResponse) error

Types

type BridgeAccessor

type BridgeAccessor struct {
	mock.Mock
}

BridgeAccessor is an autogenerated mock type for the BridgeAccessor type

func NewBridgeAccessor

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) NewExternalAdapterClient

func (_m *BridgeAccessor) NewExternalAdapterClient(_a0 context.Context) (functions.ExternalAdapterClient, error)

NewExternalAdapterClient provides a mock function with given fields: _a0

type ExternalAdapterClient

type ExternalAdapterClient struct {
	mock.Mock
}

ExternalAdapterClient is an autogenerated mock type for the ExternalAdapterClient type

func NewExternalAdapterClient

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) 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, 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 FunctionsListener

type FunctionsListener struct {
	mock.Mock
}

FunctionsListener is an autogenerated mock type for the FunctionsListener type

func NewFunctionsListener

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

func (_m *FunctionsListener) Close() error

Close provides a mock function with given fields:

func (*FunctionsListener) HandleOffchainRequest

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

HandleOffchainRequest provides a mock function with given fields: ctx, request

func (*FunctionsListener) Start

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

Start provides a mock function with given fields: _a0

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*ORM) CreateRequest

func (_m *ORM) CreateRequest(ctx context.Context, request *functions.Request) error

CreateRequest provides a mock function with given fields: ctx, request

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

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

func (_m *ORM) SetConfirmed(ctx context.Context, requestID functions.RequestID) error

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

func (*ORM) SetResult

func (_m *ORM) SetResult(ctx context.Context, requestID functions.RequestID, computationResult []byte, readyAt time.Time) error

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

func (*ORM) TimeoutExpiredResults

func (_m *ORM) TimeoutExpiredResults(ctx context.Context, cutoff time.Time, limit uint32) ([]functions.RequestID, error)

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

type OffchainTransmitter

type OffchainTransmitter struct {
	mock.Mock
}

OffchainTransmitter is an autogenerated mock type for the OffchainTransmitter type

func NewOffchainTransmitter

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) ReportChannel

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

ReportChannel provides a mock function with given fields:

func (*OffchainTransmitter) TransmitReport

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

TransmitReport provides a mock function with given fields: ctx, report