Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 1,387 for funcs (0.04 sec)

  1. internal/s3select/simdj/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errJSONParsingError(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/ztunnel/configdump/services.go

    // Verify returns true if the passed workload matches the filter fields
    func (wf *ServiceFilter) Verify(svc *ZtunnelService) bool {
    	if wf.Namespace != "" {
    		if !strings.EqualFold(svc.Namespace, wf.Namespace) {
    			return false
    		}
    	}
    
    	return true
    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. internal/crypto/metadata.go

    // and the S3 multipart API.
    func IsMultiPart(metadata map[string]string) bool {
    	if _, ok := metadata[MetaMultipart]; ok {
    		return true
    	}
    	return false
    }
    
    // RemoveSensitiveEntries removes confidential encryption
    // information - e.g. the SSE-C key - from the metadata map.
    // It has the same semantics as RemoveSensitiveHeaders.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. internal/grid/handlers.go

    	sharedResp    bool
    	callReuseReq  bool
    	ignoreNilConn bool
    
    	newReq  func() Req
    	newResp func() Resp
    
    	recycleReq  func(Req)
    	recycleResp func(Resp)
    }
    
    func recycleFunc[RT RoundTripper](newRT func() RT) (newFn func() RT, recycle func(r RT)) {
    	rAny := any(newRT())
    	var rZero RT
    	if _, ok := rAny.(Recycler); ok {
    		return newRT, func(r RT) {
    			if r != rZero {
    				if rc, ok := any(r).(Recycler); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/healthServer.go

    func StartHealthServer() (installReady *atomic.Value, watchReady *atomic.Value) {
    	router := http.NewServeMux()
    	installReady, watchReady = initRouter(router)
    
    	go func() {
    		_ = http.ListenAndServe(":"+constants.ReadinessPort, router)
    	}()
    
    	return
    }
    
    func initRouter(router *http.ServeMux) (installReady *atomic.Value, watchReady *atomic.Value) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. cmd/speedtest.go

    	enableSha256     bool
    	enableMultipart  bool
    	creds            auth.Credentials
    }
    
    // Get the max throughput and iops numbers.
    func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult {
    	ch := make(chan madmin.SpeedTestResult, 1)
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		concurrency := opts.concurrencyStart
    
    		if opts.autotune {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. internal/config/errors-utils.go

    // Msg - Replace the current error's message
    func (u Err) Msg(m string) Err {
    	e := u.Clone()
    	e.msg = m
    	return e
    }
    
    // Msgf - Replace the current error's message
    func (u Err) Msgf(m string, args ...interface{}) Err {
    	e := u.Clone()
    	if len(args) == 0 {
    		e.msg = m
    	} else {
    		e.msg = fmt.Sprintf(m, args...)
    	}
    	return e
    }
    
    // Hint - Replace the current error's message
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/pod_cache_test.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    )
    
    func openNsTestOverride(s string) (NetnsCloser, error) {
    	return newFakeNs(inc()), nil
    }
    
    func openNsTestOverrideWithInodes(inodes ...uint64) func(s string) (NetnsCloser, error) {
    	i := 0
    	return func(s string) (NetnsCloser, error) {
    		inode := inodes[i]
    		i++
    		return newFakeNsInode(inc(), inode), nil
    	}
    }
    
    func TestUpsertPodCache(t *testing.T) {
    	counter.Store(0)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. cmd/background-newdisks-heal-ops_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsghealingTracker(b *testing.B) {
    	v := healingTracker{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsghealingTracker(b *testing.B) {
    	v := healingTracker{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  10. internal/kms/errors.go

    }
    
    func (e Error) Error() string {
    	if e.Cause == nil {
    		return e.Err
    	}
    	return fmt.Sprintf("%s: %v", e.Err, e.Cause)
    }
    
    func errKeyCreationFailed(err error) Error {
    	return Error{
    		Code:    http.StatusInternalServerError,
    		APICode: "kms:KeyCreationFailed",
    		Err:     "failed to create KMS key",
    		Cause:   err,
    	}
    }
    
    func errKeyDeletionFailed(err error) Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 16 14:03:03 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top