argo

type Application struct {
	Namespace string
	Name      string
}

type Argo interface {
	// Refresh merge-patches app's annotations with argocd.argoproj.io/refresh: normal — the
	// sole write this package performs. Argo's own controller treats a refresh request as
	// idempotent and clears the annotation once it has processed it, which is exactly why
	// ArgoRefreshedStep does not try to detect "already refreshed" from the annotation's own
	// presence (see its doc comment in internal/engine).
	Refresh(ctx context.Context, app Application) error
	// Get reads app's current status. A missing Application wraps ErrNotFound.
	Get(ctx context.Context, app Application) (Status, error)
}

type Fake struct {
	Statuses map[Application]Status
	// GetErr and RefreshErr, when set, are returned by every call to the matching method
	// instead of the configured/not-found behavior — simulating a transient plumbing error a
	// caller must retry rather than treat as authoritative.
	GetErr, RefreshErr error
	// OnRefresh, when set, runs on every Refresh — see Refresh's own doc comment.
	OnRefresh func(app Application)

	Calls []string
	// contains filtered or unexported fields
}

type Status struct {
	SyncStatus     string    // status.sync.status: "Synced", "OutOfSync", "Unknown", ...
	SyncRevision   string    // status.sync.revision: the commit sha Argo last compared/synced against
	HealthStatus   string    // status.health.status: "Healthy", "Degraded", "Progressing", ...
	OperationPhase string    // status.operationState.phase: "", "Running", "Succeeded", "Failed", "Error", "Terminating"
	ReconciledAt   time.Time // status.reconciledAt; zero when absent or unparsable
}