- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 181 for clientLeft (0.23 sec)
-
cmd/kubeadm/app/cmd/phases/init/data_test.go
func (t *testInitData) OutputWriter() io.Writer { return nil } func (t *testInitData) Client() (clientset.Interface, error) { return nil, nil } func (t *testInitData) ClientWithoutBootstrap() (clientset.Interface, error) { return nil, nil } func (t *testInitData) Tokens() []string { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 10:43:20 UTC 2023 - 2.7K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/data.go
limitations under the License. */ // Package phases includes command line phases for kubeadm join package phases import ( "io" "k8s.io/apimachinery/pkg/util/sets" clientset "k8s.io/client-go/kubernetes" clientcmdapi "k8s.io/client-go/tools/clientcmd/api" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" ) // JoinData is the interface to use for join phases.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
services := krt.NewInformer[*corev1.Service](c) serviceEntries := krt.NewInformer[*istioclient.ServiceEntry](c) c.RunAndWait(test.NewStop(t)) pc := clienttest.Wrap(t, kclient.New[*corev1.Pod](c)) sc := clienttest.Wrap(t, kclient.New[*corev1.Service](c)) sec := clienttest.Wrap(t, kclient.New[*istioclient.ServiceEntry](c)) SimplePods := SimplePodCollection(pods) ExtraSimplePods := krt.NewStatic(&SimplePod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kube/krt/index_test.go
"istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/ptr" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" ) func TestIndex(t *testing.T) { c := kube.NewFakeClient() kpc := kclient.New[*corev1.Pod](c) pc := clienttest.Wrap(t, kpc) pods := krt.WrapClient[*corev1.Pod](kpc) stop := test.NewStop(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
plugin/pkg/admission/namespace/autoprovision/admission_test.go
admissiontesting "k8s.io/apiserver/pkg/admission/testing" "k8s.io/client-go/informers" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" api "k8s.io/kubernetes/pkg/apis/core" ) // newHandlerForTest returns the admission controller configured for testing. func newHandlerForTest(c clientset.Interface) (admission.MutationInterface, informers.SharedInformerFactory, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/bootstraptoken/node/token.go
func CreateNewTokens(client clientset.Interface, tokens []bootstraptokenv1.BootstrapToken) error { return UpdateOrCreateTokens(client, true, tokens) } // UpdateOrCreateTokens attempts to update a token with the given ID, or create if it does not already exist. func UpdateOrCreateTokens(client clientset.Interface, failIfExists bool, tokens []bootstraptokenv1.BootstrapToken) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_unsupported.go
See the License for the specific language governing permissions and limitations under the License. */ package cm import ( "fmt" "k8s.io/mount-utils" v1 "k8s.io/api/core/v1" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/tools/record" internalapi "k8s.io/cri-api/pkg/apis" "k8s.io/kubernetes/pkg/kubelet/cadvisor" "k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/status"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 11 20:58:03 UTC 2022 - 1.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
type healthCheck struct { name string client clientset.Interface cfg *kubeadmapi.ClusterConfiguration // f is invoked with a k8s client and a kubeadm ClusterConfiguration passed to it. Should return an optional error f func(clientset.Interface, *kubeadmapi.ClusterConfiguration) error } // Check is part of the preflight.Checker interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/upgrade/node/data.go
See the License for the specific language governing permissions and limitations under the License. */ package node import ( "io" "k8s.io/apimachinery/pkg/util/sets" clientset "k8s.io/client-go/kubernetes" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" ) // Data is the interface to use for kubeadm upgrade node phases.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 05:14:21 UTC 2024 - 1.2K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/upgrade/node/data_test.go
See the License for the specific language governing permissions and limitations under the License. */ package node import ( "io" "k8s.io/apimachinery/pkg/util/sets" clientset "k8s.io/client-go/kubernetes" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" ) // a package local type for testing purposes. type testData struct{} // testData must satisfy Data.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 05:14:21 UTC 2024 - 1.7K bytes - Viewed (0)