register

package

v0.8.18 Latest Latest Go to latest Published: May 1, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flyteorg/flytectl

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func DirectUpload(url string, contentMD5 []byte, size int64, data io.Reader) error
func DownloadFileFromHTTP(ctx context.Context, ref storage.DataReference) (io.ReadCloser, error)
func GetSerializeOutputFiles(ctx context.Context, args []string, archive bool) ([]string, string, error)
func Register(ctx context.Context, args []string, cfg *config.Config, ...) error
func RemoteRegisterCommand() *cobra.Command
func UnMarshalContents(ctx context.Context, fileContents []byte, fname string) (proto.Message, error)
type HTTPClient
type Result
type SignedURLPatternMatcher

Constants ¶

This section is empty.

Variables ¶

View Source

var Client *storage.DataStore

Functions ¶

func DirectUpload ¶ added in v0.5.9

func DirectUpload(url string, contentMD5 []byte, size int64, data io.Reader) error

func DownloadFileFromHTTP ¶

func DownloadFileFromHTTP(ctx context.Context, ref storage.DataReference) (io.ReadCloser, error)

func GetSerializeOutputFiles ¶ added in v0.5.28

func GetSerializeOutputFiles(ctx context.Context, args []string, archive bool) ([]string, string, error)

Get serialize output file list from the args list. If the archive flag is on then download the archives to temp directory and extract it. In case of fast register it will also return the compressed source code The o/p of this function would be sorted list of the file locations.

func Register ¶ added in v0.1.10

func Register(ctx context.Context, args []string, cfg *config.Config, cmdCtx cmdCore.CommandContext) error

func RemoteRegisterCommand ¶

func RemoteRegisterCommand() *cobra.Command

RemoteRegisterCommand will return register command

func UnMarshalContents ¶ added in v0.5.28

func UnMarshalContents(ctx context.Context, fileContents []byte, fname string) (proto.Message, error)

Types ¶

type HTTPClient ¶

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient interface

type Result ¶

type Result struct {
	Name   string
	Status string
	Info   string
}

type SignedURLPatternMatcher ¶ added in v0.5.9

type SignedURLPatternMatcher = *regexp.Regexp

var (
	SignedURLPattern SignedURLPatternMatcher = regexp.MustCompile(`https://((storage\.googleapis\.com/(?P<bucket_gcs>[^/]+))|((?P<bucket_s3>[^\.]+)\.s3\.amazonaws\.com)|(.*\.blob\.core\.windows\.net/(?P<bucket_az>[^/]+)))/(?P<path>[^?]*)`)
)

Source Files ¶

View all Source files

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