Documentation
¶
Index ¶
- Constants
- Variables
- func DownloadResultsHandler(ctx context.Context, cmd *cobra.Command, cfg types.BacalhauConfig, ...) error
- func EnsureValidVersion(ctx context.Context, clientVersion, serverVersion *models.BuildVersionInfo) error
- func ExecuteJob(ctx context.Context, j *model.Job, api client.APIClient) (*model.Job, error)
- func FakeFatalErrorHandler(cmd *cobra.Command, msg error, code int)
- func GetAPIClient(cfg types.BacalhauConfig) (*client.APIClient, error)
- func GetAPIClientV2(cmd *cobra.Command, cfg types.BacalhauConfig) (clientv2.API, error)
- func GetCleanupManager(ctx context.Context) *system.CleanupManager
- func GetDefaultJobFolder(jobID string) string
- func Logs(cmd *cobra.Command, api clientv2.API, options LogOptions) error
- func ReadFromFile(path string) ([]byte, error)
- func ReadFromStdinIfAvailable(cmd *cobra.Command) ([]byte, error)
- func ReadJobFromUser(cmd *cobra.Command, args []string) ([]byte, error)
- func ReadToken(path string, apiURL string) (*apimodels.HTTPCredential, error)
- func SetupRepoConfig(cmd *cobra.Command) (types.BacalhauConfig, error)
- func WriteToken(path, apiURL string, cred *apimodels.HTTPCredential) error
- type LogOptions
- type Versions
Constants ¶
View Source
const AutoDownloadFolderPerm = 0755
Variables ¶
View Source
var Fatal = fatalError
View Source
var LoggingMode = logger.LogModeDefault
View Source
var SystemManagerKey = contextKey{/* contains filtered or unexported fields */}
View Source
var TestError error
Functions ¶
func DownloadResultsHandler ¶
func EnsureValidVersion ¶
func EnsureValidVersion(ctx context.Context, clientVersion, serverVersion *models.BuildVersionInfo) error
func ExecuteJob ¶
func FakeFatalErrorHandler ¶
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(cfg types.BacalhauConfig) (*client.APIClient, error)
func GetAPIClientV2 ¶
func GetCleanupManager ¶
func GetCleanupManager(ctx context.Context) *system.CleanupManager
func GetDefaultJobFolder ¶
func ReadFromFile ¶ added in v1.4.0
func ReadJobFromUser ¶ added in v1.4.0
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 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
Source Files
¶
Click to show internal directories.
Click to hide internal directories.