Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + const APIEmail + const APIKey + const APISecret + const AllowUnstarted + const AssertNoActionTimeout + const DBPollingInterval + const DBWaitTimeout + const DefaultKeyAddress + const DefaultKeyFixtureFileName + const DefaultKeyJSON + const DefaultOCRKeyBundleID + const DefaultPeerID + const NonExistentPeerID + const Password + const RootDir + const SessionSecret + var DefaultOCRKeyBundleIDSha256 models.Sha256Hash + var DefaultP2PPeerID models.PeerID + var FluxAggAddress = common.HexToAddress("0x3cCad4715152693fE3BC4460591e3D3Fbd071b42") + var NonExistentP2PPeerID models.PeerID + func AllExternalInitiators(t testing.TB, store *strpkg.Store) []models.ExternalInitiator + func AllJobs(t testing.TB, store *strpkg.Store) []models.JobSpec + func AssertCount(t *testing.T, store *strpkg.Store, model interface{}, expected int64) + func AssertCountStays(t testing.TB, store *strpkg.Store, model interface{}, want int64) + func AssertError(t testing.TB, want bool, err error) + func AssertEthTxAttemptCountStays(t testing.TB, store *strpkg.Store, want int) []models.EthTxAttempt + func AssertPipelineRunsStays(t testing.TB, pipelineSpecID int32, store *strpkg.Store, want int) []pipeline.Run + func AssertRecordEventually(t *testing.T, store *strpkg.Store, model interface{}, check func() bool) + func AssertRunsStays(t testing.TB, j models.JobSpec, store *strpkg.Store, want int) []models.JobRun + func AssertServerResponse(t testing.TB, resp *http.Response, expectedStatusCode int) + func AssertSyncEventCountStays(t testing.TB, orm *orm.ORM, want int) + func BatchElemMatchesHash(req rpc.BatchElem, hash common.Hash) bool + func BigHexInt(val interface{}) hexutil.Big + func BlockWithTransactions(gasPrices ...int64) *types.Block + func BuildInitiatorRequests(t *testing.T, initrs []models.Initiator) []models.InitiatorRequest + func BuildTaskRequests(t *testing.T, initrs []models.TaskSpec) []models.TaskSpecRequest + func CallbackOrTimeout(t testing.TB, msg string, callback func(), durationParams ...time.Duration) + func CompareOCRJobSpecs(t *testing.T, expected, actual job.Job) + func CreateBridgeTypeViaWeb(t testing.TB, app *TestApplication, payload string) *webpresenters.BridgeResource + func CreateExternalInitiatorViaWeb(t testing.TB, app *TestApplication, payload string) *presenters.ExternalInitiatorAuthentication + func CreateHelloWorldJobViaWeb(t testing.TB, app *TestApplication, url string) models.JobSpec + func CreateJobRunViaExternalInitiator(t testing.TB, app *TestApplication, j models.JobSpec, eia auth.Token, ...) models.JobRun + func CreateJobRunViaWeb(t testing.TB, app *TestApplication, j models.JobSpec, body ...string) models.JobRun + func CreateJobRunWithStatus(t testing.TB, store *strpkg.Store, job models.JobSpec, status models.RunStatus) models.JobRun + func CreateJobSpecViaWeb(t testing.TB, app *TestApplication, job models.JobSpec) models.JobSpec + func CreateJobViaWeb(t testing.TB, app *TestApplication, request []byte) job.Job + func CreateJobViaWeb2(t testing.TB, app *TestApplication, spec string) webpresenters.JobResource + func CreateSpecViaWeb(t testing.TB, app *TestApplication, spec string) models.JobSpec + func DecodeSessionCookie(value string) (string, error) + func EmptyCLIContext() *cli.Context + func EventuallyExpectationsMet(t *testing.T, mock testifyExpectationsAsserter, timeout time.Duration, ...) + func FindServiceAgreement(t testing.TB, s *strpkg.Store, id string) models.ServiceAgreement + func FixtureCreateJobSpecV2ViaWeb(t *testing.T, app *TestApplication, path string) job.Job + func FixtureCreateJobViaWeb(t *testing.T, app *TestApplication, path string) models.JobSpec + func GenericEncode(types []string, values ...interface{}) ([]byte, error) + func GetLastEthTxAttempt(t testing.TB, store *strpkg.Store) models.EthTxAttempt + func GetLogs(t *testing.T, rv interface{}, logs EthereumLogIterator) []interface + func Head(val interface{}) *models.Head + func JSONFromBytes(t testing.TB, body []byte) models.JSON + func JSONFromFixture(t *testing.T, path string) models.JSON + func JSONFromString(t testing.TB, body string, args ...interface{}) models.JSON + func JSONResultFromFixture(t *testing.T, path string) models.JSON + func JobRunStays(t testing.TB, store *strpkg.Store, jr models.JobRun, status models.RunStatus, ...) models.JobRun + func JobRunStaysPendingIncomingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun + func LogFromFixture(t *testing.T, path string) types.Log + func MakeConfigDigest(t *testing.T) ocrtypes.ConfigDigest + func MakeRoundStateReturnData(roundID uint64, eligible bool, ...) []byte + func Mine(backend *backends.SimulatedBackend, blockTime time.Duration) (stopMining func()) + func MinimalOCRNonBootstrapSpec(contractAddress, transmitterAddress models.EIP55Address, peerID models.PeerID, ...) string + func MockApplicationEthCalls(t *testing.T, app *TestApplication, ethClient *mocks.Client) (verify func()) + func MockFluxAggCall(client *mocks.GethClient, address common.Address, funcName string) *mock.Call + func MockSubscribeToLogsCh(gethClient *mocks.GethClient, sub *mocks.Subscription) chan chan<- types.Log + func MustAddKeyToKeystore(t testing.TB, key *models.Key, store *strpkg.Store) + func MustAddRandomKeyToKeystore(t testing.TB, store *strpkg.Store, opts ...interface{}) (models.Key, common.Address) + func MustAllJobsWithStatus(t testing.TB, store *strpkg.Store, statuses ...models.RunStatus) []*models.JobRun + func MustBytesToConfigDigest(t *testing.T, b []byte) ocrtypes.ConfigDigest + func MustGenerateRandomKey(t testing.TB, opts ...interface{}) models.Key + func MustGenerateSessionCookie(value string) *http.Cookie + func MustGenericEncode(types []string, values ...interface{}) []byte + func MustHelloWorldAgreement(t *testing.T) string + func MustHexDecodeString(s string) []byte + func MustInsertBroadcastEthTxAttempt(t *testing.T, etxID int64, store *strpkg.Store, gasPrice int64) models.EthTxAttempt + func MustInsertConfirmedEthTxWithAttempt(t *testing.T, store *strpkg.Store, nonce int64, broadcastBeforeBlockNum int64, ...) models.EthTx + func MustInsertEthReceipt(t *testing.T, s *strpkg.Store, blockNumber int64, blockHash common.Hash, ...) models.EthReceipt + func MustInsertFatalErrorEthTx(t *testing.T, store *strpkg.Store, fromAddress common.Address) models.EthTx + func MustInsertHead(t *testing.T, store *strpkg.Store, number int64) models.Head + func MustInsertInProgressEthTxWithAttempt(t *testing.T, store *strpkg.Store, nonce int64, fromAddress common.Address) models.EthTx + func MustInsertJobSpec(t *testing.T, s *strpkg.Store) models.JobSpec + func MustInsertKeeperJob(t *testing.T, store *strpkg.Store, from models.EIP55Address, ...) job.Job + func MustInsertKeeperRegistry(t *testing.T, store *strpkg.Store) (keeper.Registry, job.Job) + func MustInsertOffchainreportingOracleSpec(t *testing.T, store *strpkg.Store, transmitterAddress models.EIP55Address) job.OffchainReportingOracleSpec + func MustInsertPipelineRun(t *testing.T, db *gorm.DB) pipeline.Run + func MustInsertRandomKey(t testing.TB, db *gorm.DB, opts ...interface{}) models.Key + func MustInsertSampleDirectRequestJob(t *testing.T, db *gorm.DB) job.Job + func MustInsertTaskRun(t *testing.T, store *strpkg.Store) uuid.UUID + func MustInsertUnconfirmedEthTxWithBroadcastAttempt(t *testing.T, store *strpkg.Store, nonce int64, fromAddress common.Address, ...) models.EthTx + func MustInsertUnconfirmedEthTxWithInsufficientEthAttempt(t *testing.T, store *strpkg.Store, nonce int64, fromAddress common.Address) models.EthTx + func MustInsertUnfinishedPipelineTaskRun(t *testing.T, store *strpkg.Store, pipelineRunID int64) pipeline.TaskRun + func MustInsertUnstartedEthTx(t *testing.T, store *strpkg.Store, fromAddress common.Address) models.EthTx + func MustInsertUpkeepForRegistry(t *testing.T, store *strpkg.Store, registry keeper.Registry) keeper.UpkeepRegistration + func MustInsertV2JobSpec(t *testing.T, store *strpkg.Store, transmitterAddress common.Address) job.Job + func MustJSONDel(t *testing.T, json, path string) string + func MustJSONSet(t *testing.T, json, path string, value interface{}) string + func MustNewJSONSerializable(t *testing.T, s string) pipeline.JSONSerializable + func MustNewKeyedTransactor(t *testing.T, key *ecdsa.PrivateKey, chainID int64) *bind.TransactOpts + func MustNewSimulatedBackendKeyedTransactor(t *testing.T, key *ecdsa.PrivateKey) *bind.TransactOpts + func MustNewUser(t *testing.T, email, password string) models.User + func MustParseDuration(t testing.TB, durationStr string) time.Duration + func MustParseURL(input string) *url.URL + func MustRandomBytes(t *testing.T, l int) (b []byte) + func MustRandomUser() models.User + func MustReadFile(t testing.TB, file string) []byte + func MustResultString(t *testing.T, input models.RunResult) string + func NewAddress() common.Address + func NewBridgeType(t testing.TB, info ...string) (*models.BridgeTypeAuthentication, *models.BridgeType) + func NewContractMockReceiver(t *testing.T, ethMock *mocks.Client, abi abi.ABI, address common.Address) contractMockReceiver + func NewEIP55Address() models.EIP55Address + func NewEthBroadcaster(t testing.TB, store *strpkg.Store, config *TestConfig) (bulletprooftxmanager.EthBroadcaster, func()) + func NewEthMocks(t testing.TB) (*mocks.RPCClient, *mocks.GethClient, *mocks.Subscription, func()) + func NewEthMocksWithStartupAssertions(t testing.TB) (*mocks.RPCClient, *mocks.GethClient, *mocks.Subscription, func()) + func NewEthTx(t *testing.T, store *strpkg.Store, fromAddress common.Address) models.EthTx + func NewEthTxAttempt(t *testing.T, etxID int64) models.EthTxAttempt + func NewHTTPMockServer(t *testing.T, status int, wantMethod string, response string, ...) (*httptest.Server, func()) + func NewHTTPMockServerWithAlterableResponse(t *testing.T, response func() string) (server *httptest.Server) + func NewHTTPMockServerWithAlterableResponseAndRequest(t *testing.T, response func() string, callback func(r *http.Request)) (server *httptest.Server) + func NewHTTPMockServerWithRequest(t *testing.T, status int, response string, callback func(r *http.Request)) (*httptest.Server, func()) + func NewHash() common.Hash + func NewJob() models.JobSpec + func NewJobRun(job models.JobSpec) models.JobRun + func NewJobRunPendingBridge(job models.JobSpec) models.JobRun + func NewJobWithExternalInitiator(ei *models.ExternalInitiator) models.JobSpec + func NewJobWithFluxMonitorInitiator() models.JobSpec + func NewJobWithFluxMonitorInitiatorWithBridge(bridgeName string) models.JobSpec + func NewJobWithLogInitiator() models.JobSpec + func NewJobWithRandomnessLog() models.JobSpec + func NewJobWithRunAtInitiator(t time.Time) models.JobSpec + func NewJobWithRunLogInitiator() models.JobSpec + func NewJobWithSchedule(sched string) models.JobSpec + func NewJobWithWebInitiator() models.JobSpec + func NewMockAuthenticatedHTTPClient(cfg orm.ConfigReader, sessionID string) cmd.HTTPClient + func NewPeerID() p2ppeer.ID + func NewPipelineORM(t testing.TB, config *TestConfig, db *gorm.DB) (pipeline.ORM, postgres.EventBroadcaster, func()) + func NewPollingDeviationChecker(t *testing.T, s *strpkg.Store) *fluxmonitor.PollingDeviationChecker + func NewRandomInt64() int64 + func NewRandomnessRequestLog(t *testing.T, r models.RandomnessRequestLog, emitter common.Address, blk int) types.Log + func NewRoundStateForRoundID(store *strpkg.Store, roundID uint32, latestSubmission *big.Int) flux_aggregator_wrapper.OracleRoundState + func NewRunInput(value models.JSON) models.RunInput + func NewRunInputWithResult(value interface{}) models.RunInput + func NewRunInputWithString(t testing.TB, value string) models.RunInput + func NewRunLog(t *testing.T, jobID common.Hash, emitter common.Address, ...) types.Log + func NewSession(optionalSessionID ...string) models.Session + func NewSimulatedBackendIdentity(t *testing.T) *bind.TransactOpts + func NewStore(t testing.TB, flagsAndDeps ...interface{}) (*strpkg.Store, func()) + func NewStoreWithConfig(t testing.TB, config *TestConfig, flagsAndDeps ...interface{}) (*strpkg.Store, func()) + func NewTask(t *testing.T, taskType string, json ...string) models.TaskSpec + func NewWSServer(msg string, callback func(data []byte)) (*httptest.Server, string, func()) + func NormalizedJSON(t testing.TB, input []byte) string + func NullableTime(t time.Time) null.Time + func ParseISO8601(t testing.TB, s string) time.Time + func ParseJSON(t testing.TB, body io.Reader) models.JSON + func ParseJSONAPIErrors(t testing.TB, body io.Reader) *models.JSONAPIErrors + func ParseJSONAPIResponse(t testing.TB, resp *http.Response, resource interface{}) error + func ParseJSONAPIResponseMeta(input []byte) (map[string]*json.RawMessage, error) + func ParseJSONAPIResponseMetaCount(input []byte) (int, error) + func ParseNullableTime(t testing.TB, s string) null.Time + func ParseResponseBody(t testing.TB, resp *http.Response) []byte + func Random32Byte() (b [32]byte) + func RandomLog(t *testing.T) types.Log + func RawNewRoundLog(t *testing.T, contractAddr common.Address, blockHash common.Hash, ...) types.Log + func ReadLogs(config orm.ConfigReader) (string, error) + func SendBlocksUntilComplete(t testing.TB, store *strpkg.Store, jr models.JobRun, ...) models.JobRun + func ServiceAgreementFromString(str string) (models.ServiceAgreement, error) + func SimulateIncomingHeads(t *testing.T, args SimulateIncomingHeadsArgs) (func(), chan struct{}) + func StoredVRFKey(t *testing.T, store *strpkg.Store) *vrfkey.PublicKey + func StringToHash(s string) common.Hash + func StringToVersionedLogData20190207withoutIndexes(t *testing.T, internalID string, requester common.Address, str string) []byte + func TransactionsFromGasPrices(gasPrices ...int64) []types.Transaction + func TxReceiptFromFixture(t *testing.T, path string) *types.Receipt + func UnauthenticatedPatch(t testing.TB, url string, body io.Reader, headers map[string]string) (*http.Response, func()) + func UnauthenticatedPost(t testing.TB, url string, body io.Reader, headers map[string]string) (*http.Response, func()) + func UpdateJobRunViaWeb(t testing.TB, app *TestApplication, jr models.JobRun, ...) models.JobRun + func WaitForCount(t testing.TB, store *strpkg.Store, model interface{}, want int64) + func WaitForEthTxAttemptCount(t testing.TB, store *strpkg.Store, want int) []models.EthTxAttempt + func WaitForEthTxAttemptsForEthTx(t testing.TB, store *strpkg.Store, ethTx models.EthTx) []models.EthTxAttempt + func WaitForJobRunStatus(t testing.TB, store *strpkg.Store, jr models.JobRun, status models.RunStatus) models.JobRun + func WaitForJobRunToComplete(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun + func WaitForJobRunToPendBridge(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun + func WaitForJobRunToPendIncomingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun + func WaitForJobRunToPendOutgoingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun + func WaitForPipelineComplete(t testing.TB, nodeID int, jobID int32, count int, jo job.ORM, ...) []pipeline.Run + func WaitForPipelineRuns(t testing.TB, nodeID int, jobID int32, jo job.ORM, want int, ...) []pipeline.Run + func WaitForRuns(t testing.TB, j models.JobSpec, store *strpkg.Store, want int) []models.JobRun + func WaitForRunsAtLeast(t testing.TB, j models.JobSpec, store *strpkg.Store, want int) + func WaitForSpecError(t *testing.T, store *strpkg.Store, jobID models.JobID, count int) []models.JobSpecError + func WaitForSpecErrorV2(t *testing.T, store *strpkg.Store, jobID int32, count int) []job.SpecError + func WaitForSyncEventCount(t testing.TB, orm *orm.ORM, want int) + func WebURL(t testing.TB, unparsed string) models.WebURL + type Awaiter chan struct + func NewAwaiter() Awaiter + func (a Awaiter) AwaitOrFail(t testing.TB, durationParams ...time.Duration) + func (a Awaiter) ItHappened() + type BlockedRunner struct + Done chan struct{} + func (r BlockedRunner) Run(app adamoracle.Application) error + type CallbackAuthenticator struct + Callback func(*store.Store, string) (string, error) + func (a CallbackAuthenticator) Authenticate(store *store.Store, pwd string) (string, error) + func (a CallbackAuthenticator) AuthenticateOCRKey(*store.Store, string) error + func (a CallbackAuthenticator) AuthenticateVRFKey(*store.Store, string) error + type EmptyRunner struct + func (r EmptyRunner) Run(app adamoracle.Application) error + type EthereumLogIterator interface + Next func() bool + type EventWebSocketServer struct + Connected chan struct{} + ReceivedBinary chan []byte + ReceivedText chan string + URL *url.URL + func NewEventWebSocketServer(t *testing.T) (*EventWebSocketServer, func()) + func (wss *EventWebSocketServer) Broadcast(message string) error + func (wss *EventWebSocketServer) WriteCloseMessage() + type HTTPClientCleaner struct + HTTPClient cmd.HTTPClient + func (r *HTTPClientCleaner) Delete(path string) (*http.Response, func()) + func (r *HTTPClientCleaner) Get(path string, headers ...map[string]string) (*http.Response, func()) + func (r *HTTPClientCleaner) Patch(path string, body io.Reader, headers ...map[string]string) (*http.Response, func()) + func (r *HTTPClientCleaner) Post(path string, body io.Reader) (*http.Response, func()) + func (r *HTTPClientCleaner) Put(path string, body io.Reader) (*http.Response, func()) + type HeadTrackableFunc func(context.Context, models.Head) + func (HeadTrackableFunc) Connect(*models.Head) error + func (HeadTrackableFunc) Disconnect() + func (fn HeadTrackableFunc) OnNewLongestChain(ctx context.Context, head models.Head) + type InstanceAppFactory struct + App adamoracle.Application + func (f InstanceAppFactory) NewApplication(config *orm.Config, onConnectCallbacks ...func(adamoracle.Application)) (adamoracle.Application, error) + type InstantClock struct + func (InstantClock) After(_ time.Duration) <-chan time.Time + func (InstantClock) Now() time.Time + type JobPipelineV2TestHelper struct + Eb postgres.EventBroadcaster + Jrm job.ORM + Pr pipeline.Runner + Prm pipeline.ORM + func NewJobPipelineV2(t testing.TB, db *gorm.DB) JobPipelineV2TestHelper + type MockAPIInitializer struct + Count int + func (m *MockAPIInitializer) Initialize(store *store.Store) (models.User, error) + type MockChangePasswordPrompter struct + func (m MockChangePasswordPrompter) Prompt() (web.UpdatePasswordRequest, error) + type MockCookieAuthenticator struct + Error error + SessionID string + func (m MockCookieAuthenticator) Authenticate(models.SessionRequest) (*http.Cookie, error) + func (m MockCookieAuthenticator) Cookie() (*http.Cookie, error) + type MockCountingPrompter struct + Count int + EnteredStrings []string + NotTerminal bool + T *testing.T + func (p *MockCountingPrompter) IsTerminal() bool + func (p *MockCountingPrompter) PasswordPrompt(string) string + func (p *MockCountingPrompter) Prompt(string) string + type MockCron struct + Entries []MockCronEntry + func NewMockCron() *MockCron + func (*MockCron) Start() + func (*MockCron) Stop() context.Context + func (mc *MockCron) AddFunc(schd string, fn func()) (cron.EntryID, error) + func (mc *MockCron) RunEntries() + type MockCronEntry struct + Function func() + Schedule string + type MockHeadTrackable struct + ConnectedCallback func(bn *models.Head) + func (m *MockHeadTrackable) Connect(bn *models.Head) error + func (m *MockHeadTrackable) ConnectedCount() int32 + func (m *MockHeadTrackable) Disconnect() + func (m *MockHeadTrackable) DisconnectedCount() int32 + func (m *MockHeadTrackable) OnNewLongestChain(context.Context, models.Head) + func (m *MockHeadTrackable) OnNewLongestChainCount() int32 + type MockPasswordPrompter struct + Password string + func (m MockPasswordPrompter) Prompt() string + type MockSessionRequestBuilder struct + Count int + Error error + func (m *MockSessionRequestBuilder) Build(string) (models.SessionRequest, error) + type MockSigner struct + func (s MockSigner) SignHash(common.Hash) (models.Signature, error) + type MockSubscription struct + Errors chan error + func EmptyMockSubscription() *MockSubscription + func (mes *MockSubscription) Err() <-chan error + func (mes *MockSubscription) Unsubscribe() + type NeverSleeper struct + func (ns NeverSleeper) After() time.Duration + func (ns NeverSleeper) Duration() time.Duration + func (ns NeverSleeper) Reset() + func (ns NeverSleeper) Sleep() + type RendererMock struct + Renders []interface{} + func (rm *RendererMock) Render(v interface{}, headers ...string) error + type SimulateIncomingHeadsArgs struct + BackfillDepth int64 + EndBlock int64 + Hashes map[int64]common.Hash + HeadTrackables []strpkg.HeadTrackable + Interval time.Duration + StartBlock int64 + Timeout time.Duration + type SimulatedBackendClient struct + func (c *SimulatedBackendClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error) + func (c *SimulatedBackendClient) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error + func (c *SimulatedBackendClient) BlockByNumber(ctx context.Context, n *big.Int) (*types.Block, error) + func (c *SimulatedBackendClient) Call(result interface{}, method string, args ...interface{}) error + func (c *SimulatedBackendClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error + func (c *SimulatedBackendClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error) + func (c *SimulatedBackendClient) ChainID(context.Context) (*big.Int, error) + func (c *SimulatedBackendClient) Close() + func (c *SimulatedBackendClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error) + func (c *SimulatedBackendClient) Dial(context.Context) error + func (c *SimulatedBackendClient) EstimateGas(ctx context.Context, call ethereum.CallMsg) (gas uint64, err error) + func (c *SimulatedBackendClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) (logs []types.Log, err error) + func (c *SimulatedBackendClient) GetERC20Balance(address common.Address, contractAddress common.Address) (balance *big.Int, err error) + func (c *SimulatedBackendClient) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error) + func (c *SimulatedBackendClient) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Adam, error) + func (c *SimulatedBackendClient) HeaderByNumber(ctx context.Context, n *big.Int) (*models.Head, error) + func (c *SimulatedBackendClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error) + func (c *SimulatedBackendClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error) + func (c *SimulatedBackendClient) RoundRobinBatchCallContext(ctx context.Context, b []rpc.BatchElem) error + func (c *SimulatedBackendClient) SendRawTx(txBytes []byte) (txHash common.Hash, err error) + func (c *SimulatedBackendClient) SendTransaction(ctx context.Context, tx *types.Transaction) error + func (c *SimulatedBackendClient) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, channel chan<- types.Log) (ethereum.Subscription, error) + func (c *SimulatedBackendClient) SubscribeNewHead(ctx context.Context, channel chan<- *models.Head) (ethereum.Subscription, error) + func (c *SimulatedBackendClient) SuggestGasPrice(ctx context.Context) (*big.Int, error) + func (c *SimulatedBackendClient) TransactionReceipt(ctx context.Context, receipt common.Hash) (*types.Receipt, error) + type TestApplication struct + Backend *backends.SimulatedBackend + Config *TestConfig + Key models.Key + Server *httptest.Server + Started bool + func NewApplication(t testing.TB, flagsAndDeps ...interface{}) (*TestApplication, func()) + func NewApplicationWithConfig(t testing.TB, tc *TestConfig, flagsAndDeps ...interface{}) (*TestApplication, func()) + func NewApplicationWithConfigAndKey(t testing.TB, tc *TestConfig, flagsAndDeps ...interface{}) (*TestApplication, func()) + func NewApplicationWithConfigAndKeyOnSimulatedBlockchain(t testing.TB, tc *TestConfig, backend *backends.SimulatedBackend, ...) (app *TestApplication, cleanup func()) + func NewApplicationWithKey(t testing.TB, flagsAndDeps ...interface{}) (*TestApplication, func()) + func (ta *TestApplication) ImportKey(content string) + func (ta *TestApplication) InstantClock() InstantClock + func (ta *TestApplication) MustCreateJobRun(txHashBytes []byte, blockHashBytes []byte) *models.JobRun + func (ta *TestApplication) MustSeedNewSession() string + func (ta *TestApplication) NewAuthenticatingClient(prompter cmd.Prompter) *cmd.Client + func (ta *TestApplication) NewBox() packr.Box + func (ta *TestApplication) NewClientAndRenderer() (*cmd.Client, *RendererMock) + func (ta *TestApplication) NewHTTPClient() HTTPClientCleaner + func (ta *TestApplication) Start() error + func (ta *TestApplication) StartAndConnect() error + func (ta *TestApplication) Stop() error + type TestConfig struct + func BootstrapThrowawayORM(t *testing.T, name string, migrate bool, loadFixtures ...bool) (*TestConfig, *orm.ORM, func()) + func NewConfig(t testing.TB) (*TestConfig, func()) + func NewConfigWithWSServer(t testing.TB, url string, wsserver *httptest.Server) *TestConfig + func NewTestConfig(t testing.TB, options ...interface{}) *TestConfig + type TriggerClock struct + func NewTriggerClock(t testing.TB) *TriggerClock + func (t *TriggerClock) After(_ time.Duration) <-chan time.Time + func (t *TriggerClock) Trigger() + func (t *TriggerClock) TriggerWithoutTimeout() + func (t TriggerClock) Now() time.Time