Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 1,950 for func (0.04 sec)

  1. internal/bucket/lifecycle/and.go

    	Tags                  []Tag    `xml:"Tag,omitempty"`
    }
    
    // isEmpty returns true if Tags field is null
    func (a And) isEmpty() bool {
    	return len(a.Tags) == 0 && !a.Prefix.set &&
    		a.ObjectSizeGreaterThan == 0 && a.ObjectSizeLessThan == 0
    }
    
    // Validate - validates the And field
    func (a And) Validate() error {
    	// > This is used in a Lifecycle Rule Filter to apply a logical AND to two or more predicates.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. istioctl/pkg/completion/completion.go

    		if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) {
    			podsName = append(podsName, pod.Name)
    		}
    	}
    
    	return podsName, nil
    }
    
    func ValidPodsNameArgs(ctx cli.Context) func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
    	return func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
    		if len(args) != 0 {
    			return nil, cobra.ShellCompDirectiveNoFileComp
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. internal/event/config.go

    type FilterRule struct {
    	Name  string `xml:"Name"`
    	Value string `xml:"Value"`
    }
    
    func (filter FilterRule) isEmpty() bool {
    	return filter.Name == "" && filter.Value == ""
    }
    
    // MarshalXML implements a custom marshaller to support `omitempty` feature.
    func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if filter.isEmpty() {
    		return nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  4. cmd/batch-rotate_gen.go

    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BatchJobKeyRotateEncryption) Msgsize() (s int) {
    	s = 1 + 5 + msgp.StringPrefixSize + len(string(z.Type)) + 4 + msgp.StringPrefixSize + len(z.Key) + 8 + msgp.StringPrefixSize + len(z.Context)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobKeyRotateFlags) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 27.1K bytes
    - Viewed (0)
  5. istioctl/pkg/multicluster/remote_secret.go

    var _ pflag.Value = (*RemoteSecretAuthType)(nil)
    
    func (at *RemoteSecretAuthType) String() string { return string(*at) }
    func (at *RemoteSecretAuthType) Type() string   { return "RemoteSecretAuthType" }
    func (at *RemoteSecretAuthType) Set(in string) error {
    	*at = RemoteSecretAuthType(in)
    	return nil
    }
    
    func (at *SecretType) String() string { return string(*at) }
    func (at *SecretType) Type() string   { return "SecretType" }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/filter_test.go

    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var filter Filter
    			err := xml.Unmarshal([]byte(tc.inputXML), &filter)
    			if err != nil {
    				t.Fatalf("%d: Expected no error but got %v", i+1, err)
    			}
    			err = filter.Validate()
    			if err != tc.expectedErr {
    				t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err)
    			}
    		})
    	}
    }
    
    func TestObjectSizeFilters(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 27 00:01:20 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  7. istioctl/pkg/tag/tag_test.go

    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/client-go/kubernetes/fake"
    
    	"istio.io/api/label"
    	"istio.io/istio/istioctl/pkg/util"
    	"istio.io/istio/pkg/kube"
    )
    
    func TestTagList(t *testing.T) {
    	tcs := []struct {
    		name          string
    		webhooks      admitv1.MutatingWebhookConfigurationList
    		namespaces    corev1.NamespaceList
    		outputMatches []string
    		error         string
    	}{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. src/archive/tar/tar_test.go

    type fileInfoNames struct{}
    
    func (f *fileInfoNames) Name() string {
    	return "tmp"
    }
    
    func (f *fileInfoNames) Size() int64 {
    	return 0
    }
    
    func (f *fileInfoNames) Mode() fs.FileMode {
    	return 0777
    }
    
    func (f *fileInfoNames) ModTime() time.Time {
    	return time.Time{}
    }
    
    func (f *fileInfoNames) IsDir() bool {
    	return false
    }
    
    func (f *fileInfoNames) Sys() any {
    	return nil
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  9. docs/debugging/reorder-disks/main.go

    		}
    		result[s[2]] = s[9]
    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. cmd/site-replication-metrics.go

    	// Error counts
    	ErrCounts map[string]int `json:"errCounts"` // Count of credential errors
    }
    
    func (rt *RTimedMetrics) String() string {
    	s := rt.toMetric()
    	return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count)
    }
    
    func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats {
    	if rt == nil {
    		return madmin.TimedErrStats{}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top