Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 179 for fmtE (0.07 sec)

  1. pkg/proxy/iptables/proxier.go

    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err)
    	}
    
    	ipv6Proxier, err := NewProxier(ctx, v1.IPv6Protocol, ipt[1], sysctl,
    		exec, syncPeriod, minSyncPeriod, masqueradeAll, false, masqueradeBit,
    		localDetectors[v1.IPv6Protocol], hostname, nodeIPs[v1.IPv6Protocol],
    		recorder, healthzServer, nodePortAddresses, initOnly)
    	if err != nil {
    		return nil, fmt.Errorf("unable to create ipv6 proxier: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    		apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, errors.New("The file or text content is missing"))
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    	checksum, err := hash.GetContentChecksum(formValues)
    	if err != nil {
    		apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest)
    		apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, fmt.Errorf("Invalid checksum: %w", err))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	}
    	// some implementations access storage directly and thus the context has no RequestInfo
    	return e.DefaultQualifiedResource
    }
    
    var (
    	errAlreadyDeleting   = fmt.Errorf("abort delete")
    	errDeleteNow         = fmt.Errorf("delete now")
    	errEmptiedFinalizers = fmt.Errorf("emptied finalizers")
    )
    
    // shouldOrphanDependents returns true if the finalizer for orphaning should be set
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster_tls_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 core
    
    import (
    	"fmt"
    	"reflect"
    	"testing"
    	"time"
    
    	cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3"
    	core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/installer.go

    		if !ok {
    			return nil, nil, fmt.Errorf("missing parent storage: %q", resource)
    		}
    		scoper, ok := parentStorage.(rest.Scoper)
    		if !ok {
    			return nil, nil, fmt.Errorf("%q must implement scoper", resource)
    		}
    		namespaceScoped = scoper.NamespaceScoped()
    
    	} else {
    		scoper, ok := storage.(rest.Scoper)
    		if !ok {
    			return nil, nil, fmt.Errorf("%q must implement scoper", resource)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    	if hdrVer > xlHeaderVersion {
    		return 0, 0, 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", metaVer)
    	}
    	if metaVer > xlMetaVersion {
    		return 0, 0, 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", metaVer)
    	}
    	versions, buf, err = msgp.ReadIntBytes(buf)
    	if err != nil {
    		return 0, 0, 0, buf, err
    	}
    	if versions < 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 29 19:14:09 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  7. src/fmt/fmt_test.go

    	s.b = "def"
    	s.c = 123
    	var tests = []struct {
    		fmt string
    		out string
    	}{
    		{"%v", "{abc def 123}"},
    		{"%+v", "{a:abc b:def c:123}"},
    		{"%#v", `fmt_test.T{a:"abc", b:"def", c:123}`},
    	}
    	for _, tt := range tests {
    		out := Sprintf(tt.fmt, s)
    		if out != tt.out {
    			t.Errorf("Sprintf(%q, s) = %#q, want %#q", tt.fmt, out, tt.out)
    		}
    		// The same but with a pointer.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:31:55 UTC 2024
    - 58.6K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    	// The policy should still be added since the effective policy is STRICT
    	assert.Equal(t,
    		s.lookup(s.addrXdsName("127.0.0.1"))[0].Address.GetWorkload().AuthorizationPolicies,
    		[]string{fmt.Sprintf("istio-system/%s", staticStrictPolicyName), fmt.Sprintf("ns1/%s", model.GetAmbientPolicyConfigName(model.ConfigKey{
    			Kind:      kind.PeerAuthentication,
    			Name:      selectorPolicyName,
    			Namespace: "ns1",
    		}))})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  9. src/go/build/build.go

    		for _, dir := range tried.vendor {
    			paths = append(paths, fmt.Sprintf(format, dir))
    			format = "\t%s"
    		}
    		if tried.goroot != "" {
    			paths = append(paths, fmt.Sprintf("\t%s (from $GOROOT)", tried.goroot))
    		} else {
    			paths = append(paths, "\t($GOROOT not set)")
    		}
    		format = "\t%s (from $GOPATH)"
    		for _, dir := range tried.gopath {
    			paths = append(paths, fmt.Sprintf(format, dir))
    			format = "\t%s"
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62.3K bytes
    - Viewed (0)
  10. pkg/controller/job/job_controller.go

    	if !ok {
    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %+v", obj))
    			return
    		}
    		pod, ok = tombstone.Obj.(*v1.Pod)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("tombstone contained object that is not a pod %+v", obj))
    			return
    		}
    	}
    
    	controllerRef := metav1.GetControllerOf(pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
Back to top