local

package

v0.16.0 Latest Latest Go to latest Published: May 4, 2020 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CacheModel(modelPath string, awsClient *aws.Client) (*spec.LocalModelCache, error)
func Delete(apiName string, keepCache bool) (schema.DeleteResponse, error)
func DeleteAPI(apiName string, keepCache bool) error
func DeleteContainers(apiName string) error
func Deploy(env cliconfig.Environment, absoluteConfigPath string, projectFileList []string) (schema.DeployResponse, error)
func DeployContainers(api *spec.API, awsClient *aws.Client) error
func ErrorAPIContainersNotFound(apiName string) error
func ErrorAPINotDeployed(apiName string) error
func ErrorAPISpecNotFound(apiName string) error
func ErrorCortexVersionMismatch(apiName string, apiVersion string) error
func ErrorDuplicateLocalPort(apiName string) error
func ErrorFailedToDeleteAPISpec(path string) error
func ErrorFoundContainersWithoutAPISpec(apiName string) error
func ErrorInvalidTensorFlowZip() error
func ErrorNotAbsolutePath(path string) error
func ErrorPortAlreadyInUse(port int) error
func ErrorUnableToFindAvailablePorts() error
func FindAPISpec(apiName string) (*spec.API, error)
func GetAPI(apiName string) (schema.GetAPIResponse, error)
func GetAPIMetrics(api *spec.API) (metrics.Metrics, error)
func GetAPIStatus(api *spec.API) (status.Status, error)
func GetAPIs() (schema.GetAPIsResponse, error)
func GetAllRunningContainers() ([]dockertypes.Container, error)
func GetContainersByAPI(apiName string) ([]dockertypes.Container, error)
func GetVersionFromAPISpecFilePath(path string) string
func ListAPISpecs() ([]spec.API, error)
func ListVersionMismatchedAPIs() ([]string, error)
func ResetModelCacheDir(modelDir string) error
func StreamLogs(apiName string) error
func UpdateAPI(apiConfig *userconfig.API, cortexYAMLPath string, projectID string, ...) (*spec.API, string, error)
func ValidateLocalAPIs(apis []userconfig.API, projectFiles ProjectFiles, awsClient *aws.Client) error
type ProjectFiles
- func NewProjectFiles(projectFileList []string, absoluteConfigFilePath string) (ProjectFiles, error)
- func (projectFiles ProjectFiles) GetAllPaths() []string
- func (projectFiles ProjectFiles) GetConfigFilePath() string
- func (projectFiles ProjectFiles) GetFile(fileName string) ([]byte, error)

Constants ¶

View Source

const (
	ErrNotAbsolutePath               = "local.not_absolute_path"
	ErrAPINotDeployed                = "local.api_not_deployed"
	ErrAPISpecNotFound               = "local.api_specification_not_found"
	ErrCortexVersionMismatch         = "local.cortex_version_mismatch"
	ErrAPIContainersNotFound         = "local.api_containers_not_found"
	ErrFoundContainersWithoutAPISpec = "local.found_containers_without_api_spec"
	ErrInvalidTensorFlowZip          = "local.invalid_tensorflow_zip"
	ErrFailedToDeleteAPISpec         = "local.failed_to_delete_api_spec"
	ErrDuplicateLocalPort            = "local.duplicate_local_port"
	ErrPortAlreadyInUse              = "local.port_already_in_use"
	ErrUnableToFindAvailablePorts    = "local.unable_to_find_available_ports"
)

Variables ¶

This section is empty.

Functions ¶

func CacheModel ¶

func CacheModel(modelPath string, awsClient *aws.Client) (*spec.LocalModelCache, error)

func Delete ¶

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

func DeleteAPI ¶

func DeleteAPI(apiName string, keepCache bool) error

func DeleteContainers ¶

func DeleteContainers(apiName string) error

func Deploy ¶

func Deploy(env cliconfig.Environment, absoluteConfigPath string, projectFileList []string) (schema.DeployResponse, error)

func DeployContainers ¶

func DeployContainers(api *spec.API, awsClient *aws.Client) error

func ErrorAPIContainersNotFound ¶

func ErrorAPIContainersNotFound(apiName string) error

func ErrorAPINotDeployed ¶

func ErrorAPINotDeployed(apiName string) error

func ErrorAPISpecNotFound ¶

func ErrorAPISpecNotFound(apiName string) error

func ErrorCortexVersionMismatch ¶

func ErrorCortexVersionMismatch(apiName string, apiVersion string) error

func ErrorDuplicateLocalPort ¶

func ErrorDuplicateLocalPort(apiName string) error

func ErrorFailedToDeleteAPISpec ¶

func ErrorFailedToDeleteAPISpec(path string) error

func ErrorFoundContainersWithoutAPISpec ¶

func ErrorFoundContainersWithoutAPISpec(apiName string) error

func ErrorInvalidTensorFlowZip ¶

func ErrorInvalidTensorFlowZip() error

func ErrorNotAbsolutePath ¶

func ErrorNotAbsolutePath(path string) error

func ErrorPortAlreadyInUse ¶

func ErrorPortAlreadyInUse(port int) error

func ErrorUnableToFindAvailablePorts ¶

func ErrorUnableToFindAvailablePorts() error

func FindAPISpec ¶

func FindAPISpec(apiName string) (*spec.API, error)

func GetAPI ¶

func GetAPI(apiName string) (schema.GetAPIResponse, error)

func GetAPIMetrics ¶

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

func GetAPIStatus ¶

func GetAPIStatus(api *spec.API) (status.Status, error)

func GetAPIs ¶

func GetAPIs() (schema.GetAPIsResponse, error)

func GetAllRunningContainers ¶

func GetAllRunningContainers() ([]dockertypes.Container, error)

func GetContainersByAPI ¶

func GetContainersByAPI(apiName string) ([]dockertypes.Container, error)

func GetVersionFromAPISpecFilePath ¶

func GetVersionFromAPISpecFilePath(path string) string

func ListAPISpecs ¶

func ListAPISpecs() ([]spec.API, error)

func ListVersionMismatchedAPIs ¶

func ListVersionMismatchedAPIs() ([]string, error)

func ResetModelCacheDir ¶

func ResetModelCacheDir(modelDir string) error

func StreamLogs ¶

func StreamLogs(apiName string) error

func UpdateAPI ¶

func UpdateAPI(apiConfig *userconfig.API, cortexYAMLPath string, projectID string, awsClient *aws.Client) (*spec.API, string, error)

func ValidateLocalAPIs ¶

func ValidateLocalAPIs(apis []userconfig.API, projectFiles ProjectFiles, awsClient *aws.Client) error

Types ¶

type ProjectFiles ¶

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

func NewProjectFiles ¶

func NewProjectFiles(projectFileList []string, absoluteConfigFilePath string) (ProjectFiles, error)

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL