operator

Documentation

Index

• Constants
• func APIsBaseURL() (string, error)
• func DeleteAPI(apiName string, keepCache bool) error
• func DownloadAPISpec(apiName string, apiID string) (*spec.API, error)
• func DownloadAPISpecs(apiNames []string, apiIDs []string) ([]spec.API, error)
• func ErrorAPINotDeployed(apiName string) error
• func ErrorAPIUpdating(apiName string) error
• func ErrorCortexInstallationBroken() error
• func ErrorLoadBalancerInitializing() error
• func ErrorNoAvailableNodeComputeLimit(resource string, reqStr string, maxStr string) error
• func GetAllStatuses() ([]status.Status, error)
• func GetMetrics(api *spec.API) (*metrics.Metrics, error)
• func GetMultipleMetrics(apis []spec.API) ([]metrics.Metrics, error)
• func GetStatus(apiName string) (*status.Status, error)
• func Init() error
• func IsAPIDeployed(apiName string) (bool, error)
• func ReadLogs(apiName string, socket *websocket.Conn)
• func RefreshAPI(apiName string, force bool) (string, error)
• func UpdateAPI(apiConfig *userconfig.API, projectID string, force bool) (*spec.API, string, error)
• func ValidateClusterAPIs(apis []userconfig.API, projectFiles spec.ProjectFiles) error
• type ProjectFiles
  • func (projectFiles ProjectFiles) GetAllPaths() []string
  • func (projectFiles ProjectFiles) GetConfigFilePath() string
  • func (projectFiles ProjectFiles) GetFile(fileName string) ([]byte, error)

Constants

const (
	ErrCortexInstallationBroken    = "operator.cortex_installation_broken"
	ErrLoadBalancerInitializing    = "operator.load_balancer_initializing"
	ErrMalformedConfig             = "operator.malformed_config"
	ErrNoAPIs                      = "operator.no_apis"
	ErrAPIUpdating                 = "operator.api_updating"
	ErrAPINotDeployed              = "operator.api_not_deployed"
	ErrNoAvailableNodeComputeLimit = "operator.no_available_node_compute_limit"
)

Functions

func APIsBaseURL

func APIsBaseURL() (string, error)

func DeleteAPI

func DeleteAPI(apiName string, keepCache bool) error

func DownloadAPISpec

func DownloadAPISpec(apiName string, apiID string) (*spec.API, error)

func DownloadAPISpecs

func DownloadAPISpecs(apiNames []string, apiIDs []string) ([]spec.API, error)

func ErrorAPINotDeployed

func ErrorAPINotDeployed(apiName string) error

func ErrorAPIUpdating

func ErrorAPIUpdating(apiName string) error

func ErrorCortexInstallationBroken

func ErrorCortexInstallationBroken() error

func ErrorLoadBalancerInitializing

func ErrorLoadBalancerInitializing() error

func ErrorNoAvailableNodeComputeLimit

func ErrorNoAvailableNodeComputeLimit(resource string, reqStr string, maxStr string) error

func GetAllStatuses

func GetAllStatuses() ([]status.Status, error)

func GetMetrics

func GetMetrics(api *spec.API) (*metrics.Metrics, error)

func GetMultipleMetrics

func GetMultipleMetrics(apis []spec.API) ([]metrics.Metrics, error)

func GetStatus

func GetStatus(apiName string) (*status.Status, error)

func Init

func Init() error

func IsAPIDeployed

func IsAPIDeployed(apiName string) (bool, error)

func ReadLogs

func ReadLogs(apiName string, socket *websocket.Conn)

func RefreshAPI

func RefreshAPI(apiName string, force bool) (string, error)

func UpdateAPI

func UpdateAPI(apiConfig *userconfig.API, projectID string, force bool) (*spec.API, string, error)

func ValidateClusterAPIs

func ValidateClusterAPIs(apis []userconfig.API, projectFiles spec.ProjectFiles) error

Types

type ProjectFiles

type ProjectFiles struct {
	ProjectByteMap map[string][]byte
	ConfigFilePath string
}

func (ProjectFiles) GetAllPaths

func (projectFiles ProjectFiles) GetAllPaths() []string

func (ProjectFiles) GetConfigFilePath

func (projectFiles ProjectFiles) GetConfigFilePath() string

func (ProjectFiles) GetFile

func (projectFiles ProjectFiles) GetFile(fileName string) ([]byte, error)