artifact

type AdoptRequest struct {
	Collection              collection.CollectionRef
	Occurrence              catalog.OccurrenceKey
	ExpectedCatalogRevision uint64
	Name                    string
	Enabled                 bool
	Data                    json.RawMessage
}

type AdoptionMode string

type Artifact struct {
	ID                 basespec.ArtifactID     `json:"id"`
	RootID             basespec.RootID         `json:"rootID"`
	CollectionID       basespec.CollectionID   `json:"collectionID"`
	Binding            SourceBinding           `json:"binding"`
	Kind               basespec.ArtifactKind   `json:"kind"`
	Name               string                  `json:"name"`
	Enabled            bool                    `json:"enabled"`
	Adoption           AdoptionMode            `json:"adoption"`
	ResolvedDefinition *cryptoutil.Digest      `json:"resolvedDefinition,omitempty"`
	Data               json.RawMessage         `json:"-"`
	State              State                   `json:"state"`
	Diagnostics        []diagnostic.Diagnostic `json:"diagnostics,omitempty"`
	Revision           uint64                  `json:"revision"`
	CreatedAt          time.Time               `json:"createdAt"`
	ModifiedAt         time.Time               `json:"modifiedAt"`
}

type ArtifactAddress struct {
	RootID       basespec.RootID       `json:"rootID"`
	CollectionID basespec.CollectionID `json:"collectionID"`
	ArtifactID   basespec.ArtifactID   `json:"artifactID"`
	Kind         basespec.ArtifactKind `json:"kind"`
}

type ArtifactRef struct {
	RootID     basespec.RootID     `json:"rootID"`
	ArtifactID basespec.ArtifactID `json:"artifactID"`
}

type Draft struct {
	Name    string
	Enabled bool
	Data    json.RawMessage
}

type PinRequest struct {
	Collection                 collection.CollectionRef
	ExpectedCollectionRevision uint64
	Binding                    SourceBinding
	Name                       string
	Enabled                    bool
	Data                       json.RawMessage
}

type Policy interface {
	Derive(
		ctx context.Context,
		value collection.Collection,
		occurrence catalog.Occurrence,
		def definition.Definition,
	) (Draft, bool, []diagnostic.Diagnostic)
}

type Reader interface {
	Get(
		ctx context.Context,
		ref ArtifactRef,
	) (Artifact, error)

	ListByCollection(
		ctx context.Context,
		ref collection.CollectionRef,
	) ([]Artifact, error)

	ListSuppressions(
		ctx context.Context,
		ref collection.CollectionRef,
	) ([]Suppression, error)
}

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

type Reconciliation struct {
	Creates     []Artifact
	Updates     []SourceStateUpdate
	Diagnostics []diagnostic.Diagnostic
}

type Repository interface {
	Reader

	CreateAdopted(
		ctx context.Context,
		value Artifact,
		expectedCollectionRevision uint64,
		expectedCatalogRevision uint64,
	) error

	CreatePinned(
		ctx context.Context,
		value Artifact,
		expectedCollectionRevision uint64,
		expectedCatalogRevision uint64,
	) error

	Update(
		ctx context.Context,
		value Artifact,
		expectedRevision uint64,
	) error

	Unadopt(
		ctx context.Context,
		ref ArtifactRef,
		expectedRevision uint64,
		suppression *Suppression,
	) error

	Suppress(
		ctx context.Context,
		value Suppression,
		expectedCollectionRevision uint64,
	) error

	Unsuppress(
		ctx context.Context,
		ref collection.CollectionRef,
		binding SourceBinding,
		expectedRevision uint64,
	) error

	Purge(
		ctx context.Context,
		ref ArtifactRef,
		expectedRevision uint64,
	) error
}

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

type SourceBinding struct {
	SourceID           basespec.SourceID           `json:"sourceID"`
	Locator            basespec.Locator            `json:"locator"`
	SubresourceLocator basespec.SubresourceLocator `json:"subresourceLocator,omitempty"`
	ExpectedKind       basespec.ArtifactKind       `json:"expectedKind"`
}

type SourceStateUpdate struct {
	ArtifactID         basespec.ArtifactID
	RootID             basespec.RootID
	CollectionID       basespec.CollectionID
	ResolvedDefinition *cryptoutil.Digest
	State              State
	Diagnostics        []diagnostic.Diagnostic
	Revision           uint64
	ModifiedAt         time.Time
	ExpectedRevision   uint64
}

type State string

type SuppressRequest struct {
	Collection                 collection.CollectionRef
	ExpectedCollectionRevision uint64
	Binding                    SourceBinding
}

type Suppression struct {
	RootID       basespec.RootID       `json:"rootID"`
	CollectionID basespec.CollectionID `json:"collectionID"`
	Binding      SourceBinding         `json:"binding"`
	Revision     uint64                `json:"revision"`
	CreatedAt    time.Time             `json:"createdAt"`
	ModifiedAt   time.Time             `json:"modifiedAt"`
}