ocr2

package
v0.0.0-...-cce48a0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 20, 2021 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrJobStopped     = errors.New("job stopped")
	ErrObserveTimeout = errors.New("observation timed out")
)
View Source 
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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.