cmd

Documentation

Index

• Constants
• func GetDownloadModeVals() []string
• func GetFormatVals() []string
• func GetUploadModeVals() []string
• func NewDataCommand() *cobra.Command
• func NewDownloadCommand(opts *RootOptions) *cobra.Command
• func NewUploadCommand(opts *RootOptions) *cobra.Command
• func PollUntilTimeout(ctx context.Context, pollInterval, timeout time.Duration, ...) error
• type DownloadOptions
  • func (d *DownloadOptions) Download(ctx context.Context) error
• type RootOptions
  • func (r *RootOptions) ConfigureClient() error
  • func (r RootOptions) UploadError(ctx context.Context, code string, recvErr error, prefix storage.DataReference) error
• type UploadOptions
  • func (u *UploadOptions) Sidecar(ctx context.Context) error

Constants

const (
	StartFile   = "_START"
	SuccessFile = "_SUCCESS"
	ErrorFile   = "_ERROR"
)

Functions

func GetDownloadModeVals

func GetDownloadModeVals() []string

func GetFormatVals

func GetFormatVals() []string

func GetUploadModeVals

func GetUploadModeVals() []string

func NewDataCommand

func NewDataCommand() *cobra.Command

NewCommand returns a new instance of the co-pilot root command

func NewDownloadCommand

func NewDownloadCommand(opts *RootOptions) *cobra.Command

func NewUploadCommand

func NewUploadCommand(opts *RootOptions) *cobra.Command

func PollUntilTimeout

func PollUntilTimeout(ctx context.Context, pollInterval, timeout time.Duration, condition wait.ConditionFunc) error

Types

type DownloadOptions

type DownloadOptions struct {
	*RootOptions
	// contains filtered or unexported fields
}

func (*DownloadOptions) Download

func (d *DownloadOptions) Download(ctx context.Context) error

type RootOptions

type RootOptions struct {
	*clientcmd.ConfigOverrides

	Scope promutils.Scope
	Store *storage.DataStore
	// contains filtered or unexported fields
}

func (*RootOptions) ConfigureClient

func (r *RootOptions) ConfigureClient() error

func (RootOptions) UploadError

func (r RootOptions) UploadError(ctx context.Context, code string, recvErr error, prefix storage.DataReference) error

type UploadOptions

type UploadOptions struct {
	*RootOptions
	// contains filtered or unexported fields
}

func (*UploadOptions) Sidecar

func (u *UploadOptions) Sidecar(ctx context.Context) error