util

Documentation

Index

• Constants
• Variables
• func CheckVersion(cmd *cobra.Command, args []string) error
• func DownloadResultsHandler(ctx context.Context, cmd *cobra.Command, jobID string, ...) error
• func EnsureValidVersion(ctx context.Context, clientVersion, serverVersion *models.BuildVersionInfo) error
• func ExecuteJob(ctx context.Context, j *model.Job, ...) (*model.Job, error)
• func FakeFatalErrorHandler(cmd *cobra.Command, msg error, code int)
• func GetAPIClient(ctx context.Context) *client.APIClient
• func GetAPIClientV2() *clientv2.Client
• func GetCleanupManager(ctx context.Context) *system.CleanupManager
• func GetDefaultJobFolder(jobID string) string
• func Logs(cmd *cobra.Command, options LogOptions) error
• func ReadFromStdinIfAvailable(cmd *cobra.Command) ([]byte, error)
• func ReadToken(apiURL string) (string, error)
• func WriteToken(apiURL, token string) error
• type LogOptions
• type Versions
  • func GetAllVersions(ctx context.Context) (Versions, error)

Constants

const AutoDownloadFolderPerm = 0755

Variables

var Fatal = fatalError

var LoggingMode = logger.LogModeDefault

var ShutdownSignals = []os.Signal{
	os.Interrupt,
	syscall.SIGTERM,
}

var SystemManagerKey = contextKey{/* contains filtered or unexported fields */}

Functions

func CheckVersion

func CheckVersion(cmd *cobra.Command, args []string) error

func DownloadResultsHandler

func DownloadResultsHandler(
	ctx context.Context,
	cmd *cobra.Command,
	jobID string,
	downloadSettings *cliflags.DownloaderSettings,
) error

func EnsureValidVersion

func EnsureValidVersion(ctx context.Context, clientVersion, serverVersion *models.BuildVersionInfo) error

func ExecuteJob

func ExecuteJob(ctx context.Context,
	j *model.Job,
	runtimeSettings *cliflags.RunTimeSettingsWithDownload,
) (*model.Job, error)

func FakeFatalErrorHandler

func FakeFatalErrorHandler(cmd *cobra.Command, msg error, code int)

FakeFatalErrorHandler captures the error for testing, responsibility of the test to handle the exit (if any) NOTE: If your test is not idempotent, you can cause side effects (the underlying function will continue to run) Returned as text JSON to wherever RootCmd is printing.

func GetAPIClient

func GetAPIClient(ctx context.Context) *client.APIClient

func GetAPIClientV2

func GetAPIClientV2() *clientv2.Client

func GetCleanupManager

func GetCleanupManager(ctx context.Context) *system.CleanupManager

func GetDefaultJobFolder

func GetDefaultJobFolder(jobID string) string

func Logs

func Logs(cmd *cobra.Command, options LogOptions) error

func ReadFromStdinIfAvailable

func ReadFromStdinIfAvailable(cmd *cobra.Command) ([]byte, error)

func ReadToken

func ReadToken(apiURL string) (string, error)

func WriteToken

func WriteToken(apiURL, token string) error

Types

type LogOptions

type LogOptions struct {
	JobID       string
	ExecutionID string
	Follow      bool
	Tail        bool
}

type Versions

type Versions struct {
	ClientVersion *models.BuildVersionInfo `json:"clientVersion,omitempty"`
	ServerVersion *models.BuildVersionInfo `json:"serverVersion,omitempty"`
	LatestVersion *models.BuildVersionInfo `json:"latestVersion,omitempty"`
	UpdateMessage string                   `json:"updateMessage,omitempty"`
}

func GetAllVersions

func GetAllVersions(ctx context.Context) (Versions, error)