dataio

func AskYesNoWithTimeout ¶

func AskYesNoWithTimeout(prompt string, timeout time.Duration) bool

func DetectPublish ¶ added in v0.29.8

func DetectPublish(
	ctx context.Context,
	rtClient ctrlrtclient.Client,
	sClient *safeClient.SafeClient,
	log *slog.Logger,
) (bool, error)

DetectPublish decides default publish mode when user did not set --publish.

Detection strategy:

1. Read Service default/kubernetes via the normal kubeconfig endpoint.
2. Read the same Service via https://<ClusterIP>:443 with ServerName override.
3. Compare UIDs of both objects.

Decision matrix:

• same UID: internal path is reachable -> publish=false
• UID mismatch: ClusterIP reached a different cluster (e.g. local minikube/kind) -> publish=true
• network-unreachable on probe: internal path is not reachable -> publish=true
• TLS/auth rejection on probe: ClusterIP reached a different server -> publish=true
• any other probe error (transient 5xx, cancellation, deserialization): ambiguous -> fail fast with hint

func ParseArgs ¶

func ParseArgs(args []string) (string, string, error)

func ResolvePublish ¶ added in v0.29.8

func ResolvePublish(
	ctx context.Context,
	publishFlag PublishFlag,
	rtClient ctrlrtclient.Client,
	sClient *safeClient.SafeClient,
	log *slog.Logger,
) (bool, error)

ResolvePublish returns explicit publish value if user set the flag, otherwise runs autodetection.

func ShouldCleanup ¶ added in v0.29.16

func ShouldCleanup(cleanup, cleanupExplicit bool) bool

ShouldCleanup decides whether to delete an auto-created DataExport. When the --cleanup flag was explicitly set by the user, its value is used directly. Otherwise the decision is delegated to an interactive prompt with a timeout.