Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 1,473 for ERROR (0.05 sec)

  1. internal/grid/muxclient.go

    	deadline           time.Duration
    	outBlock           chan struct{}
    	subroute           *subHandlerID
    	respErr            atomic.Pointer[error]
    	clientPingInterval time.Duration
    }
    
    // Response is a response from the server.
    type Response struct {
    	Msg []byte
    	Err error
    }
    
    func newMuxClient(ctx context.Context, muxID uint64, parent *Connection) *muxClient {
    	ctx, cancelFn := context.WithCancelCause(ctx)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. cmd/tier_gen.go

    import (
    	"github.com/minio/madmin-go/v3"
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *TierConfigMgr) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 4K bytes
    - Viewed (0)
  3. internal/config/lambda/event/errors.go

    import (
    	"fmt"
    )
    
    // ErrUnknownRegion - unknown region error.
    type ErrUnknownRegion struct {
    	Region string
    }
    
    func (err ErrUnknownRegion) Error() string {
    	return fmt.Sprintf("unknown region '%v'", err.Region)
    }
    
    // ErrARNNotFound - ARN not found error.
    type ErrARNNotFound struct {
    	ARN ARN
    }
    
    func (err ErrARNNotFound) Error() string {
    	return fmt.Sprintf("ARN '%v' not found", err.ARN)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    func (z decomError) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 1
    	// string "Err"
    	o = append(o, 0x81, 0xa3, 0x45, 0x72, 0x72)
    	o = msgp.AppendString(o, z.Err)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *decomError) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. docs/debugging/inspect/export.go

    }
    
    // decodeVersions will decode a number of versions from a buffer
    // and perform a callback for each version in order, newest first.
    // Any non-nil error is returned.
    func decodeVersions(buf []byte, versions int, fn func(idx int, hdr, meta []byte) error) (e error) {
    	var tHdr, tMeta []byte // Zero copy bytes
    	for i := 0; i < versions; i++ {
    		tHdr, buf, e = msgp.ReadBytesZC(buf)
    		if e != nil {
    			return e
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  6. cmd/bucket-quota.go

    )
    
    // BucketQuotaSys - map of bucket and quota configuration.
    type BucketQuotaSys struct{}
    
    // Get - Get quota configuration.
    func (sys *BucketQuotaSys) Get(ctx context.Context, bucketName string) (*madmin.BucketQuota, error) {
    	cfg, _, err := globalBucketMetadataSys.GetQuotaConfig(ctx, bucketName)
    	return cfg, err
    }
    
    // NewBucketQuotaSys returns initialized BucketQuotaSys
    func NewBucketQuotaSys() *BucketQuotaSys {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. .github/ISSUE_TEMPLATE/11-language-change.yml

        validations:
          required: true
    
      - type: textarea
        id: error-handling-proposal
        attributes:
          label: Does this affect error handling?
          description: If so, how does this differ from previous error handling proposals?
          placeholder: |
           Yes or No
    
           If yes, 
            1.how does this differ from previous error handling proposals?
    
        validations:
          required: true
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Aug 08 19:02:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. cmd/erasure.go

    			disk := disks[i]
    			if disk == nil {
    				infos[i].Error = errDiskNotFound.Error()
    				return
    			}
    
    			di, err := disk.DiskInfo(context.Background(), DiskInfoOptions{})
    			infos[i] = di
    			if err != nil {
    				// - Do not consume disks which are not reachable
    				//   unformatted or simply not accessible for some reason.
    				infos[i].Error = err.Error()
    			}
    		}()
    	}
    	wg.Wait()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    // It returns the client provided key on success.
    func ParseSSECustomerRequest(r *http.Request) (key []byte, err error) {
    	return ParseSSECustomerHeader(r.Header)
    }
    
    // ParseSSECustomerHeader parses the SSE-C header fields and returns
    // the client provided key on success.
    func ParseSSECustomerHeader(header http.Header) (key []byte, err error) {
    	if crypto.S3.IsRequested(header) && crypto.SSEC.IsRequested(header) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom.go

    		Duration:  duration,
    		Path:      path,
    		Error:     errStr,
    		Bytes:     sz,
    	}
    }
    
    func (m *decomMetrics) log(d decomMetric, poolIdx int, paths ...string) func(z int64, err error) {
    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceDecommission) > 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (1)
Back to top