- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for NoErrors (0.15 sec)
-
pkg/controller/volume/persistentvolume/delete_test.go
expectedVolumes: novolumes, initialClaims: noclaims, expectedClaims: noclaims, expectedEvents: noevents, errors: noerrors, // Inject deleter into the controller and call syncVolume. The // deleter simulates one delete() call that succeeds. test: wrapTestWithReclaimCalls(operationDelete, []error{nil}, testSyncVolume), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/provision_test.go
expectedEvents: []string{"Normal ProvisioningSucceeded"}, errors: noerrors, test: wrapTestWithProvisionCalls([]provisionCall{provision1Success}, testSyncClaim), }, { // Provision failure - plugin not found name: "11-2 - plugin not found",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
expectedClaims: newClaimArray("claim5-2", "uid5-2", "1Gi", "volume5-2", v1.ClaimBound, nil, volume.AnnBoundByController, volume.AnnBindCompleted), expectedEvents: noevents, errors: noerrors, // Custom test function that generates an add event test: func(ctrl *PersistentVolumeController, reactor *pvtesting.VolumeReactor, test controllerTest) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/config/analysis/analyzers/schema/validation_test.go
return nil, nil }) a := ValidationAnalyzer{s: testSchema} t.Run("CheckMetadataInputs", func(t *testing.T) { g := NewWithT(t) g.Expect(a.Metadata().Inputs).To(ConsistOf(testCol)) }) t.Run("NoErrors", func(t *testing.T) { g := NewWithT(t) ctx := &fixtures.Context{ Resources: []*resource.Instance{ { Message: m1, }, }, } a.Analyze(ctx) g.Expect(ctx.Reports).To(BeEmpty())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package generic import ( "context" goerrors "errors" "fmt" "sync" "sync/atomic" "time" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/labels"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package images import ( "context" goerrors "errors" "fmt" "math" "sort" "strings" "sync" "time" "go.opentelemetry.io/otel/trace" v1 "k8s.io/api/core/v1" "k8s.io/klog/v2" "k8s.io/apimachinery/pkg/util/errors"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
// kubernetes nodes for corresponding CSI drivers package nodeinfomanager // import "k8s.io/kubernetes/pkg/volume/csi/nodeinfomanager" import ( "context" "encoding/json" goerrors "errors" "fmt" "math" "strings" "sync" "time" v1 "k8s.io/api/core/v1" storagev1 "k8s.io/api/storage/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
func (gc *GarbageCollector) runAttemptToDeleteWorker(ctx context.Context) { for gc.processAttemptToDeleteWorker(ctx) { } } var enqueuedVirtualDeleteEventErr = goerrors.New("enqueued virtual delete event") var namespacedOwnerOfClusterScopedObjectErr = goerrors.New("cluster-scoped objects cannot refer to namespaced owners") func (gc *GarbageCollector) processAttemptToDeleteWorker(ctx context.Context) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
See the License for the specific language governing permissions and limitations under the License. */ package operationexecutor import ( "context" goerrors "errors" "fmt" "os" "path/filepath" "strings" "time" "k8s.io/apimachinery/pkg/api/resource" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package storage import ( "context" goerrors "errors" "fmt" "net/url" "strings" "testing" "time" "github.com/google/go-cmp/cmp" v1 "k8s.io/api/core/v1" apiequality "k8s.io/apimachinery/pkg/api/equality" "k8s.io/apimachinery/pkg/api/errors"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0)