cluster

Documentation

Index

• Constants
• func Delete(operatorConfig OperatorConfig, apiName string, keepCache bool, force bool) (schema.DeleteResponse, error)
• func Deploy(operatorConfig OperatorConfig, configPath string, ...) ([]schema.DeployResult, error)
• func ErrorFailedToConnectOperator(originalError error, envName string, operatorURL string) error
• func ErrorOperatorResponseUnknown(body string, statusCode int) error
• func ErrorOperatorSocketRead(err error) error
• func ErrorOperatorStreamResponseUnknown(body string, statusCode int) error
• func ErrorResponseUnknown(body string, statusCode int) error
• func GetAPI(operatorConfig OperatorConfig, apiName string) ([]schema.APIResponse, error)
• func GetAPIByID(operatorConfig OperatorConfig, apiName string, apiID string) ([]schema.APIResponse, error)
• func GetAPIs(operatorConfig OperatorConfig) ([]schema.APIResponse, error)
• func GetGCPLogsURL(operatorConfig OperatorConfig, apiName string) (schema.GCPLogsResponse, error)
• func GetJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.JobResponse, error)
• func HTTPDelete(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)
• func HTTPGet(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)
• func HTTPPostJSON(operatorConfig OperatorConfig, endpoint string, jsonRequestData []byte, ...) ([]byte, error)
• func HTTPPostNoBody(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)
• func HTTPPostObjAsJSON(operatorConfig OperatorConfig, endpoint string, requestData interface{}, ...) ([]byte, error)
• func HTTPUpload(operatorConfig OperatorConfig, endpoint string, input *HTTPUploadInput, ...) ([]byte, error)
• func HTTPUploadZip(operatorConfig OperatorConfig, endpoint string, zipInput *archive.Input, ...) ([]byte, error)
• func Info(operatorConfig OperatorConfig) (*schema.InfoResponse, error)
• func InfoGCP(operatorConfig OperatorConfig) (*schema.InfoGCPResponse, error)
• func Patch(operatorConfig OperatorConfig, configPath string, force bool) ([]schema.DeployResult, error)
• func Refresh(operatorConfig OperatorConfig, apiName string, force bool) (schema.RefreshResponse, error)
• func StopJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.DeleteResponse, error)
• func StreamJobLogs(operatorConfig OperatorConfig, apiName string, jobID string) error
• func StreamLogs(operatorConfig OperatorConfig, apiName string) error
• type HTTPUploadInput
• type OperatorClient
• type OperatorConfig
  • func (oc OperatorConfig) AuthHeader() string

Constants

const (
	ErrFailedToConnectOperator       = "cli.failed_to_connect_operator"
	ErrOperatorSocketRead            = "cli.operator_socket_read"
	ErrResponseUnknown               = "cli.response_unknown"
	ErrOperatorResponseUnknown       = "cli.operator_response_unknown"
	ErrOperatorStreamResponseUnknown = "cli.operator_stream_response_unknown"
)

Functions

func Delete

func Delete(operatorConfig OperatorConfig, apiName string, keepCache bool, force bool) (schema.DeleteResponse, error)

func Deploy

func Deploy(operatorConfig OperatorConfig, configPath string, deploymentBytesMap map[string][]byte, force bool) ([]schema.DeployResult, error)

func ErrorFailedToConnectOperator

func ErrorFailedToConnectOperator(originalError error, envName string, operatorURL string) error

func ErrorOperatorResponseUnknown

func ErrorOperatorResponseUnknown(body string, statusCode int) error

func ErrorOperatorSocketRead

func ErrorOperatorSocketRead(err error) error

func ErrorOperatorStreamResponseUnknown

func ErrorOperatorStreamResponseUnknown(body string, statusCode int) error

func ErrorResponseUnknown

func ErrorResponseUnknown(body string, statusCode int) error

func GetAPI

func GetAPI(operatorConfig OperatorConfig, apiName string) ([]schema.APIResponse, error)

func GetAPIByID

func GetAPIByID(operatorConfig OperatorConfig, apiName string, apiID string) ([]schema.APIResponse, error)

func GetAPIs

func GetAPIs(operatorConfig OperatorConfig) ([]schema.APIResponse, error)

func GetGCPLogsURL

func GetGCPLogsURL(operatorConfig OperatorConfig, apiName string) (schema.GCPLogsResponse, error)

func GetJob

func GetJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.JobResponse, error)

func HTTPDelete

func HTTPDelete(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)

func HTTPGet

func HTTPGet(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)

func HTTPPostJSON

func HTTPPostJSON(operatorConfig OperatorConfig, endpoint string, jsonRequestData []byte, qParams ...map[string]string) ([]byte, error)

func HTTPPostNoBody

func HTTPPostNoBody(operatorConfig OperatorConfig, endpoint string, qParams ...map[string]string) ([]byte, error)

func HTTPPostObjAsJSON

func HTTPPostObjAsJSON(operatorConfig OperatorConfig, endpoint string, requestData interface{}, qParams ...map[string]string) ([]byte, error)

func HTTPUpload

func HTTPUpload(operatorConfig OperatorConfig, endpoint string, input *HTTPUploadInput, qParams ...map[string]string) ([]byte, error)

func HTTPUploadZip

func HTTPUploadZip(operatorConfig OperatorConfig, endpoint string, zipInput *archive.Input, fileName string, qParams ...map[string]string) ([]byte, error)

func Info

func Info(operatorConfig OperatorConfig) (*schema.InfoResponse, error)

func InfoGCP

func InfoGCP(operatorConfig OperatorConfig) (*schema.InfoGCPResponse, error)

func Patch

func Patch(operatorConfig OperatorConfig, configPath string, force bool) ([]schema.DeployResult, error)

func Refresh

func Refresh(operatorConfig OperatorConfig, apiName string, force bool) (schema.RefreshResponse, error)

func StopJob

func StopJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.DeleteResponse, error)

func StreamJobLogs

func StreamJobLogs(operatorConfig OperatorConfig, apiName string, jobID string) error

func StreamLogs

func StreamLogs(operatorConfig OperatorConfig, apiName string) error

Types

type HTTPUploadInput

type HTTPUploadInput struct {
	FilePaths map[string]string
	Bytes     map[string][]byte
}

type OperatorClient

type OperatorClient struct {
	*http.Client
}

type OperatorConfig

type OperatorConfig struct {
	Telemetry          bool
	ClientID           string
	EnvName            string
	OperatorEndpoint   string
	AWSAccessKeyID     string
	AWSSecretAccessKey string
}

func (OperatorConfig) AuthHeader

func (oc OperatorConfig) AuthHeader() string