refresh

type Publication struct {
	RootID                  artifactstore.RootID
	ExpectedRootRevision    uint64
	ExpectedSourceRevisions map[artifactstore.SourceID]uint64
	SourceGenerations       map[artifactstore.SourceID]string
	Occurrences             []catalog.Occurrence
	RecordCreates           []record.Record
	RecordUpdates           []record.SourceStateUpdate
	Diagnostics             []artifactstore.Diagnostic
	PublishedAt             time.Time
}

type Publisher interface {
	Publish(
		ctx context.Context,
		publication Publication,
	) (catalog.Snapshot, error)
}

type RecordReader interface {
	ListByRoot(
		ctx context.Context,
		rootID artifactstore.RootID,
	) ([]record.Record, error)
}

type Result struct {
	Catalog        catalog.Snapshot
	CreatedRecords []artifactstore.RecordID
	UpdatedRecords []artifactstore.RecordID
	Diagnostics    []artifactstore.Diagnostic
	Candidates     int
}

type RootReader interface {
	Get(
		ctx context.Context,
		id artifactstore.RootID,
		includeDeleted bool,
	) (root.Root, error)

	ListAttachments(
		ctx context.Context,
		rootID artifactstore.RootID,
	) ([]root.Attachment, error)
}

type Runner interface {
	Refresh(
		ctx context.Context,
		rootID artifactstore.RootID,
		plan discovery.Plan,
		policy record.Policy,
	) (Result, error)
}

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