The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DirectRequestSpec ¶
type DirectRequestSpec struct {
ContractAddress models.EIP55Address `json:"contractAddress"`
OnChainJobSpecID string `json:"onChainJobSpecId"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
DirectRequestSpec defines the spec details of a DirectRequest Job
func NewDirectRequestSpec ¶
func NewDirectRequestSpec(spec *job.DirectRequestSpec) *DirectRequestSpec
NewDirectRequestSpec initializes a new DirectRequestSpec from a job.DirectRequestSpec
type FluxMonitorSpec ¶
type FluxMonitorSpec struct {
ContractAddress models.EIP55Address `json:"contractAddress"`
Precision int32 `json:"precision"`
Threshold float32 `json:"threshold"`
AbsoluteThreshold float32 `json:"absoluteThreshold"`
PollTimerPeriod string `json:"pollTimerPeriod"`
PollTimerDisabled bool `json:"pollTimerDisabled"`
IdleTimerPeriod string `json:"idleTimerPeriod"`
IdleTimerDisabled bool `json:"idleTimerDisabled"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
FluxMonitorSpec defines the spec details of a FluxMonitor Job
func NewFluxMonitorSpec ¶
func NewFluxMonitorSpec(spec *job.FluxMonitorSpec) *FluxMonitorSpec
NewFluxMonitorSpec initializes a new DirectFluxMonitorSpec from a job.FluxMonitorSpec
type JAID ¶
type JAID struct {
ID string `json:"-"`
}
JAID represents a JSON API ID. It implements the api2go MarshalIdentifier and UnmarshalIdentitier interface.
type JobError ¶
type JobError struct {
ID int64 `json:"id"`
Description string `json:"description"`
Occurrences uint `json:"occurrences"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
JobError represents errors on the job
func NewJobError ¶
type JobResource ¶
type JobResource struct {
JAID
Name string `json:"name"`
Type JobSpecType `json:"type"`
SchemaVersion uint32 `json:"schemaVersion"`
MaxTaskDuration models.Interval `json:"maxTaskDuration"`
DirectRequestSpec *DirectRequestSpec `json:"directRequestSpec"`
FluxMonitorSpec *FluxMonitorSpec `json:"fluxMonitorSpec"`
OffChainReportingSpec *OffChainReportingSpec `json:"offChainReportingOracleSpec"`
KeeperSpec *KeeperSpec `json:"KeeperSpec"`
PipelineSpec PipelineSpec `json:"pipelineSpec"`
Errors []JobError `json:"errors"`
}
JobResource represents a JobResource
func NewJobResource ¶
func NewJobResource(j job.Job) *JobResource
NewJobResource initializes a new JSONAPI job resource
func NewJobResources ¶
func NewJobResources(js []job.Job) []JobResource
NewJobResources initializes a slice of JSONAPI job resources
func (JobResource) GetName ¶
func (r JobResource) GetName() string
GetName implements the api2go EntityNamer interface
type JobSpecType ¶
type JobSpecType string
JobSpecType defines the the the spec type of the job
const ( // DirectRequestJobSpec defines a Direct Request Job DirectRequestJobSpec JobSpecType = "directrequest" // FluxMonitorJobSpec defines a Flux Monitor Job FluxMonitorJobSpec JobSpecType = "fluxmonitor" // OffChainReportingJobSpec defines an OCR Job OffChainReportingJobSpec JobSpecType = "offchainreporting" )
func (JobSpecType) String ¶
func (t JobSpecType) String() string
type KeeperSpec ¶
type KeeperSpec struct {
ContractAddress models.EIP55Address `json:"contractAddress"`
FromAddress models.EIP55Address `json:"fromAddress"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
KeeperSpec defines the spec details of a Keeper Job
func NewKeeperSpec ¶
func NewKeeperSpec(spec *job.KeeperSpec) *KeeperSpec
NewKeeperSpec generates a new KeeperSpec from a job.KeeperSpec
type OffChainReportingSpec ¶
type OffChainReportingSpec struct {
ContractAddress models.EIP55Address `json:"contractAddress"`
P2PPeerID *models.PeerID `json:"p2pPeerID"`
P2PBootstrapPeers pq.StringArray `json:"p2pBootstrapPeers"`
IsBootstrapPeer bool `json:"isBootstrapPeer"`
EncryptedOCRKeyBundleID *models.Sha256Hash `json:"keyBundleID"`
TransmitterAddress *models.EIP55Address `json:"transmitterAddress"`
ObservationTimeout models.Interval `json:"observationTimeout"`
BlockchainTimeout models.Interval `json:"blockchainTimeout"`
ContractConfigTrackerSubscribeInterval models.Interval `json:"contractConfigTrackerSubscribeInterval"`
ContractConfigTrackerPollInterval models.Interval `json:"contractConfigTrackerPollInterval"`
ContractConfigConfirmations uint16 `json:"contractConfigConfirmations"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
OffChainReportingSpec defines the spec details of a OffChainReporting Job
func NewOffChainReportingSpec ¶
func NewOffChainReportingSpec(spec *job.OffchainReportingOracleSpec) *OffChainReportingSpec
NewOffChainReportingSpec initializes a new OffChainReportingSpec from a job.OffchainReportingOracleSpec
type PipelineSpec ¶
PipelineSpec defines the spec details of the pipeline
func NewPipelineSpec ¶
func NewPipelineSpec(spec *pipeline.Spec) PipelineSpec
NewPipelineSpec generates a new PipelineSpec from a pipeline.Spec
Source Files