remotesync

type Connection interface {
	Remote
	GetJob(context.Context, string) (jobcontract.Snapshot, error)
	ListJobs(context.Context, uint64, uint32) (jobhost.JobPage, error)
	Close() error
}

type Dependencies struct {
	Repository remoteresults.Repository
	Documents  DocumentCache
}

type DocumentCache interface {
	Read(context.Context, jobcontract.ReportReference, func(context.Context, io.ReadWriteSeeker) error) ([]byte, error)
}

type DocumentOutcome struct {
	Imported bool
}

type DocumentRequest struct {
	Request  Request
	Document remoteresults.DocumentReference
}

type Node struct {
	Origin   remoteresults.Origin
	Revision uint64
}

type NodeStatus struct {
	ConfigurationID string    `json:"configuration_id"`
	State           string    `json:"state"`
	ErrorCode       string    `json:"error_code"`
	ObservedAt      time.Time `json:"observed_at"`
	AppliedAt       time.Time `json:"applied_at"`
}

type Outcome struct {
	Mirror remoteresults.Mirror
	// MoreEvents describes the observed page tail, not execution settlement or
	// a final artifact manifest. A later pass may discover newly committed facts.
	MoreEvents bool
}

type Remote interface {
	Probe(context.Context) (jobcontract.RunnerInfo, error)
	ReadEvents(context.Context, runnerclient.EventQuery) (jobhost.EventPage, error)
	DownloadReport(context.Context, string, jobcontract.ReportReference, io.ReadWriteSeeker) error
	DownloadPerformanceArchive(context.Context, string, jobcontract.ReportReference, io.ReadWriteSeeker) error
}

type Request struct {
	Origin remoteresults.Origin
	JobID  string
	Remote Remote
}

type Synchronizer struct {
	// contains filtered or unexported fields
}

type Watcher struct {
	// contains filtered or unexported fields
}

type WatcherDependencies struct {
	Synchronizer     *Synchronizer
	Nodes            func(context.Context) ([]Node, error)
	Connect          func(context.Context, Node) (Connection, error)
	FactPriorityJobs func(context.Context, remoteresults.Origin, string, uint32) (remoteresults.PriorityPage, error)
	DocumentWork     func(context.Context, remoteresults.DocumentQuery) (remoteresults.DocumentPage, error)
}

type WatcherSnapshot struct {
	Running   bool         `json:"running"`
	ErrorCode string       `json:"error_code"`
	Nodes     []NodeStatus `json:"nodes"`
}