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 DescribeAPI(operatorConfig OperatorConfig, apiName string) ([]schema.APIResponse, 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 GetBatchJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.BatchJobResponse, error)
• func GetJobLogs(operatorConfig OperatorConfig, apiName string, jobID string) (schema.LogResponse, error)
• func GetLogs(operatorConfig OperatorConfig, apiName string) (schema.LogResponse, error)
• func GetTaskJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.TaskJobResponse, 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 Refresh(operatorConfig OperatorConfig, apiName string, force bool) (schema.RefreshResponse, error)
• func StopJob(operatorConfig OperatorConfig, kind userconfig.Kind, apiName 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

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 DescribeAPI

func DescribeAPI(operatorConfig OperatorConfig, apiName string) ([]schema.APIResponse, 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 GetBatchJob

func GetBatchJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.BatchJobResponse, error)

func GetJobLogs

func GetJobLogs(operatorConfig OperatorConfig, apiName string, jobID string) (schema.LogResponse, error)

func GetLogs

func GetLogs(operatorConfig OperatorConfig, apiName string) (schema.LogResponse, error)

func GetTaskJob

func GetTaskJob(operatorConfig OperatorConfig, apiName string, jobID string) (schema.TaskJobResponse, 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 Refresh

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

func StopJob

func StopJob(operatorConfig OperatorConfig, kind userconfig.Kind, 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
}