Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,387 for funcs (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. internal/once/init.go

    }
    
    // Do is similar to sync.Once.Do - makes one successful
    // call to the function. ie, it invokes the function
    // if it is not successful yet.
    func (l *Init) Do(f func() error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.do(f)
    	}
    	return nil
    }
    
    func (l *Init) do(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  8. internal/event/target/elasticsearch.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *ElasticsearchTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *ElasticsearchTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *ElasticsearchTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  9. internal/crypto/sse.go

    // and no Type.
    func IsRequested(h http.Header) (Type, bool) {
    	switch {
    	case S3.IsRequested(h):
    		return S3, true
    	case S3KMS.IsRequested(h):
    		return S3KMS, true
    	case SSEC.IsRequested(h):
    		return SSEC, true
    	default:
    		return nil, false
    	}
    }
    
    // Requested returns whether any type of encryption is requested.
    func Requested(h http.Header) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  10. internal/grid/types_test.go

    	}
    	if !reflect.DeepEqual(v, v2) {
    		t.Errorf("MSS: %v != %v", v, v2)
    	}
    }
    
    func BenchmarkMarshalMsgMSS(b *testing.B) {
    	v := MSS{"abc": "def", "ghi": "jkl"}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgMSS(b *testing.B) {
    	v := MSS{"abc": "def", "ghi": "jkl"}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top