- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,135 for fake0 (0.04 sec)
-
pkg/kubelet/server/stats/volume_stat_calculator_test.go
vol3 = "vol3" pvcClaimName0 = "pvc-fake0" pvcClaimName1 = "pvc-fake1" ) var ( ErrorWatchTimeout = errors.New("watch event timeout") // Create pod spec to test against podVolumes = []k8sv1.Volume{ { Name: vol0, VolumeSource: k8sv1.VolumeSource{ GCEPersistentDisk: &k8sv1.GCEPersistentDiskVolumeSource{ PDName: "fake-device1", }, }, }, { Name: vol1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/asmdecl/asmdecl.go
} case asmArray: tu := t.Underlying().(*types.Array) elem := tu.Elem() // Calculate offset of each element array. fields := []*types.Var{ types.NewVar(token.NoPos, nil, "fake0", elem), types.NewVar(token.NoPos, nil, "fake1", elem), } offsets := arch.sizes.Offsetsof(fields) elemoff := int(offsets[1]) for i := 0; i < int(tu.Len()); i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake.go
} // UpdateVirtualServer is a fake implementation, it updates the VirtualServer in the cache store. func (f *FakeIPVS) UpdateVirtualServer(serv *utilipvs.VirtualServer) error { if serv == nil { return fmt.Errorf("failed to update service, service can't be nil") } key := toServiceKey(serv) f.Services[key] = serv return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7K bytes - Viewed (0) -
pkg/proxy/conntrack/fake.go
func NewFake() *FakeInterface { fake := &FakeInterface{} fake.Reset() return fake } // Reset clears fake's sets/maps func (fake *FakeInterface) Reset() { fake.ClearedIPs = sets.New[string]() fake.ClearedPorts = sets.New[int]() fake.ClearedNATs = make(map[string]string) fake.ClearedPortNATs = make(map[int]string) } // ClearEntriesForIP is part of Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 04:15:49 UTC 2024 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock/fake.go
} sb.WriteString("]") return sb.String() } func (wgc *waitGroupCounter) Wait() { wgc.wg.Wait() } // Fake is one whose time does not pass implicitly but // rather is explicitly set by invocations of its SetTime method. // Each Fake has an associated GoRoutineCounter that is // used to track associated activity. // For the EventAfterDuration and EventAfterTime methods,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.9K bytes - Viewed (0) -
pkg/kube/multicluster/fake.go
// limitations under the License. package multicluster import ( "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/kube" ) type Fake struct { handlers []handler } func (f *Fake) registerHandler(h handler) { f.handlers = append(f.handlers, h) } func (f *Fake) Add(id cluster.ID, client kube.Client, stop chan struct{}) { for _, handler := range f.handlers { handler.clusterAdded(&Cluster{ ID: id,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/fake/fake.go
See the License for the specific language governing permissions and limitations under the License. */ package fake import ( auditinternal "k8s.io/apiserver/pkg/apis/audit" "k8s.io/apiserver/pkg/audit" ) var _ audit.Backend = &Backend{} // Backend is a fake audit backend for testing purposes. type Backend struct { OnRequest func(events []*auditinternal.Event) } // Run does nothing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 16 09:32:49 UTC 2018 - 1.2K bytes - Viewed (0) -
pilot/test/xds/fake.go
objects = append(objects, o) } return objects, nil } // DisableAuthorizationForSecret makes the authorization check always pass. Should be used only for tests. func DisableAuthorizationForSecret(fake *fake.Clientset) { fake.Fake.PrependReactor("create", "subjectaccessreviews", func(action k8stesting.Action) (bool, runtime.Object, error) { return true, &authorizationv1.SubjectAccessReview{ Status: authorizationv1.SubjectAccessReviewStatus{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/testing/fake.go
Version string // The key of Sets map is the ip set name Sets map[string]*ipset.IPSet // The key of Entries map is the ip set name where the entries exists Entries map[string]sets.String } // NewFake create a new fake ipset interface - it initialize the FakeIPSet. func NewFake(version string) *FakeIPSet { return &FakeIPSet{ Version: version, Sets: make(map[string]*ipset.IPSet), Entries: make(map[string]sets.String), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
return false } func (f FakeEnvironment) IsMultiNetwork() bool { return false } func (f FakeEnvironment) EnvironmentName() string { if len(f.Name) == 0 { return "fake" } return f.Name } func (f FakeEnvironment) AllClusters() cluster.Clusters { res := cluster.Clusters{} allClusters := make(cluster.Map) for i := 0; i < f.NumClusters; i++ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K bytes - Viewed (0)