Documentation ¶
Index ¶
- Constants
- Variables
- func FindSessionCookie(cookies []*http.Cookie) *http.Cookie
- 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 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(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(bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
- func ValidateEthBalanceForTransfer(c *gin.Context, chain evm.Chain, fromAddr common.Address, amount assets.Eth) error
- func ValidateExternalInitiator(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 Change
- type ConfigController
- type ConfigPatchResponse
- type CreateEVMChainRequest
- type CreateEVMForwarderRequest
- type CreateFeedsManagerRequest
- type CreateJobRequest
- type CreateSolanaChainRequest
- type CreateTerraChainRequest
- type ETHKeysController
- 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)
- func (ekc *ETHKeysController) Update(c *gin.Context)
- type EVMChainsController
- type EVMForwardersController
- type EVMNodesController
- type EVMTransfersController
- type EmbedFileSystem
- type ExternalInitiatorsController
- type FeaturesController
- type FeedsManagerController
- type HealthController
- type JobsController
- type LogController
- type LogPatchRequest
- type OCR2KeysController
- type OCRKeysController
- type P2PKeysController
- type PingController
- type PipelineJobSpecErrorsController
- type PipelineRunsController
- type ReplayController
- type ReplayResponse
- type ServeFileSystem
- type Session
- type SessionsController
- type SolanaChainsController
- func (cc *SolanaChainsController) Create(c *gin.Context)
- func (cc *SolanaChainsController) Delete(c *gin.Context)
- func (cc *SolanaChainsController) Index(c *gin.Context, size, page, offset int)
- func (cc *SolanaChainsController) Show(c *gin.Context)
- func (cc *SolanaChainsController) Update(c *gin.Context)
- type SolanaKeysController
- type SolanaNodesController
- type SolanaTransfersController
- type TerraChainsController
- func (cc *TerraChainsController) Create(c *gin.Context)
- func (cc *TerraChainsController) Delete(c *gin.Context)
- func (cc *TerraChainsController) Index(c *gin.Context, size, page, offset int)
- func (cc *TerraChainsController) Show(c *gin.Context)
- func (cc *TerraChainsController) Update(c *gin.Context)
- type TerraKeysController
- type TerraNodesController
- type TerraTransfersController
- type TransactionsController
- type TxAttemptsController
- type UpdateEVMChainRequest
- type UpdateFeedsManagerRequest
- type UpdatePasswordRequest
- type UpdateSolanaChainRequest
- type UpdateTerraChainRequest
- type UserController
- type VRFKeysController
- type WebAuthnController
- type WebSecurityConfig
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" )
Variables ¶
var ( ErrMissingChainID = errors.New("evmChainID does not match any local chains") ErrInvalidChainID = errors.New("invalid evmChainID") ErrMultipleChains = errors.New("more than one chain available, you must specify evmChainID parameter") )
var ErrSolanaNotEnabled = errors.New("Solana is disabled. Set SOLANA_ENABLED=true to enable.")
ErrSolanaNotEnabled is returned when SOLANA_ENABLED is not true.
var ErrTerraNotEnabled = errors.New("Terra is disabled. Set TERRA_ENABLED=true to enable.")
ErrTerraNotEnabled is returned when TERRA_ENABLED is not true.
Functions ¶
func FindSessionCookie ¶ added in v0.8.2
FindSessionCookie returns the cookie with the "clsession" name
func GzipFileServer ¶ added in v0.10.6
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 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(app chainlink.Application, prometheus *ginprom.Prometheus) *gin.Engine
Router listens and responds to requests to the node for valid paths.
func ServeGzippedAssets ¶ added in v0.10.6
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 ¶ added in v1.1.0
func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error
ValidateBridgeType checks that the bridge type has the required field with valid values.
func ValidateBridgeTypeNotExist ¶ added in v1.1.0
func ValidateBridgeTypeNotExist(bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
ValidateBridgeTypeNotExist checks that a bridge has not already been created
func ValidateEthBalanceForTransfer ¶ added in v1.2.0
func ValidateEthBalanceForTransfer(c *gin.Context, chain evm.Chain, fromAddr common.Address, amount assets.Eth) error
ValidateEthBalanceForTransfer validates that the current balance can cover the transaction amount
func ValidateExternalInitiator ¶ added in v1.1.0
func ValidateExternalInitiator( 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 ¶ added in v1.3.0
type BuildInfoController struct {
App chainlink.Application
}
BuildVersonController has the build_info endpoint.
func (*BuildInfoController) Show ¶ added in v1.3.0
func (eic *BuildInfoController) Show(c *gin.Context)
Show returns the build info.
type CSAKeysController ¶ added in v0.10.8
type CSAKeysController struct {
App chainlink.Application
}
CSAKeysController manages CSA keys
func (*CSAKeysController) Create ¶ added in v0.10.8
func (ctrl *CSAKeysController) Create(c *gin.Context)
Create and return a CSA key Example: "POST <application>/keys/csa"
func (*CSAKeysController) Export ¶ added in v1.0.0
func (ctrl *CSAKeysController) Export(c *gin.Context)
Export exports a key
func (*CSAKeysController) Import ¶ added in v1.1.0
func (ctrl *CSAKeysController) Import(c *gin.Context)
Import imports a CSA key
func (*CSAKeysController) Index ¶ added in v0.10.8
func (ctrl *CSAKeysController) Index(c *gin.Context)
Index lists CSA keys Example: "GET <application>/keys/csa"
type Change ¶ added in v0.6.6
Change represents the old value and the new value after a PATH request has been made
type ConfigController ¶
type ConfigController struct {
App chainlink.Application
}
ConfigController manages config variables
func (*ConfigController) Patch ¶ added in v0.6.6
func (cc *ConfigController) Patch(c *gin.Context)
Patch updates one or more configuration options
func (*ConfigController) Show ¶
func (cc *ConfigController) Show(c *gin.Context)
Show returns the whitelist of config variables Example:
"<application>/config"
type ConfigPatchResponse ¶ added in v0.6.6
type ConfigPatchResponse struct { EvmGasPriceDefault Change `json:"ethGasPriceDefault"` EVMChainID *utils.Big `json:"evmChainID"` }
ConfigPatchResponse represents the change to the configuration made due to a PATCH to the config endpoint
func (ConfigPatchResponse) GetID ¶ added in v0.6.6
func (c ConfigPatchResponse) GetID() string
GetID returns the jsonapi ID.
func (*ConfigPatchResponse) SetID ¶ added in v0.6.6
func (*ConfigPatchResponse) SetID(string) error
SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.
type CreateEVMChainRequest ¶ added in v1.2.0
type CreateEVMChainRequest struct { ID utils.Big `json:"chainID"` Config types.ChainCfg `json:"config"` }
CreateEVMChainRequest is a JSONAPI request for creating an EVM chain.
type CreateEVMForwarderRequest ¶ added in v1.3.0
type CreateEVMForwarderRequest struct { EVMChainID *utils.Big `json:"chainID"` Address common.Address `json:"address"` }
CreateEVMChainRequest is a JSONAPI request for creating an EVM chain.
type CreateFeedsManagerRequest ¶ added in v0.10.8
type CreateFeedsManagerRequest struct { Name string `json:"name"` URI string `json:"uri"` JobTypes []string `json:"jobTypes"` PublicKey crypto.PublicKey `json:"publicKey"` IsBootstrapPeer bool `json:"isBootstrapPeer"` BootstrapPeerMultiaddr null.String `json:"bootstrapPeerMultiaddr"` }
CreateFeedsManagerRequest represents a JSONAPI request for registering a feeds manager
type CreateJobRequest ¶ added in v0.10.6
type CreateJobRequest struct {
TOML string `json:"toml"`
}
CreateJobRequest represents a request to create and start a job (V2).
type CreateSolanaChainRequest ¶ added in v1.4.0
type CreateSolanaChainRequest struct { ID string `json:"chainID"` Config db.ChainCfg `json:"config"` }
CreateSolanaChainRequest is a JSONAPI request for creating a Solana chain.
type CreateTerraChainRequest ¶ added in v1.2.0
type CreateTerraChainRequest struct { ID string `json:"chainID"` Config db.ChainCfg `json:"config"` }
CreateTerraChainRequest is a JSONAPI request for creating a Terra chain.
type ETHKeysController ¶ added in v0.9.9
type ETHKeysController struct {
App chainlink.Application
}
ETHKeysController manages account keys
func (*ETHKeysController) Create ¶ added in v0.9.9
func (ekc *ETHKeysController) Create(c *gin.Context)
Create adds a new account Example:
"<application>/keys/eth"
func (*ETHKeysController) Delete ¶ added in v0.9.9
func (ekc *ETHKeysController) Delete(c *gin.Context)
Delete an ETH key bundle Example: "DELETE <application>/keys/eth/:keyID" "DELETE <application>/keys/eth/:keyID?hard=true"
func (*ETHKeysController) Export ¶ added in v0.9.9
func (ekc *ETHKeysController) Export(c *gin.Context)
func (*ETHKeysController) Import ¶ added in v0.9.9
func (ekc *ETHKeysController) Import(c *gin.Context)
Import imports a key
func (*ETHKeysController) Index ¶ added in v0.9.9
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"
func (*ETHKeysController) Update ¶ added in v1.1.0
func (ekc *ETHKeysController) Update(c *gin.Context)
Update an ETH key's parameters Example: "PUT <application>/keys/eth/:keyID?maxGasPriceGWei=12345"
type EVMChainsController ¶ added in v1.2.0
type EVMChainsController struct {
App chainlink.Application
}
EVMChainsController manages EVM chains.
func (*EVMChainsController) Create ¶ added in v1.2.0
func (cc *EVMChainsController) Create(c *gin.Context)
Create adds a new EVM chain.
func (*EVMChainsController) Delete ¶ added in v1.2.0
func (cc *EVMChainsController) Delete(c *gin.Context)
Delete removes an EVM chain.
func (*EVMChainsController) Index ¶ added in v1.2.0
func (cc *EVMChainsController) Index(c *gin.Context, size, page, offset int)
Index lists EVM chains.
func (*EVMChainsController) Show ¶ added in v1.2.0
func (cc *EVMChainsController) Show(c *gin.Context)
Show gets an EVM chain by chain id.
func (*EVMChainsController) Update ¶ added in v1.2.0
func (cc *EVMChainsController) Update(c *gin.Context)
Update configures an existing EVM chain.
type EVMForwardersController ¶ added in v1.3.0
type EVMForwardersController struct {
App chainlink.Application
}
EVMForwardersController manages EVM chains.
func (*EVMForwardersController) Create ¶ added in v1.3.0
func (cc *EVMForwardersController) Create(c *gin.Context)
Create adds a new EVM chain.
func (*EVMForwardersController) Delete ¶ added in v1.3.0
func (cc *EVMForwardersController) Delete(c *gin.Context)
Delete removes an EVM chain.
type EVMNodesController ¶ added in v1.2.0
type EVMNodesController struct {
App chainlink.Application
}
EVMNodesController manages EVM nodes.
func (*EVMNodesController) Create ¶ added in v1.2.0
func (nc *EVMNodesController) Create(c *gin.Context)
Create adds a new EVM node.
func (*EVMNodesController) Delete ¶ added in v1.2.0
func (nc *EVMNodesController) Delete(c *gin.Context)
Delete removes an EVM node.
type EVMTransfersController ¶ added in v1.3.0
type EVMTransfersController struct {
App chainlink.Application
}
EVMTransfersController can send LINK tokens to another address
func (*EVMTransfersController) Create ¶ added in v1.3.0
func (tc *EVMTransfersController) Create(c *gin.Context)
Create sends ETH from the Chainlink's account to a specified address.
Example: "<application>/withdrawals"
type EmbedFileSystem ¶ added in v1.1.0
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 ¶ added in v1.0.0
type FeaturesController struct {
App chainlink.Application
}
FeaturesController manages the feature flags
func (*FeaturesController) Index ¶ added in v1.0.0
func (fc *FeaturesController) Index(c *gin.Context)
Index retrieves the features Example: "GET <application>/features"
type FeedsManagerController ¶ added in v0.10.8
type FeedsManagerController struct {
App chainlink.Application
}
FeedsManagerController manages the feeds managers
func (*FeedsManagerController) Create ¶ added in v0.10.8
func (fmc *FeedsManagerController) Create(c *gin.Context)
Create registers a new feeds manager. Example: "POST <application>/feeds_managers"
func (*FeedsManagerController) List ¶ added in v0.10.8
func (fmc *FeedsManagerController) List(c *gin.Context)
List retrieves all the feeds managers Example: "GET <application>/feeds_managers"
func (*FeedsManagerController) Show ¶ added in v0.10.8
func (fmc *FeedsManagerController) Show(c *gin.Context)
Show retrieve a feeds manager by id Example: "GET <application>/feeds_managers/<id>"
func (*FeedsManagerController) Update ¶ added in v1.0.0
func (fmc *FeedsManagerController) Update(c *gin.Context)
Update updates a feeds manager Example: "PUT <application>/feeds_managers/<id>"
type HealthController ¶ added in v0.10.8
type HealthController struct {
App chainlink.Application
}
func (*HealthController) Health ¶ added in v0.10.8
func (hc *HealthController) Health(c *gin.Context)
func (*HealthController) Readyz ¶ added in v0.10.8
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 ¶ added in v0.9.7
type JobsController struct {
App chainlink.Application
}
JobsController manages jobs
func (*JobsController) Create ¶ added in v0.9.7
func (jc *JobsController) Create(c *gin.Context)
Create validates, saves and starts a new job. Example: "POST <application>/jobs"
func (*JobsController) Delete ¶ added in v0.9.7
func (jc *JobsController) Delete(c *gin.Context)
Delete hard deletes a job spec. Example: "DELETE <application>/specs/:ID"
func (*JobsController) Index ¶ added in v0.9.7
func (jc *JobsController) Index(c *gin.Context, size, page, offset int)
Index lists all jobs Example: "GET <application>/jobs"
func (*JobsController) Show ¶ added in v0.9.7
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"
type LogController ¶ added in v0.10.4
type LogController struct {
App chainlink.Application
}
LogController manages the logger config
func (*LogController) Get ¶ added in v0.10.4
func (cc *LogController) Get(c *gin.Context)
Get retrieves the current log config settings
func (*LogController) Patch ¶ added in v0.10.4
func (cc *LogController) Patch(c *gin.Context)
Patch sets a log level and enables sql logging for the logger
type LogPatchRequest ¶ added in v0.10.4
type OCR2KeysController ¶ added in v1.2.0
type OCR2KeysController struct {
App chainlink.Application
}
OCRKeysController manages OCR key bundles
func (*OCR2KeysController) Create ¶ added in v1.2.0
func (ocr2kc *OCR2KeysController) Create(c *gin.Context)
Create and return an OCR2 key bundle Example: "POST <application>/keys/ocr"
func (*OCR2KeysController) Delete ¶ added in v1.2.0
func (ocr2kc *OCR2KeysController) Delete(c *gin.Context)
Delete an OCR2 key bundle Example: "DELETE <application>/keys/ocr/:keyID"
func (*OCR2KeysController) Export ¶ added in v1.2.0
func (ocr2kc *OCR2KeysController) Export(c *gin.Context)
Export exports an OCR2 key bundle Example: "Post <application>/keys/ocr/export"
func (*OCR2KeysController) Import ¶ added in v1.2.0
func (ocr2kc *OCR2KeysController) Import(c *gin.Context)
Import imports an OCR2 key bundle Example: "Post <application>/keys/ocr/import"
func (*OCR2KeysController) Index ¶ added in v1.2.0
func (ocr2kc *OCR2KeysController) Index(c *gin.Context)
Index lists OCR2 key bundles Example: "GET <application>/keys/ocr"
type OCRKeysController ¶ added in v0.9.9
type OCRKeysController struct {
App chainlink.Application
}
OCRKeysController manages OCR key bundles
func (*OCRKeysController) Create ¶ added in v0.9.9
func (ocrkc *OCRKeysController) Create(c *gin.Context)
Create and return an OCR key bundle Example: "POST <application>/keys/ocr"
func (*OCRKeysController) Delete ¶ added in v0.9.9
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 ¶ added in v0.9.9
func (ocrkc *OCRKeysController) Export(c *gin.Context)
Export exports an OCR key bundle Example: "Post <application>/keys/ocr/export"
func (*OCRKeysController) Import ¶ added in v0.9.9
func (ocrkc *OCRKeysController) Import(c *gin.Context)
Import imports an OCR key bundle Example: "Post <application>/keys/ocr/import"
func (*OCRKeysController) Index ¶ added in v0.9.9
func (ocrkc *OCRKeysController) Index(c *gin.Context)
Index lists OCR key bundles Example: "GET <application>/keys/ocr"
type P2PKeysController ¶ added in v0.9.3
type P2PKeysController struct {
App chainlink.Application
}
P2PKeysController manages P2P keys
func (*P2PKeysController) Create ¶ added in v0.9.3
func (p2pkc *P2PKeysController) Create(c *gin.Context)
Create and return a P2P key Example: "POST <application>/keys/p2p"
func (*P2PKeysController) Delete ¶ added in v0.9.3
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 ¶ added in v0.9.9
func (p2pkc *P2PKeysController) Export(c *gin.Context)
Export exports a P2P key Example: "Post <application>/keys/p2p/export"
func (*P2PKeysController) Import ¶ added in v0.9.9
func (p2pkc *P2PKeysController) Import(c *gin.Context)
Import imports a P2P key Example: "Post <application>/keys/p2p/import"
func (*P2PKeysController) Index ¶ added in v0.9.3
func (p2pkc *P2PKeysController) Index(c *gin.Context)
Index lists P2P keys Example: "GET <application>/keys/p2p"
type PingController ¶ added in v0.6.6
type PingController struct {
App chainlink.Application
}
PingController has the ping endpoint.
func (*PingController) Show ¶ added in v0.6.6
func (eic *PingController) Show(c *gin.Context)
Show returns pong.
type PipelineJobSpecErrorsController ¶ added in v0.10.11
type PipelineJobSpecErrorsController struct {
App chainlink.Application
}
PipelineJobSpecErrorsController manages PipelineJobSpecError requests
func (*PipelineJobSpecErrorsController) Destroy ¶ added in v0.10.11
func (psec *PipelineJobSpecErrorsController) Destroy(c *gin.Context)
Destroy deletes a PipelineJobSpecError record from the database, effectively silencing the error notification
type PipelineRunsController ¶ added in v0.9.7
type PipelineRunsController struct {
App chainlink.Application
}
PipelineRunsController manages V2 job run requests.
func (*PipelineRunsController) Create ¶ added in v0.9.7
func (prc *PipelineRunsController) Create(c *gin.Context)
Create triggers a pipeline run for a job. Example: "POST <application>/jobs/:ID/runs"
func (*PipelineRunsController) Index ¶ added in v0.9.7
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 ¶ added in v0.10.10
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 ¶ added in v0.9.7
func (prc *PipelineRunsController) Show(c *gin.Context)
Show returns a specified pipeline run. Example: "GET <application>/jobs/:ID/runs/:runID"
type ReplayController ¶ added in v0.10.11
type ReplayController struct {
App chainlink.Application
}
func (*ReplayController) ReplayFromBlock ¶ added in v0.10.11
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 ¶ added in v0.10.11
type ReplayResponse struct { Message string `json:"message"` EVMChainID *utils.Big `json:"evmChainID"` }
func (ReplayResponse) GetID ¶ added in v0.10.11
func (s ReplayResponse) GetID() string
GetID returns the jsonapi ID.
func (ReplayResponse) GetName ¶ added in v0.10.11
func (ReplayResponse) GetName() string
GetName returns the collection name for jsonapi.
func (*ReplayResponse) SetID ¶ added in v0.10.11
func (*ReplayResponse) SetID(string) error
SetID is used to conform to the UnmarshallIdentifier interface for deserializing from jsonapi documents.
type ServeFileSystem ¶ added in v0.10.6
type ServeFileSystem interface { http.FileSystem Exists(prefix string, path string) bool }
ServeFileSystem wraps a http.FileSystem with an additional file existence check
func NewEmbedFileSystem ¶ added in v1.1.0
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 ¶ added in v1.1.0
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 erases the session ID for the sole API user.
type SolanaChainsController ¶ added in v1.4.0
type SolanaChainsController struct {
App chainlink.Application
}
SolanaChainsController manages Solana chains.
func (*SolanaChainsController) Create ¶ added in v1.4.0
func (cc *SolanaChainsController) Create(c *gin.Context)
Create adds a new Solana chain.
func (*SolanaChainsController) Delete ¶ added in v1.4.0
func (cc *SolanaChainsController) Delete(c *gin.Context)
Delete removes a Solana chain.
func (*SolanaChainsController) Index ¶ added in v1.4.0
func (cc *SolanaChainsController) Index(c *gin.Context, size, page, offset int)
Index lists Solana chains.
func (*SolanaChainsController) Show ¶ added in v1.4.0
func (cc *SolanaChainsController) Show(c *gin.Context)
Show gets a Solana chain by chain id.
func (*SolanaChainsController) Update ¶ added in v1.4.0
func (cc *SolanaChainsController) Update(c *gin.Context)
Update configures an existing Solana chain.
type SolanaKeysController ¶ added in v1.2.0
type SolanaKeysController struct {
App chainlink.Application
}
SolanaKeysController manages Solana keys
func (*SolanaKeysController) Create ¶ added in v1.2.0
func (solkc *SolanaKeysController) Create(c *gin.Context)
Create and return a Solana key Example: "POST <application>/keys/solana"
func (*SolanaKeysController) Delete ¶ added in v1.2.0
func (solkc *SolanaKeysController) Delete(c *gin.Context)
Delete a Solana key Example: "DELETE <application>/keys/solana/:keyID" "DELETE <application>/keys/solana/:keyID?hard=true"
func (*SolanaKeysController) Export ¶ added in v1.2.0
func (solkc *SolanaKeysController) Export(c *gin.Context)
Export exports a Solana key Example: "Post <application>/keys/solana/export"
func (*SolanaKeysController) Import ¶ added in v1.2.0
func (solkc *SolanaKeysController) Import(c *gin.Context)
Import imports a Solana key Example: "Post <application>/keys/solana/import"
func (*SolanaKeysController) Index ¶ added in v1.2.0
func (solkc *SolanaKeysController) Index(c *gin.Context)
Index lists Solana keys Example: "GET <application>/keys/solana"
type SolanaNodesController ¶ added in v1.4.0
type SolanaNodesController struct {
App chainlink.Application
}
SolanaNodesController manages Solana nodes.
func (*SolanaNodesController) Create ¶ added in v1.4.0
func (nc *SolanaNodesController) Create(c *gin.Context)
Create adds a new Solana node.
func (*SolanaNodesController) Delete ¶ added in v1.4.0
func (nc *SolanaNodesController) Delete(c *gin.Context)
Delete removes a Solana node.
type SolanaTransfersController ¶ added in v1.4.0
type SolanaTransfersController struct {
App chainlink.Application
}
SolanaTransfersController can send LINK tokens to another address
func (*SolanaTransfersController) Create ¶ added in v1.4.0
func (tc *SolanaTransfersController) Create(c *gin.Context)
Create sends Luna and other native coins from the Chainlink's account to a specified address.
type TerraChainsController ¶ added in v1.2.0
type TerraChainsController struct {
App chainlink.Application
}
TerraChainsController manages Terra chains.
func (*TerraChainsController) Create ¶ added in v1.2.0
func (cc *TerraChainsController) Create(c *gin.Context)
Create adds a new Terra chain.
func (*TerraChainsController) Delete ¶ added in v1.2.0
func (cc *TerraChainsController) Delete(c *gin.Context)
Delete removes a Terra chain.
func (*TerraChainsController) Index ¶ added in v1.2.0
func (cc *TerraChainsController) Index(c *gin.Context, size, page, offset int)
Index lists Terra chains.
func (*TerraChainsController) Show ¶ added in v1.2.0
func (cc *TerraChainsController) Show(c *gin.Context)
Show gets a Terra chain by chain id.
func (*TerraChainsController) Update ¶ added in v1.2.0
func (cc *TerraChainsController) Update(c *gin.Context)
Update configures an existing Terra chain.
type TerraKeysController ¶ added in v1.2.0
type TerraKeysController struct {
App chainlink.Application
}
TerraKeysController manages Terra keys
func (*TerraKeysController) Create ¶ added in v1.2.0
func (terkc *TerraKeysController) Create(c *gin.Context)
Create and return a Terra key Example: "POST <application>/keys/terra"
func (*TerraKeysController) Delete ¶ added in v1.2.0
func (terkc *TerraKeysController) Delete(c *gin.Context)
Delete a Terra key Example: "DELETE <application>/keys/terra/:keyID" "DELETE <application>/keys/terra/:keyID?hard=true"
func (*TerraKeysController) Export ¶ added in v1.2.0
func (terkc *TerraKeysController) Export(c *gin.Context)
Export exports a Terra key Example: "Post <application>/keys/terra/export"
func (*TerraKeysController) Import ¶ added in v1.2.0
func (terkc *TerraKeysController) Import(c *gin.Context)
Import imports a Terra key Example: "Post <application>/keys/terra/import"
func (*TerraKeysController) Index ¶ added in v1.2.0
func (terkc *TerraKeysController) Index(c *gin.Context)
Index lists Terra keys Example: "GET <application>/keys/terra"
type TerraNodesController ¶ added in v1.2.0
type TerraNodesController struct {
App chainlink.Application
}
TerraNodesController manages Terra nodes.
func (*TerraNodesController) Create ¶ added in v1.2.0
func (nc *TerraNodesController) Create(c *gin.Context)
Create adds a new Terra node.
func (*TerraNodesController) Delete ¶ added in v1.2.0
func (nc *TerraNodesController) Delete(c *gin.Context)
Delete removes a Terra node.
type TerraTransfersController ¶ added in v1.3.0
type TerraTransfersController struct {
App chainlink.Application
}
TerraTransfersController can send LINK tokens to another address
func (*TerraTransfersController) Create ¶ added in v1.3.0
func (tc *TerraTransfersController) Create(c *gin.Context)
Create sends Luna and other native coins from the Chainlink's account to a specified address.
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 UpdateEVMChainRequest ¶ added in v1.2.0
type UpdateEVMChainRequest struct { Enabled bool `json:"enabled"` Config types.ChainCfg `json:"config"` }
UpdateEVMChainRequest is a JSONAPI request for updating an EVM chain.
type UpdateFeedsManagerRequest ¶ added in v1.0.0
type UpdateFeedsManagerRequest struct { Name string `json:"name"` URI string `json:"uri"` JobTypes []string `json:"jobTypes"` PublicKey crypto.PublicKey `json:"publicKey"` IsBootstrapPeer bool `json:"isBootstrapPeer"` BootstrapPeerMultiaddr null.String `json:"bootstrapPeerMultiaddr"` }
UpdateFeedsManagerRequest represents a JSONAPI request for updating a feeds manager
type UpdatePasswordRequest ¶ added in v0.10.5
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 UpdateSolanaChainRequest ¶ added in v1.4.0
type UpdateSolanaChainRequest struct { Enabled bool `json:"enabled"` Config db.ChainCfg `json:"config"` }
UpdateSolanaChainRequest is a JSONAPI request for updating a Solana chain.
type UpdateTerraChainRequest ¶ added in v1.2.0
type UpdateTerraChainRequest struct { Enabled bool `json:"enabled"` Config db.ChainCfg `json:"config"` }
UpdateTerraChainRequest is a JSONAPI request for updating a Terra chain.
type UserController ¶
type UserController struct {
App chainlink.Application
}
UserController manages the current Session's User.
func (*UserController) DeleteAPIToken ¶ added in v0.8.2
func (c *UserController) DeleteAPIToken(ctx *gin.Context)
DeleteAPIToken deletes and disables a user's API token.
func (*UserController) NewAPIToken ¶ added in v0.8.2
func (c *UserController) NewAPIToken(ctx *gin.Context)
NewAPIToken generates a new API token for a user overwriting any pre-existing one set.
func (*UserController) UpdatePassword ¶
func (c *UserController) UpdatePassword(ctx *gin.Context)
UpdatePassword changes the password for the current User.
type VRFKeysController ¶ added in v0.10.9
type VRFKeysController struct {
App chainlink.Application
}
VRFKeysController manages VRF keys
func (*VRFKeysController) Create ¶ added in v0.10.9
func (vrfkc *VRFKeysController) Create(c *gin.Context)
Create and return a VRF key Example: "POST <application>/keys/vrf"
func (*VRFKeysController) Delete ¶ added in v0.10.9
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 ¶ added in v0.10.9
func (vrfkc *VRFKeysController) Export(c *gin.Context)
Export exports a VRF key Example: "Post <application>/keys/vrf/export/:keyID"
func (*VRFKeysController) Import ¶ added in v0.10.9
func (vrfkc *VRFKeysController) Import(c *gin.Context)
Import imports a VRF key Example: "Post <application>/keys/vrf/import"
func (*VRFKeysController) Index ¶ added in v0.10.9
func (vrfkc *VRFKeysController) Index(c *gin.Context)
Index lists VRF keys Example: "GET <application>/keys/vrf"
type WebAuthnController ¶ added in v1.1.0
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 ¶ added in v1.1.0
func NewWebAuthnController(app chainlink.Application) WebAuthnController
func (*WebAuthnController) BeginRegistration ¶ added in v1.1.0
func (c *WebAuthnController) BeginRegistration(ctx *gin.Context)
func (*WebAuthnController) FinishRegistration ¶ added in v1.1.0
func (c *WebAuthnController) FinishRegistration(ctx *gin.Context)
Source Files ¶
- api.go
- bridge_types_controller.go
- build_info_controller.go
- common.go
- config_controller.go
- cookies.go
- csa_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
- feeds_manager_controller.go
- health_controller.go
- helpers.go
- jobs_controller.go
- log_controller.go
- middleware.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
- terra_chains_controller.go
- terra_keys_controller.go
- terra_nodes_controller.go
- terra_transfer_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 ./... |