reposerver

func (*Client) Cleanup ¶

func (c *Client) Cleanup()

Cleanup stops the port-forward if one was started by this client.

func (*Client) EnsurePortForward ¶

func (c *Client) EnsurePortForward() error

EnsurePortForward starts a port-forward to the Argo CD repo server if one is not already running. It is idempotent and safe to call concurrently.

func (*Client) GenerateManifests ¶

func (c *Client) GenerateManifests(ctx context.Context, appDir string, request *repoapiclient.ManifestRequest) ([]string, error)

GenerateManifests renders Kubernetes manifests for the given application source by streaming the source files to the Argo CD repo server via the GenerateManifestWithFiles gRPC endpoint.

appDir is the local directory that contains the rendered/checked-out source files to stream. It must exist and be readable. The directory is compressed into a .tar.gz archive and streamed chunk-by-chunk to the repo server.

request is a fully-populated ManifestRequest that describes the application, its source, cluster API versions, Helm settings, etc.

Returns the list of rendered manifest strings (one per Kubernetes resource, serialised as JSON by the repo server).

Transient gRPC Unavailable errors (e.g. EOF on the kubectl port-forward tunnel under high concurrency) are retried with exponential back-off up to maxGenerateRetries times before the error is propagated to the caller.

func (*Client) GenerateManifestsForApp ¶

func (c *Client) GenerateManifestsForApp(
	ctx context.Context,
	appDir string,
	app *v1alpha1.Application,
	appLabelKey string,
	kubeVersion string,
	apiVersions []string,
) ([]string, error)

GenerateManifestsForApp is a higher-level helper that compresses the given appDir and sends it to the repo server. It constructs a minimal ManifestRequest from the provided Application object.

This is intentionally kept simple – callers that need fine-grained control over Helm repos, API versions, project settings, etc. should build the ManifestRequest themselves and call GenerateManifests directly.

func (*Client) GenerateManifestsRemote ¶

func (c *Client) GenerateManifestsRemote(ctx context.Context, request *repoapiclient.ManifestRequest) ([]string, error)

GenerateManifestsRemote renders manifests for an application whose source lives on a remote server (e.g. an external Helm chart registry). Unlike GenerateManifests, no local files are streamed; the repo server fetches the chart directly from the registry using the RepoURL / TargetRevision / Chart fields in the ManifestRequest.

This method uses the unary GenerateManifest RPC (not the streaming GenerateManifestWithFiles RPC).

Transient gRPC Unavailable errors are retried with the same exponential back-off as GenerateManifests.