Documentation ¶
Index ¶
- Constants
- Variables
- func DownloadResultsHandler(ctx context.Context, cmd *cobra.Command, cfg types.Bacalhau, ...) error
- func EnsureValidVersion(ctx context.Context, clientVersion, serverVersion *models.BuildVersionInfo) error
- func GetAPIClientV2(cmd *cobra.Command, cfg types.Bacalhau) (clientv2.API, error)
- func GetCleanupManager(ctx context.Context) *system.CleanupManager
- func GetDefaultJobFolder(jobID string) string
- func InjectCleanupManager(ctx context.Context) context.Context
- 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 SetupConfig(cmd *cobra.Command) (types.Bacalhau, error)
- func SetupRepo(cfg types.Bacalhau) (*repo.FsRepo, error)
- func SetupRepoConfig(cmd *cobra.Command) (types.Bacalhau, error)
- func WriteToken(path, apiURL string, cred *apimodels.HTTPCredential) error
- type LiveTableWriter
- type LogOptions
- type Versions
Constants ¶
View Source
const AutoDownloadFolderPerm = 0755
View Source
const ESC = 27
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 GetAPIClientV2 ¶
func GetCleanupManager ¶
func GetCleanupManager(ctx context.Context) *system.CleanupManager
func GetDefaultJobFolder ¶
func InjectCleanupManager ¶ added in v1.5.0
injects a Cleanup Manager into the context. TODO deprecated this and the CleanupManager.
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 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 LiveTableWriter ¶ added in v1.5.0
type LiveTableWriter struct { // Out is the writer to write the table to. Out io.Writer // contains filtered or unexported fields }
LiveTableWriter is a buffered table writer that updates the terminal. The contents of LiveTableWriter will be flushed on a timed interval or when Flush is called.
func NewLiveTableWriter ¶ added in v1.5.0
func NewLiveTableWriter() *LiveTableWriter
NewLiveTableWriter returns a new LiveTableWriter with defaults
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"` }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.