ocr2

Documentation

Index

• Variables
• func NewMonitor() commontypes.MonitoringEndpoint
• type Config
• type DBDriver
• type Job
• type JobDB
• type JobService
  • func NewJobService(dbDriver DBDriver, client chainlink.WebhookClient, peerKey p2pkey.Key, ...) (JobService, error)
• type JobStateDB
  • func NewJobDBWrapper(dbSvc db.JobDBService) JobStateDB

Variables

var (
	ErrJobStopped     = errors.New("job stopped")
	ErrObserveTimeout = errors.New("observation timed out")
)

var (
	ErrJobNotFound = errors.New("job not found")
	ErrInternal    = errors.New("internal error")
)

Functions

func NewMonitor

func NewMonitor() commontypes.MonitoringEndpoint

Types

type Config

type Config struct {
	ContractPollInterval               time.Duration
	ContractTransmitterTransmitTimeout time.Duration
	DatabaseTimeout                    time.Duration
}

type DBDriver

type DBDriver interface {
	String() string
}

type Job

type Job interface {
	median.DataSource

	Start() error
	Run(data string) error
	Stop() error
}

type JobDB

type JobDB interface {
}

type JobService

type JobService interface {
	StartJob(jobID string, spec *model.JobSpec) error
	RunJob(jobID, result string) error
	StopJob(jobID string) error
	Close() error
}

func NewJobService

func NewJobService(
	dbDriver DBDriver,
	client chainlink.WebhookClient,
	peerKey p2pkey.Key,
	peerNetworkingConfig p2p.NetworkingConfig,
	ocrKey ocrkey.KeyV2,
	chainID string,
	chainQueryClient chaintypes.QueryClient,
	cosmosClient chainclient.CosmosClient,
	tmClient tmclient.TendermintClient,
	onchainSigner sdk.AccAddress,
	cosmosKeyring keyring.Keyring,
) (JobService, error)

type JobStateDB

type JobStateDB interface {
	ocrtypes.Database
}

func NewJobDBWrapper

func NewJobDBWrapper(dbSvc db.JobDBService) JobStateDB