handler

Documentation

Index

• func CheckAndRefreshAuth(a *cli.App) error
• func CreateNewRequest(method, url string, body []byte) (*http.Request, error)
• func EnsureImageTag(imageName *string) error
• func ExportDockerImage(imageName string) (io.ReadCloser, int64, error)
• func FieldCheck(a *cli.App) error
• func HandleExistingContainer(app *cli.App, conflictResp *common.ConflictCheckResponse) error
• func PrepareJSONPayload(payload common.Payload) ([]byte, error)
• func ReAuthenticate(a *cli.App) error
• func SendRequest(req *http.Request) (*http.Response, error)
• func StartServer(a *server.App, port string) error
• func ValidateImageName(imageName string) error
• func ValidatePortMapping(port string) error
• func ValidateTargetDomain(targetDomain string) error
• type ChunkMetadata
• type ChunkedClient
  • func NewChunkedClient(app *cli.App) *ChunkedClient
  • func (c *ChunkedClient) Cancel()
  • func (c *ChunkedClient) SendFileAsChunks(ctx context.Context, endpoint string, headers http.Header, reader io.Reader, ...) (*Response, error)
• type PingResponse
  • func PerformPingRequest(a *cli.App) (PingResponse, error)
• type ProgressDisplay
  • func NewProgressDisplay() *ProgressDisplay
  • func (pd *ProgressDisplay) Clear()
  • func (pd *ProgressDisplay) Pause()
  • func (pd *ProgressDisplay) Resume()
  • func (pd *ProgressDisplay) Start()
  • func (pd *ProgressDisplay) Stop()
  • func (pd *ProgressDisplay) Update(completed, total int, percentage float64)
• type Response
  • func SendHTTPRequest(a *cli.App, rp *common.RequestPayload, method string, endpoint string) (*Response, error)
• type UploadProgress

Functions

func CheckAndRefreshAuth

func CheckAndRefreshAuth(a *cli.App) error

func CreateNewRequest

func CreateNewRequest(method, url string, body []byte) (*http.Request, error)

CreateNewRequest creates a new HTTP request

func EnsureImageTag

func EnsureImageTag(imageName *string) error

func ExportDockerImage

func ExportDockerImage(imageName string) (io.ReadCloser, int64, error)

func FieldCheck

func FieldCheck(a *cli.App) error

func HandleExistingContainer

func HandleExistingContainer(app *cli.App, conflictResp *common.ConflictCheckResponse) error

func PrepareJSONPayload

func PrepareJSONPayload(payload common.Payload) ([]byte, error)

PrepareJSONPayload marshals the payload into JSON

func ReAuthenticate

func ReAuthenticate(a *cli.App) error

func SendRequest

func SendRequest(req *http.Request) (*http.Response, error)

SendRequest sends the HTTP request and returns the response

func StartServer

func StartServer(a *server.App, port string) error

func ValidateImageName

func ValidateImageName(imageName string) error

func ValidatePortMapping

func ValidatePortMapping(port string) error

func ValidateTargetDomain

func ValidateTargetDomain(targetDomain string) error

Types

type ChunkMetadata

type ChunkMetadata = common.ChunkMetadata

type ChunkedClient

type ChunkedClient struct {
	// contains filtered or unexported fields
}

func NewChunkedClient

func NewChunkedClient(app *cli.App) *ChunkedClient

NewChunkedClient creates a new chunked client

func (*ChunkedClient) Cancel

func (c *ChunkedClient) Cancel()

func (*ChunkedClient) SendFileAsChunks

func (c *ChunkedClient) SendFileAsChunks(ctx context.Context, endpoint string, headers http.Header, reader io.Reader, totalSize int64, imageName string) (*Response, error)

SendFileAsChunks sends a file as chunks to the specified endpoint

type PingResponse

type PingResponse struct {
	Uptime  string `json:"uptime"`
	Version string `json:"version"`
}

Define a struct to match the JSON response structure

func PerformPingRequest

func PerformPingRequest(a *cli.App) (PingResponse, error)

type ProgressDisplay

type ProgressDisplay struct {
	// contains filtered or unexported fields
}

ProgressDisplay manages the upload progress display

func NewProgressDisplay

func NewProgressDisplay() *ProgressDisplay

NewProgressDisplay creates a new progress display

func (*ProgressDisplay) Clear

func (pd *ProgressDisplay) Clear()

func (*ProgressDisplay) Pause

func (pd *ProgressDisplay) Pause()

func (*ProgressDisplay) Resume

func (pd *ProgressDisplay) Resume()

func (*ProgressDisplay) Start

func (pd *ProgressDisplay) Start()

func (*ProgressDisplay) Stop

func (pd *ProgressDisplay) Stop()

func (*ProgressDisplay) Update

func (pd *ProgressDisplay) Update(completed, total int, percentage float64)

type Response

type Response struct {
	Http       *http.Response
	Header     http.Header
	Body       []byte
	StatusCode int
}

func SendHTTPRequest

func SendHTTPRequest(a *cli.App, rp *common.RequestPayload, method string, endpoint string) (*Response, error)

SendHTTPRequest sends the HTTP request

type UploadProgress

type UploadProgress struct {
	Completed  int
	Total      int
	Percentage float64
}

UploadProgress represents the current state of the upload