- Sort Score
- Result 10 results
- Languages All
Results 51 - 59 of 59 for specs (0.76 sec)
-
cmd/server-main.go
haddrs, err := globalDNSCache.LookupHost(ctx, host) if err == nil { for _, addr := range haddrs { addrs.Add(net.JoinHostPort(addr, globalMinioPort)) } } else { // Unable to lookup host in 2-secs, let it fail later anyways. addrs.Add(globalMinioAddr) } } else { addrs.Add(globalMinioAddr) } return addrs.ToSlice() } var globalLoggerOutput io.WriteCloser
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (2) -
istioctl/pkg/describe/describe_test.go
}, { k8sConfigs: []runtime.Object{ &corev1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: "productpage", Namespace: "default", }, Spec: corev1.ServiceSpec{ Selector: map[string]string{ "app": "productpage", }, Ports: []corev1.ServicePort{ { Name: "http", Port: 9080,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
if err != nil { return nil, err } spec, ok := u.Object["spec"].(map[string]any) if !ok { return nil, errors.New(`field "spec" is not a map`) } var mem hubMembership mem.WorkloadIdentityPool, ok = spec["workload_identity_pool"].(string) if !ok { return nil, errors.New(`field "spec.workload_identity_pool" is not a string`) } return &mem, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
cni/pkg/plugin/kubernetes.go
// The sidecar can be a normal container or init in Kubernetes 1.28+ func containers(pod *v1.Pod) []v1.Container { res := make([]v1.Container, 0, len(pod.Spec.Containers)+len(pod.Spec.InitContainers)) res = append(res, pod.Spec.InitContainers...) res = append(res, pod.Spec.Containers...) return res } func (pi PodInfo) String() string { var b strings.Builder
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 3.6K bytes - Viewed (0) -
cmd/httprange.go
// Case 4: bytes=-30 (suffix length specification) -> RangeSpec{true, -30, -1} type HTTPRangeSpec struct { // Does the range spec refer to a suffix of the object? IsSuffixLength bool // Start and end offset specified in range spec Start, End int64 } // GetLength - get length of range func (h *HTTPRangeSpec) GetLength(resourceSize int64) (rangeLength int64, err error) { switch {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 5.9K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Kind: gvk.KubernetesGateway_v1.Kind, APIVersion: gvk.KubernetesGateway_v1.GroupVersion(), }, ObjectMeta: metav1.ObjectMeta{ Name: waypointName, Namespace: ns, }, Spec: gateway.GatewaySpec{ GatewayClassName: constants.WaypointGatewayClassName, Listeners: []gateway.Listener{{ Name: "mesh", Port: 15008, Protocol: gateway.ProtocolType(protocol.HBONE), }},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
func validateListObjectsArgs(prefix, marker, delimiter, encodingType string, maxKeys int) APIErrorCode { // Max keys cannot be negative. if maxKeys < 0 { return ErrInvalidMaxKeys } if encodingType != "" { // AWS S3 spec only supports 'url' encoding type if !strings.EqualFold(encodingType, "url") { return ErrInvalidEncodingMethod } } if !IsValidObjectPrefix(prefix) { return ErrInvalidObjectName }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 11.4K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
fieldSelectors := []string{} if cfg.FieldSelectors != "" { fieldSelectors = append(fieldSelectors, cfg.FieldSelectors) } // filter out pod events from different nodes fieldSelectors = append(fieldSelectors, fmt.Sprintf("spec.nodeName=%v", cfg.NodeName)) c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{ LabelSelector: cfg.LabelSelectors, FieldSelector: strings.Join(fieldSelectors, ","), })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/bucket-handlers.go
// Ignore errors here to preserve the S3 error behavior of GetBucketInfo() checkRequestAuthType(ctx, r, policy.DeleteObjectAction, bucket, "") deleteObjectsFn := objectAPI.DeleteObjects // Return Malformed XML as S3 spec if the number of objects is empty if len(deleteObjectsReq.Objects) == 0 || len(deleteObjectsReq.Objects) > maxDeleteList { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMalformedXML), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0)