sync

type Applier struct {
	BulkUpsert func(ctx context.Context, catalogID string, ents []catalog.DesiredEntity) error
	BulkDelete func(ctx context.Context, catalogID string, externalIDs []string) error
}

type Change struct {
	Op         string
	ExternalID string
	Before     *catalog.LiveEntity
	After      *catalog.DesiredEntity
	FieldDiffs map[string][2]string
}

type Counts struct {
	Create int
	Update int
	Delete int
	Noop   int
}

type JSONChange struct {
	Op         string               `json:"op"`
	ExternalID string               `json:"external_id"`
	Name       string               `json:"name"`
	FieldDiffs map[string][2]string `json:"field_diffs,omitempty"`
}

type JSONOutput struct {
	Catalog   string       `json:"catalog"`
	CatalogID string       `json:"catalog_id"`
	Counts    Counts       `json:"counts"`
	Changes   []JSONChange `json:"changes"`
}

type Plan struct {
	Catalog   string
	CatalogID string
	Changes   []Change
	Counts    Counts
}

type StaleChange struct {
	ExternalID string
	Reason     string
}