register

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

Variables

var Client *storage.DataStore

Functions

func DirectUpload

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

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

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

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

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>[^?]*)`)
)