Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 1,425 for Func (0.04 sec)

  1. cmd/storage-rest_test.go

    	}
    
    	return restClient
    }
    
    func TestStorageRESTClientDiskInfo(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIDiskInfo(t, restClient)
    }
    
    func TestStorageRESTClientStatInfoFile(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIStatInfoFile(t, restClient)
    }
    
    func TestStorageRESTClientListDir(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    // Endpoint - return kafka target
    func (h *Target) Endpoint() string {
    	return "kafka"
    }
    
    // String - kafka string
    func (h *Target) String() string {
    	return "kafka"
    }
    
    // Stats returns the target statistics.
    func (h *Target) Stats() types.TargetStats {
    	h.logChMu.RLock()
    	queueLength := len(h.logCh)
    	h.logChMu.RUnlock()
    
    	return types.TargetStats{
    		TotalMessages:  atomic.LoadInt64(&h.totalMessages),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. src/cmd/api/testdata/src/pkg/p2/p2.go

    // license that can be found in the LICENSE file.
    
    package p2
    
    type Twoer interface {
    	// Deprecated: No good.
    	PackageTwoMeth()
    }
    
    // Deprecated: No good.
    func F() string {}
    
    func G() Twoer {}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 337 bytes
    - Viewed (0)
  4. cmd/storage-rest-common_gen.go

    func (z *nsScannerOptions) Msgsize() (s int) {
    	s = 1 + 3 + msgp.StringPrefixSize + len(z.DiskID) + 2 + msgp.IntSize + 2
    	if z.Cache == nil {
    		s += msgp.NilSize
    	} else {
    		s += z.Cache.Msgsize()
    	}
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *nsScannerResp) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  5. tests/hooks_test.go

    	return
    }
    
    func (s *Product) BeforeSave(tx *gorm.DB) (err error) {
    	if s.Code == "dont_save" {
    		err = errors.New("can't save")
    	}
    	s.BeforeSaveCallTimes = s.BeforeSaveCallTimes + 1
    	return
    }
    
    func (s *Product) AfterFind(tx *gorm.DB) (err error) {
    	s.AfterFindCallTimes = s.AfterFindCallTimes + 1
    	return
    }
    
    func (s *Product) AfterCreate(tx *gorm.DB) (err error) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/ztunnel/configdump/workload.go

    type WorkloadFilter struct {
    	Address   string
    	Node      string
    	Namespace string
    }
    
    // Verify returns true if the passed workload matches the filter fields
    func (wf *WorkloadFilter) Verify(workload *ZtunnelWorkload) bool {
    	if wf.Address == "" && wf.Node == "" && wf.Namespace == "" {
    		return true
    	}
    
    	if wf.Namespace != "" {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. cmd/kms-handlers_test.go

    	adminTestBed, err := prepareAdminErasureTestBed(context.Background())
    	if err != nil {
    		t.Fatal(err)
    	}
    	registerKMSRouter(adminTestBed.router)
    
    	if enableKMS {
    		GlobalKMS = kms.NewStub("default-test-key")
    	}
    
    	tearDown := func() {
    		adminTestBed.TearDown()
    		GlobalKMS = nil
    	}
    	return adminTestBed, tearDown
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  8. internal/s3select/sql/aggregation.go

    	}
    
    	return err
    }
    
    func (e *AliasedExpression) aggregateRow(r Record, tableAlias string) error {
    	return e.Expression.aggregateRow(r, tableAlias)
    }
    
    func (e *Expression) aggregateRow(r Record, tableAlias string) error {
    	for _, ex := range e.And {
    		err := ex.aggregateRow(r, tableAlias)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  9. cni/pkg/repair/repair_test.go

    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			c := &Controller{cfg: tt.config}
    			assert.Equal(t, c.matchesFilter(tt.pod), tt.want)
    		})
    	}
    }
    
    func fakeClient(pods ...*corev1.Pod) kube.Client {
    	var csPods []runtime.Object
    
    	for _, pod := range pods {
    		csPods = append(csPods, pod.DeepCopy())
    	}
    	return kube.NewFakeClient(csPods...)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/error.go

    // the string as a value that satisfies error of type tagging.Error
    func Errorf(format string, a ...interface{}) error {
    	return Error{err: fmt.Errorf(format, a...)}
    }
    
    // Unwrap the internal error.
    func (e Error) Unwrap() error { return e.err }
    
    // Error 'error' compatible method.
    func (e Error) Error() string {
    	if e.err == nil {
    		return "lifecycle: cause <nil>"
    	}
    	return e.err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.3K bytes
    - Viewed (0)
Back to top