util

package
v1.4.1-rc5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 8, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source
const AutoDownloadFolderPerm = 0755

Variables

View Source
var Fatal = fatalError
View Source
var LoggingMode = logger.LogModeDefault
View Source
var ShutdownSignals = []os.Signal{
	os.Interrupt,
	syscall.SIGTERM,
}
View Source
var SystemManagerKey = contextKey{/* contains filtered or unexported fields */}
View Source
var TestError error

Functions

func DownloadResultsHandler

func DownloadResultsHandler(
	ctx context.Context,
	cmd *cobra.Command,
	cfg types.BacalhauConfig,
	apiV2 clientv2.API,
	jobID string,
	downloadSettings *cliflags.DownloaderSettings,
) error

func EnsureValidVersion

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

func GetAPIClientV2

func GetAPIClientV2(cmd *cobra.Command, cfg types.BacalhauConfig) (clientv2.API, error)

func GetCleanupManager

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

func GetDefaultJobFolder

func GetDefaultJobFolder(jobID string) string

func Logs

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

func ReadFromFile added in v1.4.0

func ReadFromFile(path string) ([]byte, error)

func ReadFromStdinIfAvailable

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

func ReadJobFromUser added in v1.4.0

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

func ReadToken added in v1.2.1

func ReadToken(path string, apiURL string) (*apimodels.HTTPCredential, error)

Read the authorization crdential associated with the passed API base URL. If there is no credential currently stored, ReadToken will return nil with no error.

func SetupRepoConfig added in v1.3.2

func SetupRepoConfig(cmd *cobra.Command) (types.BacalhauConfig, error)

func WriteToken added in v1.2.1

func WriteToken(path, apiURL string, cred *apimodels.HTTPCredential) error

Persistently store the authorization token against the passed API base URL. Callers may pass nil for the credential which will delete any existing stored token.

Types

type LogOptions added in v1.2.2

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

type Versions added in v1.1.2

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 added in v1.1.2

func GetAllVersions(ctx context.Context, cfg types.BacalhauConfig, api clientv2.API) (Versions, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL