Documentation ¶
Index ¶
- Constants
- Variables
- func FindSessionCookie(cookies []*http.Cookie) *http.Cookie
- func FindTxAttempt(ctx context.Context, timeout time.Duration, etx txmgr.Tx, ...) (attempt txmgr.TxAttempt, err error)
- func GzipFileServer(root ServeFileSystem, lggr logger.Logger) http.Handler
- func NewJSONAPIResponse(resource interface{}) ([]byte, error)
- func NewPaginatedResponse(url url.URL, size, page, count int, resource interface{}) ([]byte, error)
- func NewRouter(app chainlink.Application, prometheus *ginprom.Prometheus) (*gin.Engine, error)
- func ParseJSONAPIResponse(input []byte, resource interface{}) error
- func ParsePaginatedRequest(sizeParam, pageParam string) (int, int, int, error)
- func ParsePaginatedResponse(input []byte, resource interface{}, links *jsonapi.Links) error
- func Router(t testing.TB, app chainlink.Application, prometheus *ginprom.Prometheus) *gin.Engine
- func ServeGzippedAssets(urlPrefix string, fs ServeFileSystem, lggr logger.Logger) gin.HandlerFunc
- func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error
- func ValidateBridgeTypeNotExist(ctx context.Context, bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
- func ValidateEthBalanceForTransfer(c *gin.Context, chain legacyevm.Chain, fromAddr common.Address, ...) error
- func ValidateExternalInitiator(ctx context.Context, exi *bridges.ExternalInitiatorRequest, orm bridges.ORM) error
- type BridgeTypesController
- func (btc *BridgeTypesController) Create(c *gin.Context)
- func (btc *BridgeTypesController) Destroy(c *gin.Context)
- func (btc *BridgeTypesController) Index(c *gin.Context, size, page, offset int)
- func (btc *BridgeTypesController) Show(c *gin.Context)
- func (btc *BridgeTypesController) Update(c *gin.Context)
- type BuildInfoController
- type CSAKeysController
- type ChainsController
- type ConfigController
- type ConfigV2Resource
- type CosmosTransfersController
- type CreateJobRequest
- type ETHKeysController
- func (ekc *ETHKeysController) Chain(c *gin.Context)
- func (ekc *ETHKeysController) Create(c *gin.Context)
- func (ekc *ETHKeysController) Delete(c *gin.Context)
- func (ekc *ETHKeysController) Export(c *gin.Context)
- func (ekc *ETHKeysController) Import(c *gin.Context)
- func (ekc *ETHKeysController) Index(c *gin.Context)
- type EVMForwardersController
- type EVMTransfersController
- type EmbedFileSystem
- type ExternalInitiatorsController
- type FeaturesController
- type HealthController
- type JobsController
- type KeysController
- func NewCosmosKeysController(app chainlink.Application) KeysController
- func NewDKGEncryptKeysController(app chainlink.Application) KeysController
- func NewDKGSignKeysController(app chainlink.Application) KeysController
- func NewKeysController[K keystore.Key, R jsonapi.EntityNamer](ks Keystore[K], lggr logger.Logger, auditLogger audit.AuditLogger, ...) KeysController
- func NewSolanaKeysController(app chainlink.Application) KeysController
- func NewStarkNetKeysController(app chainlink.Application) KeysController
- type Keystore
- type LCAController
- type LCAResponse
- type LogController
- type LogPatchRequest
- type LoopRegistryServer
- type NetworkScopedNodeStatuser
- type NodesController
- type OCR2KeysController
- type OCRKeysController
- type P2PKeysController
- type PingController
- type PipelineJobSpecErrorsController
- type PipelineRunsController
- type ReplayController
- type ReplayResponse
- type ServeFileSystem
- type Session
- type SessionsController
- type SolanaTransfersController
- type TrackEVMForwarderRequest
- type TransactionsController
- type TxAttemptsController
- type UpdateJobRequest
- type UpdatePasswordRequest
- type UserController
- func (u *UserController) Create(c *gin.Context)
- func (u *UserController) Delete(c *gin.Context)
- func (u *UserController) DeleteAPIToken(c *gin.Context)
- func (u *UserController) Index(c *gin.Context)
- func (u *UserController) NewAPIToken(c *gin.Context)
- func (u *UserController) UpdatePassword(c *gin.Context)
- func (u *UserController) UpdateRole(c *gin.Context)
- type VRFKeysController
- type WebAuthnController
Constants ¶
const ( // PaginationDefault is the number of records to supply from a paginated // request when no size param is supplied. PaginationDefault = 25 // MediaType is the response header for JSONAPI documents. MediaType = "application/vnd.api+json" // KeyNextLink is the name of the key that contains the HREF for the next // document in a paginated response. KeyNextLink = "next" // KeyPreviousLink is the name of the key that contains the HREF for the // previous document in a paginated response. KeyPreviousLink = "prev" )
const ( FeatureKeyCSA string = "csa" FeatureKeyFeedsManager string = "feeds_manager" )
const ( HealthStatusPassing = "passing" HealthStatusFailing = "failing" )
Variables ¶
var ( ErrMissingChainID = errors.New("chain id does not match any local chains") ErrEmptyChainID = errors.New("chainID is empty") ErrInvalidChainID = errors.New("invalid chain id") ErrMultipleChains = errors.New("more than one chain available, you must specify chain id parameter") )
var ErrCosmosNotEnabled = errChainDisabled{/* contains filtered or unexported fields */}
ErrCosmosNotEnabled is returned when COSMOS_ENABLED is not true.
var ErrEVMNotEnabled = errChainDisabled{/* contains filtered or unexported fields */}
var ErrSolanaNotEnabled = errChainDisabled{/* contains filtered or unexported fields */}
ErrSolanaNotEnabled is returned when Solana.Enabled is not true.
var ErrStarkNetNotEnabled = errChainDisabled{/* contains filtered or unexported fields */}
ErrStarkNetNotEnabled is returned when Starknet.Enabled is not true.
Functions ¶
func FindSessionCookie ¶
FindSessionCookie returns the cookie with the "clsession" name
func FindTxAttempt ¶ added in v2.6.0
func GzipFileServer ¶
func GzipFileServer(root ServeFileSystem, lggr logger.Logger) http.Handler
GzipFileServer is a drop-in replacement for Go's standard http.FileServer which adds support for static resources precompressed with gzip, at the cost of removing the support for directory browsing.
func NewJSONAPIResponse ¶
NewJSONAPIResponse returns a JSONAPI response for a single resource.
func NewPaginatedResponse ¶
NewPaginatedResponse returns a jsonapi.Document with links to next and previous collection pages
func NewRouter ¶
func NewRouter(app chainlink.Application, prometheus *ginprom.Prometheus) (*gin.Engine, error)
NewRouter returns *gin.Engine router that listens and responds to requests to the node for valid paths.
func ParseJSONAPIResponse ¶
ParseJSONAPIResponse parses the bytes of the root document and unmarshals it into the given resource.
func ParsePaginatedRequest ¶
ParsePaginatedRequest parses the parameters that control pagination for a collection request, returning the size and offset if specified, or a sensible default.
func ParsePaginatedResponse ¶
ParsePaginatedResponse parse a JSONAPI response for a document with links
func Router ¶
func Router(t testing.TB, app chainlink.Application, prometheus *ginprom.Prometheus) *gin.Engine
func ServeGzippedAssets ¶
func ServeGzippedAssets(urlPrefix string, fs ServeFileSystem, lggr logger.Logger) gin.HandlerFunc
ServeGzippedAssets returns a middleware handler that serves static files in the given directory.
func ValidateBridgeType ¶
func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error
ValidateBridgeType checks that the bridge type has the required field with valid values.
func ValidateBridgeTypeNotExist ¶
func ValidateBridgeTypeNotExist(ctx context.Context, bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
ValidateBridgeTypeNotExist checks that a bridge has not already been created
func ValidateEthBalanceForTransfer ¶
func ValidateEthBalanceForTransfer(c *gin.Context, chain legacyevm.Chain, fromAddr common.Address, amount assets.Eth) error
ValidateEthBalanceForTransfer validates that the current balance can cover the transaction amount
func ValidateExternalInitiator ¶
func ValidateExternalInitiator( ctx context.Context, exi *bridges.ExternalInitiatorRequest, orm bridges.ORM, ) error
ValidateExternalInitiator checks whether External Initiator parameters are safe for processing.
Types ¶
type BridgeTypesController ¶
type BridgeTypesController struct {
App chainlink.Application
}
BridgeTypesController manages BridgeType requests in the node.
func (*BridgeTypesController) Create ¶
func (btc *BridgeTypesController) Create(c *gin.Context)
Create adds the BridgeType to the given context.
func (*BridgeTypesController) Destroy ¶
func (btc *BridgeTypesController) Destroy(c *gin.Context)
Destroy removes a specific Bridge.
func (*BridgeTypesController) Index ¶
func (btc *BridgeTypesController) Index(c *gin.Context, size, page, offset int)
Index lists Bridges, one page at a time.
func (*BridgeTypesController) Show ¶
func (btc *BridgeTypesController) Show(c *gin.Context)
Show returns the details of a specific Bridge.
func (*BridgeTypesController) Update ¶
func (btc *BridgeTypesController) Update(c *gin.Context)
Update can change the restricted attributes for a bridge
type BuildInfoController ¶
type BuildInfoController struct {
App chainlink.Application
}
BuildVersonController has the build_info endpoint.
func (*BuildInfoController) Show ¶
func (eic *BuildInfoController) Show(c *gin.Context)
Show returns the build info.
type CSAKeysController ¶
type CSAKeysController struct {
App chainlink.Application
}
CSAKeysController manages CSA keys
func (*CSAKeysController) Create ¶
func (ctrl *CSAKeysController) Create(c *gin.Context)
Create and return a CSA key Example: "POST <application>/keys/csa"
func (*CSAKeysController) Export ¶
func (ctrl *CSAKeysController) Export(c *gin.Context)
Export exports a key
func (*CSAKeysController) Import ¶
func (ctrl *CSAKeysController) Import(c *gin.Context)
Import imports a CSA key
func (*CSAKeysController) Index ¶
func (ctrl *CSAKeysController) Index(c *gin.Context)
Index lists CSA keys Example: "GET <application>/keys/csa"
type ChainsController ¶
type ChainsController interface { // Index lists chains. Index(c *gin.Context, size, page, offset int) // Show gets a chain by id. Show(*gin.Context) }
func NewCosmosChainsController ¶
func NewCosmosChainsController(app chainlink.Application) ChainsController
func NewEVMChainsController ¶
func NewEVMChainsController(app chainlink.Application) ChainsController
func NewSolanaChainsController ¶
func NewSolanaChainsController(app chainlink.Application) ChainsController
func NewStarkNetChainsController ¶
func NewStarkNetChainsController(app chainlink.Application) ChainsController
type ConfigController ¶
type ConfigController struct {
App chainlink.Application
}
ConfigController manages config variables
func (*ConfigController) Show ¶
func (cc *ConfigController) Show(c *gin.Context)
Show returns the whitelist of config variables Example:
"<application>/config"
type ConfigV2Resource ¶
type ConfigV2Resource struct {
Config string `json:"config"`
}
func (ConfigV2Resource) GetID ¶
func (c ConfigV2Resource) GetID() string
func (*ConfigV2Resource) SetID ¶
func (c *ConfigV2Resource) SetID(string) error
type CosmosTransfersController ¶
type CosmosTransfersController struct {
App chainlink.Application
}
CosmosTransfersController can send LINK tokens to another address
func (*CosmosTransfersController) Create ¶
func (tc *CosmosTransfersController) Create(c *gin.Context)
Create sends native coins from the Chainlink's account to a specified address.
type CreateJobRequest ¶
type CreateJobRequest struct {
TOML string `json:"toml"`
}
CreateJobRequest represents a request to create and start a job (V2).
type ETHKeysController ¶
type ETHKeysController struct {
// contains filtered or unexported fields
}
ETHKeysController manages account keys
func NewETHKeysController ¶
func NewETHKeysController(app chainlink.Application) *ETHKeysController
func (*ETHKeysController) Chain ¶
func (ekc *ETHKeysController) Chain(c *gin.Context)
Chain updates settings for a given chain for the key
func (*ETHKeysController) Create ¶
func (ekc *ETHKeysController) Create(c *gin.Context)
Create adds a new account Example:
"<application>/keys/eth"
func (*ETHKeysController) Delete ¶
func (ekc *ETHKeysController) Delete(c *gin.Context)
Delete an ETH key bundle (irreversible!) Example: "DELETE <application>/keys/eth/:keyID"
func (*ETHKeysController) Export ¶
func (ekc *ETHKeysController) Export(c *gin.Context)
func (*ETHKeysController) Import ¶
func (ekc *ETHKeysController) Import(c *gin.Context)
Import imports a key
func (*ETHKeysController) Index ¶
func (ekc *ETHKeysController) Index(c *gin.Context)
Index returns the node's Ethereum keys and the account balances of ETH & LINK. Example:
"<application>/keys/eth"
type EVMForwardersController ¶
type EVMForwardersController struct {
App chainlink.Application
}
EVMForwardersController manages EVM forwarders.
func (*EVMForwardersController) Delete ¶
func (cc *EVMForwardersController) Delete(c *gin.Context)
Delete removes an EVM Forwarder.
func (*EVMForwardersController) Index ¶
func (cc *EVMForwardersController) Index(c *gin.Context, size, page, offset int)
Index lists EVM forwarders.
func (*EVMForwardersController) Track ¶
func (cc *EVMForwardersController) Track(c *gin.Context)
Track adds a new EVM forwarder.
type EVMTransfersController ¶
type EVMTransfersController struct {
App chainlink.Application
}
EVMTransfersController can send LINK tokens to another address
func (*EVMTransfersController) Create ¶
func (tc *EVMTransfersController) Create(c *gin.Context)
Create sends ETH from the Chainlink's account to a specified address.
Example: "<application>/withdrawals"
type EmbedFileSystem ¶
type EmbedFileSystem struct { embed.FS http.FileSystem // contains filtered or unexported fields }
EmbedFileSystem implements the ServeFileSystem interface using an embed.FS object.
type ExternalInitiatorsController ¶
type ExternalInitiatorsController struct {
App chainlink.Application
}
ExternalInitiatorsController manages external initiators
func (*ExternalInitiatorsController) Create ¶
func (eic *ExternalInitiatorsController) Create(c *gin.Context)
Create builds and saves a new external initiator
func (*ExternalInitiatorsController) Destroy ¶
func (eic *ExternalInitiatorsController) Destroy(c *gin.Context)
Destroy deletes an ExternalInitiator
type FeaturesController ¶
type FeaturesController struct {
App chainlink.Application
}
FeaturesController manages the feature flags
func (*FeaturesController) Index ¶
func (fc *FeaturesController) Index(c *gin.Context)
Index retrieves the features Example: "GET <application>/features"
type HealthController ¶
type HealthController struct {
App chainlink.Application
}
func (*HealthController) Health ¶
func (hc *HealthController) Health(c *gin.Context)
func (*HealthController) Readyz ¶
func (hc *HealthController) Readyz(c *gin.Context)
NOTE: We only implement the k8s readiness check, *not* the liveness check. Liveness checks are only recommended in cases where the app doesn't crash itself on panic, and if implemented incorrectly can cause cascading failures. See the following for more information: - https://srcco.de/posts/kubernetes-liveness-probes-are-dangerous.html
type JobsController ¶
type JobsController struct {
App chainlink.Application
}
JobsController manages jobs
func (*JobsController) Create ¶
func (jc *JobsController) Create(c *gin.Context)
Create validates, saves and starts a new job. Example: "POST <application>/jobs"
func (*JobsController) Delete ¶
func (jc *JobsController) Delete(c *gin.Context)
Delete hard deletes a job spec. Example: "DELETE <application>/specs/:ID"
func (*JobsController) Index ¶
func (jc *JobsController) Index(c *gin.Context, size, page, offset int)
Index lists all jobs Example: "GET <application>/jobs"
func (*JobsController) Show ¶
func (jc *JobsController) Show(c *gin.Context)
Show returns the details of a job :ID could be both job ID and external job ID Example: "GET <application>/jobs/:ID"
func (*JobsController) Update ¶
func (jc *JobsController) Update(c *gin.Context)
Update validates a new TOML for an existing job, stops and deletes existing job, saves and starts a new job. Example: "PUT <application>/jobs/:ID"
type KeysController ¶
type KeysController interface { // Index lists keys Index(*gin.Context) // Create and return a key Create(*gin.Context) // Delete a key Delete(*gin.Context) // Import imports a key Import(*gin.Context) // Export exports a key Export(*gin.Context) }
func NewCosmosKeysController ¶
func NewCosmosKeysController(app chainlink.Application) KeysController
func NewDKGEncryptKeysController ¶
func NewDKGEncryptKeysController(app chainlink.Application) KeysController
func NewDKGSignKeysController ¶
func NewDKGSignKeysController(app chainlink.Application) KeysController
func NewKeysController ¶
func NewKeysController[K keystore.Key, R jsonapi.EntityNamer](ks Keystore[K], lggr logger.Logger, auditLogger audit.AuditLogger, resourceName string, newResource func(K) *R, newResources func([]K) []R) KeysController
func NewSolanaKeysController ¶
func NewSolanaKeysController(app chainlink.Application) KeysController
func NewStarkNetKeysController ¶
func NewStarkNetKeysController(app chainlink.Application) KeysController
type LCAController ¶ added in v2.12.0
type LCAController struct {
App chainlink.Application
}
func (*LCAController) FindLCA ¶ added in v2.12.0
func (bdc *LCAController) FindLCA(c *gin.Context)
FindLCA compares chain of blocks available in the DB with chain provided by an RPC and returns last common ancestor Example:
"<application>/v2/find_lca"
type LCAResponse ¶ added in v2.12.0
type LCAResponse struct { BlockNumber int64 `json:"blockNumber"` Hash string `json:"hash"` EVMChainID *big.Big `json:"evmChainID"` }
func (LCAResponse) GetID ¶ added in v2.12.0
func (s LCAResponse) GetID() string
GetID returns the jsonapi ID.
func (LCAResponse) GetName ¶ added in v2.12.0
func (LCAResponse) GetName() string
GetName returns the collection name for jsonapi.
func (*LCAResponse) SetID ¶ added in v2.12.0
func (*LCAResponse) SetID(string) error
SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.
type LogController ¶
type LogController struct {
App chainlink.Application
}
LogController manages the logger config
func (*LogController) Get ¶
func (cc *LogController) Get(c *gin.Context)
Get retrieves the current log config settings
func (*LogController) Patch ¶
func (cc *LogController) Patch(c *gin.Context)
Patch sets a log level and enables sql logging for the logger
type LogPatchRequest ¶
type LoopRegistryServer ¶ added in v2.2.0
type LoopRegistryServer struct {
// contains filtered or unexported fields
}
func NewLoopRegistryServer ¶ added in v2.2.0
func NewLoopRegistryServer(app chainlink.Application) *LoopRegistryServer
type NetworkScopedNodeStatuser ¶ added in v2.6.0
type NetworkScopedNodeStatuser struct {
// contains filtered or unexported fields
}
func NewNetworkScopedNodeStatuser ¶ added in v2.6.0
func NewNetworkScopedNodeStatuser(relayers chainlink.RelayerChainInteroperators, network string) *NetworkScopedNodeStatuser
func (*NetworkScopedNodeStatuser) NodeStatuses ¶ added in v2.6.0
func (n *NetworkScopedNodeStatuser) NodeStatuses(ctx context.Context, offset, limit int, relayIDs ...types.RelayID) (nodes []types.NodeStatus, count int, err error)
type NodesController ¶
type NodesController interface { // Index lists nodes, and optionally filters by chain id. Index(c *gin.Context, size, page, offset int) }
func NewCosmosNodesController ¶
func NewCosmosNodesController(app chainlink.Application) NodesController
func NewEVMNodesController ¶
func NewEVMNodesController(app chainlink.Application) NodesController
func NewSolanaNodesController ¶
func NewSolanaNodesController(app chainlink.Application) NodesController
func NewStarkNetNodesController ¶
func NewStarkNetNodesController(app chainlink.Application) NodesController
type OCR2KeysController ¶
type OCR2KeysController struct {
App chainlink.Application
}
OCRKeysController manages OCR key bundles
func (*OCR2KeysController) Create ¶
func (ocr2kc *OCR2KeysController) Create(c *gin.Context)
Create and return an OCR2 key bundle Example: "POST <application>/keys/ocr"
func (*OCR2KeysController) Delete ¶
func (ocr2kc *OCR2KeysController) Delete(c *gin.Context)
Delete an OCR2 key bundle Example: "DELETE <application>/keys/ocr/:keyID"
func (*OCR2KeysController) Export ¶
func (ocr2kc *OCR2KeysController) Export(c *gin.Context)
Export exports an OCR2 key bundle Example: "Post <application>/keys/ocr/export"
func (*OCR2KeysController) Import ¶
func (ocr2kc *OCR2KeysController) Import(c *gin.Context)
Import imports an OCR2 key bundle Example: "Post <application>/keys/ocr/import"
func (*OCR2KeysController) Index ¶
func (ocr2kc *OCR2KeysController) Index(c *gin.Context)
Index lists OCR2 key bundles Example: "GET <application>/keys/ocr"
type OCRKeysController ¶
type OCRKeysController struct {
App chainlink.Application
}
OCRKeysController manages OCR key bundles
func (*OCRKeysController) Create ¶
func (ocrkc *OCRKeysController) Create(c *gin.Context)
Create and return an OCR key bundle Example: "POST <application>/keys/ocr"
func (*OCRKeysController) Delete ¶
func (ocrkc *OCRKeysController) Delete(c *gin.Context)
Delete an OCR key bundle Example: "DELETE <application>/keys/ocr/:keyID" "DELETE <application>/keys/ocr/:keyID?hard=true"
func (*OCRKeysController) Export ¶
func (ocrkc *OCRKeysController) Export(c *gin.Context)
Export exports an OCR key bundle Example: "Post <application>/keys/ocr/export"
func (*OCRKeysController) Import ¶
func (ocrkc *OCRKeysController) Import(c *gin.Context)
Import imports an OCR key bundle Example: "Post <application>/keys/ocr/import"
func (*OCRKeysController) Index ¶
func (ocrkc *OCRKeysController) Index(c *gin.Context)
Index lists OCR key bundles Example: "GET <application>/keys/ocr"
type P2PKeysController ¶
type P2PKeysController struct {
App chainlink.Application
}
P2PKeysController manages P2P keys
func (*P2PKeysController) Create ¶
func (p2pkc *P2PKeysController) Create(c *gin.Context)
Create and return a P2P key Example: "POST <application>/keys/p2p"
func (*P2PKeysController) Delete ¶
func (p2pkc *P2PKeysController) Delete(c *gin.Context)
Delete a P2P key Example: "DELETE <application>/keys/p2p/:keyID" "DELETE <application>/keys/p2p/:keyID?hard=true"
func (*P2PKeysController) Export ¶
func (p2pkc *P2PKeysController) Export(c *gin.Context)
Export exports a P2P key Example: "Post <application>/keys/p2p/export"
func (*P2PKeysController) Import ¶
func (p2pkc *P2PKeysController) Import(c *gin.Context)
Import imports a P2P key Example: "Post <application>/keys/p2p/import"
func (*P2PKeysController) Index ¶
func (p2pkc *P2PKeysController) Index(c *gin.Context)
Index lists P2P keys Example: "GET <application>/keys/p2p"
type PingController ¶
type PingController struct {
App chainlink.Application
}
PingController has the ping endpoint.
type PipelineJobSpecErrorsController ¶
type PipelineJobSpecErrorsController struct {
App chainlink.Application
}
PipelineJobSpecErrorsController manages PipelineJobSpecError requests
func (*PipelineJobSpecErrorsController) Destroy ¶
func (psec *PipelineJobSpecErrorsController) Destroy(c *gin.Context)
Destroy deletes a PipelineJobSpecError record from the database, effectively silencing the error notification
type PipelineRunsController ¶
type PipelineRunsController struct {
App chainlink.Application
}
PipelineRunsController manages V2 job run requests.
func (*PipelineRunsController) Create ¶
func (prc *PipelineRunsController) Create(c *gin.Context)
Create triggers a pipeline run for a job. Example: "POST <application>/jobs/:ID/runs"
func (*PipelineRunsController) Index ¶
func (prc *PipelineRunsController) Index(c *gin.Context, size, page, offset int)
Index returns all pipeline runs for a job. Example: "GET <application>/jobs/:ID/runs"
func (*PipelineRunsController) Resume ¶
func (prc *PipelineRunsController) Resume(c *gin.Context)
Resume finishes a task and resumes the pipeline run. Example: "PATCH <application>/jobs/:ID/runs/:runID"
func (*PipelineRunsController) Show ¶
func (prc *PipelineRunsController) Show(c *gin.Context)
Show returns a specified pipeline run. Example: "GET <application>/jobs/:ID/runs/:runID"
type ReplayController ¶
type ReplayController struct {
App chainlink.Application
}
func (*ReplayController) ReplayFromBlock ¶
func (bdc *ReplayController) ReplayFromBlock(c *gin.Context)
ReplayFromBlock causes the node to process blocks again from the given block number Example:
"<application>/v2/replay_from_block/:number"
type ReplayResponse ¶
type ReplayResponse struct { Message string `json:"message"` EVMChainID *big.Big `json:"evmChainID"` }
func (ReplayResponse) GetName ¶
func (ReplayResponse) GetName() string
GetName returns the collection name for jsonapi.
func (*ReplayResponse) SetID ¶
func (*ReplayResponse) SetID(string) error
SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.
type ServeFileSystem ¶
type ServeFileSystem interface { http.FileSystem Exists(prefix string, path string) bool }
ServeFileSystem wraps a http.FileSystem with an additional file existence check
func NewEmbedFileSystem ¶
func NewEmbedFileSystem(efs embed.FS, pathPrefix string) ServeFileSystem
type Session ¶
type Session struct {
Authenticated bool `json:"authenticated"`
}
type SessionsController ¶
type SessionsController struct { App chainlink.Application // contains filtered or unexported fields }
SessionsController manages session requests.
func NewSessionsController ¶
func NewSessionsController(app chainlink.Application) *SessionsController
func (*SessionsController) Create ¶
func (sc *SessionsController) Create(c *gin.Context)
Create creates a session ID for the given user credentials, and returns it in a cookie.
func (*SessionsController) Destroy ¶
func (sc *SessionsController) Destroy(c *gin.Context)
Destroy removes the specified session ID from the database.
type SolanaTransfersController ¶
type SolanaTransfersController struct {
App chainlink.Application
}
SolanaTransfersController can send LINK tokens to another address
func (*SolanaTransfersController) Create ¶
func (tc *SolanaTransfersController) Create(c *gin.Context)
Create sends SOL and other native coins from the Chainlink's account to a specified address.
type TrackEVMForwarderRequest ¶
type TrackEVMForwarderRequest struct { EVMChainID *ubig.Big `json:"evmChainId"` Address common.Address `json:"address"` }
TrackEVMForwarderRequest is a JSONAPI request for creating an EVM forwarder.
type TransactionsController ¶
type TransactionsController struct {
App chainlink.Application
}
TransactionsController displays Ethereum transactions requests.
func (*TransactionsController) Index ¶
func (tc *TransactionsController) Index(c *gin.Context, size, page, offset int)
Index returns paginated transactions
func (*TransactionsController) Show ¶
func (tc *TransactionsController) Show(c *gin.Context)
Show returns the details of a Ethereum Transaction details. Example:
"<application>/transactions/:TxHash"
type TxAttemptsController ¶
type TxAttemptsController struct {
App chainlink.Application
}
TxAttemptsController lists TxAttempts requests.
type UpdateJobRequest ¶
type UpdateJobRequest struct {
TOML string `json:"toml"`
}
UpdateJobRequest represents a request to update a job with new toml and start a job (V2).
type UpdatePasswordRequest ¶
type UpdatePasswordRequest struct { OldPassword string `json:"oldPassword"` NewPassword string `json:"newPassword"` }
UpdatePasswordRequest defines the request to set a new password for the current session's User.
type UserController ¶
type UserController struct {
App chainlink.Application
}
UserController manages the current Session's User.
func (*UserController) Create ¶
func (u *UserController) Create(c *gin.Context)
Create creates a new API user with provided context arguments.
func (*UserController) Delete ¶
func (u *UserController) Delete(c *gin.Context)
Delete deletes an API user and any sessions by email
func (*UserController) DeleteAPIToken ¶
func (u *UserController) DeleteAPIToken(c *gin.Context)
DeleteAPIToken deletes and disables a user's API token.
func (*UserController) Index ¶
func (u *UserController) Index(c *gin.Context)
Index lists all API users
func (*UserController) NewAPIToken ¶
func (u *UserController) NewAPIToken(c *gin.Context)
NewAPIToken generates a new API token for a user overwriting any pre-existing one set.
func (*UserController) UpdatePassword ¶
func (u *UserController) UpdatePassword(c *gin.Context)
UpdatePassword changes the password for the current User.
func (*UserController) UpdateRole ¶
func (u *UserController) UpdateRole(c *gin.Context)
UpdateRole changes role field of a specified API user.
type VRFKeysController ¶
type VRFKeysController struct {
App chainlink.Application
}
VRFKeysController manages VRF keys
func (*VRFKeysController) Create ¶
func (vrfkc *VRFKeysController) Create(c *gin.Context)
Create and return a VRF key Example: "POST <application>/keys/vrf"
func (*VRFKeysController) Delete ¶
func (vrfkc *VRFKeysController) Delete(c *gin.Context)
Delete a VRF key Example: "DELETE <application>/keys/vrf/:keyID" "DELETE <application>/keys/vrf/:keyID?hard=true"
func (*VRFKeysController) Export ¶
func (vrfkc *VRFKeysController) Export(c *gin.Context)
Export exports a VRF key Example: "Post <application>/keys/vrf/export/:keyID"
func (*VRFKeysController) Import ¶
func (vrfkc *VRFKeysController) Import(c *gin.Context)
Import imports a VRF key Example: "Post <application>/keys/vrf/import"
func (*VRFKeysController) Index ¶
func (vrfkc *VRFKeysController) Index(c *gin.Context)
Index lists VRF keys Example: "GET <application>/keys/vrf"
type WebAuthnController ¶
type WebAuthnController struct { App chainlink.Application // contains filtered or unexported fields }
WebAuthnController manages registers new keys as well as authentication with those keys
func NewWebAuthnController ¶
func NewWebAuthnController(app chainlink.Application) WebAuthnController
func (*WebAuthnController) BeginRegistration ¶
func (w *WebAuthnController) BeginRegistration(c *gin.Context)
func (*WebAuthnController) FinishRegistration ¶
func (w *WebAuthnController) FinishRegistration(c *gin.Context)
Source Files ¶
- api.go
- bridge_types_controller.go
- build_info_controller.go
- chains_controller.go
- common.go
- config_controller.go
- cookies.go
- cosmos_chains_controller.go
- cosmos_keys_controller.go
- cosmos_nodes_controller.go
- cosmos_transfer_controller.go
- csa_keys_controller.go
- dkgencrypt_keys_controller.go
- dkgsign_keys_controller.go
- eth_keys_controller.go
- evm_chains_controller.go
- evm_forwarders_controller.go
- evm_nodes_controller.go
- evm_transactions_controller.go
- evm_transfer_controller.go
- evm_tx_attempts_controller.go
- external_initiators_controller.go
- features_controller.go
- health_controller.go
- helpers.go
- jobs_controller.go
- keys_controller.go
- lca_controller.go
- log_controller.go
- loop_registry.go
- middleware.go
- nodes_controller.go
- ocr2_keys_controller.go
- ocr_keys_controller.go
- p2p_keys_controller.go
- ping_controller.go
- pipeline_job_spec_errors_controller.go
- pipeline_runs_controller.go
- replay_controller.go
- router.go
- sessions_controller.go
- solana_chains_controller.go
- solana_keys_controller.go
- solana_nodes_controller.go
- solana_transfer_controller.go
- starknet_chains_controller.go
- starknet_keys_controller.go
- starknet_nodes_controller.go
- user_controller.go
- vrf_keys_controller.go
- webauthn_controller.go
Directories ¶
Path | Synopsis |
---|---|
Package schema is used to read schema files go:generate go-bindata -ignore=\.go -pkg=schema -o=bindata.go ./...
|
Package schema is used to read schema files go:generate go-bindata -ignore=\.go -pkg=schema -o=bindata.go ./... |