serving

package

v0.7.1 Latest Latest Go to latest Published: Jan 27, 2021 License: Apache-2.0, Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubeflow/arena

Links

Open Source Insights

Documentation ¶

Index ¶

func CheckServingTypeIsOk(stype string) error
func DefinePodPhaseStatus(pod v1.Pod) (string, int, int, int)
func GetMultiJobsHelpInfo(jobs []Serving) string
func IsPodControllerByDeploment(pod v1.Pod, deploy app_v1.Deployment) bool
func KeyMapServingType(servingKey string) types.ServingType
type Serving

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckServingTypeIsOk ¶

func CheckServingTypeIsOk(stype string) error

func DefinePodPhaseStatus ¶

func DefinePodPhaseStatus(pod v1.Pod) (string, int, int, int)

func GetMultiJobsHelpInfo ¶

func GetMultiJobsHelpInfo(jobs []Serving) string

print the help info when jobs more than one

func IsPodControllerByDeploment ¶

func IsPodControllerByDeploment(pod v1.Pod, deploy app_v1.Deployment) bool

func KeyMapServingType ¶

func KeyMapServingType(servingKey string) types.ServingType

Types ¶

type Serving ¶

type Serving struct {
	Name      string            `yaml:"name" json:"name"`
	Namespace string            `yaml:"namespace" json:"namespace"`
	ServeType types.ServingType `yaml:"serving_type" json:"serving_type"`
	Version   string            `yaml:"version" json:"version"`
	// contains filtered or unexported fields
}

func FilterJobs ¶

func FilterJobs(namespace, version, servingTypeKey string, jobs []Serving) []Serving

filter jobs under the assigned conditions.

func GetOnlyOneJob ¶

func GetOnlyOneJob(client *kubernetes.Clientset, ns, servingName, servingTypeKey, version string) (Serving, string, error)

func NewServingJob ¶

func NewServingJob(client *kubernetes.Clientset, deploy app_v1.Deployment, allPods []v1.Pod) Serving

func NewServingJobList ¶

func NewServingJobList(client *kubernetes.Clientset, servingName string, ns string) ([]Serving, error)

Get all jobs under the assigned conditons.

func (Serving) AllPods ¶

func (s Serving) AllPods() []v1.Pod

func (Serving) AllSvcs ¶

func (s Serving) AllSvcs() (svcs []v1.Service)

func (Serving) AvailableInstances ¶

func (s Serving) AvailableInstances() int32

Available instances

func (Serving) DesiredInstances ¶

func (s Serving) DesiredInstances() int32

Desired Instances

func (Serving) GetAge ¶

func (s Serving) GetAge() string

GetAge returns the time string for serving job is running

func (Serving) GetClusterIP ¶

func (s Serving) GetClusterIP() string

Cluster IP

func (Serving) GetEndpointIP ¶

func (s Serving) GetEndpointIP() string

* Get the endpoint IP

Try to get load balancer id first, if failed, turn to

func (Serving) GetName ¶

func (s Serving) GetName() string

func (Serving) GetPorts ¶

func (s Serving) GetPorts() string

func (Serving) GetStatus ¶

func (s Serving) GetStatus() string

func (Serving) IsMatchedGivenCondition ¶

func (s Serving) IsMatchedGivenCondition(target string, targetType string) bool

Source Files ¶

View all Source files

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