Versions in this module Expand all Collapse all v0 v0.0.2 Mar 12, 2021 Changes in this version + var ErrorNoAPICredentialsAvailable = errors.New("API credentials must be supplied") + func NewApp(client *Client) *cli.App + type APIInitializer interface + Initialize func(store *store.Store) (models.User, error) + func NewFileAPIInitializer(file string) APIInitializer + func NewPromptingAPIInitializer(prompter Prompter) APIInitializer + type AppFactory interface + NewApplication func(*orm.Config, ...func(seerlink.Application)) seerlink.Application + type ChangePasswordPrompter interface + Prompt func() (models.ChangePasswordRequest, error) + func NewChangePasswordPrompter() ChangePasswordPrompter + type Client struct + AppFactory AppFactory + ChangePasswordPrompter ChangePasswordPrompter + Config *orm.Config + CookieAuthenticator CookieAuthenticator + FallbackAPIInitializer APIInitializer + FileSessionRequestBuilder SessionRequestBuilder + HTTP HTTPClient + KeyStoreAuthenticator KeyStoreAuthenticator + PasswordPrompter PasswordPrompter + PromptingSessionRequestBuilder SessionRequestBuilder + Runner Runner + func (cli *Client) ArchiveJobSpec(c *clipkg.Context) error + func (cli *Client) CancelJobRun(c *clipkg.Context) error + func (cli *Client) ChangePassword(c *clipkg.Context) (err error) + func (cli *Client) CreateAndExportWeakVRFKey(c *clipkg.Context) error + func (cli *Client) CreateBridge(c *clipkg.Context) (err error) + func (cli *Client) CreateETHKey(c *clipkg.Context) (err error) + func (cli *Client) CreateExternalInitiator(c *clipkg.Context) (err error) + func (cli *Client) CreateJobRun(c *clipkg.Context) (err error) + func (cli *Client) CreateJobSpec(c *clipkg.Context) (err error) + func (cli *Client) CreateJobV2(c *clipkg.Context) (err error) + func (cli *Client) CreateOCRKeyBundle(c *clipkg.Context) error + func (cli *Client) CreateP2PKey(c *clipkg.Context) (err error) + func (cli *Client) CreateServiceAgreement(c *clipkg.Context) (err error) + func (cli *Client) CreateVRFKey(c *clipkg.Context) error + func (cli *Client) DeleteETHKey(c *clipkg.Context) (err error) + func (cli *Client) DeleteExternalInitiator(c *clipkg.Context) (err error) + func (cli *Client) DeleteJobV2(c *clipkg.Context) error + func (cli *Client) DeleteOCRKeyBundle(c *clipkg.Context) error + func (cli *Client) DeleteP2PKey(c *clipkg.Context) (err error) + func (cli *Client) DeleteUser(c *clipkg.Context) (err error) + func (cli *Client) DeleteVRFKey(c *clipkg.Context) error + func (cli *Client) ExportETHKey(c *clipkg.Context) (err error) + func (cli *Client) ExportOCRKey(c *clipkg.Context) (err error) + func (cli *Client) ExportP2PKey(c *clipkg.Context) (err error) + func (cli *Client) ExportVRFKey(c *clipkg.Context) error + func (cli *Client) GetConfiguration(c *clipkg.Context) (err error) + func (cli *Client) HardReset(c *clipkg.Context) error + func (cli *Client) ImportETHKey(c *clipkg.Context) (err error) + func (cli *Client) ImportKey(c *clipkg.Context) error + func (cli *Client) ImportOCRKey(c *clipkg.Context) (err error) + func (cli *Client) ImportP2PKey(c *clipkg.Context) (err error) + func (cli *Client) ImportVRFKey(c *clipkg.Context) error + func (cli *Client) IndexBridges(c *clipkg.Context) (err error) + func (cli *Client) IndexJobRuns(c *clipkg.Context) error + func (cli *Client) IndexJobSpecs(c *clipkg.Context) error + func (cli *Client) IndexTransactions(c *clipkg.Context) error + func (cli *Client) IndexTxAttempts(c *clipkg.Context) error + func (cli *Client) ListETHKeys(c *clipkg.Context) (err error) + func (cli *Client) ListJobsV2(c *clipkg.Context) (err error) + func (cli *Client) ListKeys(c *clipkg.Context) error + func (cli *Client) ListOCRKeyBundles(c *clipkg.Context) error + func (cli *Client) ListP2PKeys(c *clipkg.Context) (err error) + func (cli *Client) PrepareTestDatabase(c *clipkg.Context) error + func (cli *Client) RebroadcastTransactions(c *clipkg.Context) (err error) + func (cli *Client) RemoteLogin(c *clipkg.Context) error + func (cli *Client) RemoveBridge(c *clipkg.Context) (err error) + func (cli *Client) ResetDatabase(c *clipkg.Context) error + func (cli *Client) RunNode(c *clipkg.Context) error + func (cli *Client) SendEther(c *clipkg.Context) (err error) + func (cli *Client) SetMinimumGasPrice(c *clipkg.Context) (err error) + func (cli *Client) SetNextNonce(c *clipkg.Context) error + func (cli *Client) ShowBridge(c *clipkg.Context) (err error) + func (cli *Client) ShowJobRun(c *clipkg.Context) (err error) + func (cli *Client) ShowJobSpec(c *clipkg.Context) (err error) + func (cli *Client) ShowTransaction(c *clipkg.Context) (err error) + func (cli *Client) TriggerPipelineRun(c *clipkg.Context) error + type CookieAuthenticator interface + Authenticate func(models.SessionRequest) (*http.Cookie, error) + Cookie func() (*http.Cookie, error) + func NewSessionCookieAuthenticator(config *orm.Config, store CookieStore) CookieAuthenticator + type CookieStore interface + Retrieve func() (*http.Cookie, error) + Save func(cookie *http.Cookie) error + type DirectRequestSpec struct + ContractAddress string + CreatedAt time.Time + OnChainJobSpecID string + UpdatedAt time.Time + type DiskCookieStore struct + Config *orm.Config + func (d DiskCookieStore) Retrieve() (*http.Cookie, error) + func (d DiskCookieStore) Save(cookie *http.Cookie) error + type FluxMonitorSpec struct + CreatedAt time.Time + UpdatedAt time.Time + type HTTPClient interface + Delete func(string) (*http.Response, error) + Get func(string, ...map[string]string) (*http.Response, error) + Patch func(string, io.Reader, ...map[string]string) (*http.Response, error) + Post func(string, io.Reader) (*http.Response, error) + Put func(string, io.Reader) (*http.Response, error) + func NewAuthenticatedHTTPClient(config orm.ConfigReader, cookieAuth CookieAuthenticator) HTTPClient + type JAID struct + ID string + func (jaid *JAID) SetID(value string) error + func (jaid JAID) GetID() string + type Job struct + DirectRequestSpec *DirectRequestSpec + FluxMonitorSpec *FluxMonitorSpec + Name string + OffChainReportingSpec *OffChainReportingSpec + PipelineSpec PipelineSpec + Type JobType + func (j Job) FriendlyCreatedAt() string + func (j Job) FriendlyTasks() []string + func (j Job) GetName() string + func (j Job) GetTasks() ([]string, error) + func (j Job) ToRow() [][]string + type JobType string + const DirectRequestJob + const FluxMonitorJob + const OffChainReportingJob + func (t JobType) String() string + type KeyStoreAuthenticator interface + Authenticate func(*store.Store, string) (string, error) + AuthenticateOCRKey func(store *store.Store, password string) error + AuthenticateVRFKey func(*store.Store, string) error + type MemoryCookieStore struct + Cookie *http.Cookie + func (m *MemoryCookieStore) Retrieve() (*http.Cookie, error) + func (m *MemoryCookieStore) Save(cookie *http.Cookie) error + type OffChainReportingSpec struct + CreatedAt time.Time + UpdatedAt time.Time + type PasswordPrompter interface + Prompt func() string + func NewPasswordPrompter() PasswordPrompter + type PipelineSpec struct + DotDAGSource string + ID int32 + type Prompter interface + IsTerminal func() bool + PasswordPrompt func(string) string + Prompt func(string) string + func NewTerminalPrompter() Prompter + type Renderer interface + Render func(interface{}) error + type RendererJSON struct + func (rj RendererJSON) Render(v interface{}) error + type RendererTable struct + func (rt RendererTable) Render(v interface{}) error + type Runner interface + Run func(seerlink.Application) error + type SeerlinkAppFactory struct + func (n SeerlinkAppFactory) NewApplication(config *orm.Config, onConnectCallbacks ...func(seerlink.Application)) seerlink.Application + type SeerlinkRunner struct + func (n SeerlinkRunner) Run(app seerlink.Application) error + type SessionCookieAuthenticator struct + func (t *SessionCookieAuthenticator) Authenticate(sessionRequest models.SessionRequest) (*http.Cookie, error) + func (t *SessionCookieAuthenticator) Cookie() (*http.Cookie, error) + type SessionRequestBuilder interface + Build func(flag string) (models.SessionRequest, error) + func NewFileSessionRequestBuilder() SessionRequestBuilder + func NewPromptingSessionRequestBuilder(prompter Prompter) SessionRequestBuilder + type TerminalKeyStoreAuthenticator struct + Prompter Prompter + func (auth TerminalKeyStoreAuthenticator) Authenticate(store *store.Store, password string) (string, error) + func (auth TerminalKeyStoreAuthenticator) AuthenticateOCRKey(store *store.Store, password string) error + func (auth TerminalKeyStoreAuthenticator) AuthenticateVRFKey(store *store.Store, password string) error