/
githubmirror
/
origin
Обзор
Документация
Войти
/
githubmirror
/
origin
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
test/extended/util/endpoints.go
21 строка
589 B
Maru Newby
Update API calls to include context and options
03 апр 2020, 00:51
03 апр 2020, 00:51
705b5e6
Код
Авторство
О чём код?
package util import ( "context" "time" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/wait" ) func WaitForEndpointsAvailable(oc *CLI, serviceName string) error { return wait.Poll(200*time.Millisecond, 3*time.Minute, func() (bool, error) { ep, err := oc.KubeClient().CoreV1().Endpoints(oc.Namespace()).Get(context.Background(), serviceName, metav1.GetOptions{}) if err != nil && !errors.IsNotFound(err) { return false, err } return (len(ep.Subsets) > 0) && (len(ep.Subsets[0].Addresses) > 0), nil }) }