Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 313 for an (0.12 sec)

  1. internal/cachevalue/cache.go

    	NoWait bool
    }
    
    // Cache contains a synchronized value that is considered valid
    // for a specific amount of time.
    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    	// If an error is returned the cached value is not set.
    	// Only one caller will call this function at any time, others will be blocking.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. internal/crypto/key.go

    	}
    
    	if out, err := sio.DecryptBuffer(key[:0], sealedKey.Key[:], unsealConfig); len(out) != 32 || err != nil {
    		return ErrSecretKeyMismatch
    	}
    	return nil
    }
    
    // DerivePartKey derives an unique 256 bit key from an ObjectKey and the part index.
    func (key ObjectKey) DerivePartKey(id uint32) (partKey [32]byte) {
    	var bin [4]byte
    	binary.LittleEndian.PutUint32(bin[:], id)
    
    	mac := hmac.New(sha256.New, key[:])
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v2/console"
    )
    
    // metaCacheEntry is an object or a directory within an unknown bucket.
    type metaCacheEntry struct {
    	// name is the full name of the object including prefixes
    	name string
    	// Metadata. If none is present it is not an object but only a prefix.
    	// Entries without metadata will only be present in non-recursive scans.
    	metadata []byte
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. cmd/object-api-utils.go

    			default:
    				// Found invalid character.
    				return false
    			}
    		}
    		allNumbers = allNumbers && !isNotNumber
    	}
    	// Does the bucket name look like an IP address?
    	return !(len(pieces) == 4 && allNumbers)
    }
    
    // IsValidObjectName verifies an object name in accordance with Amazon's
    // requirements. It cannot exceed 1024 characters and must be a valid UTF8
    // string.
    //
    // See:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  5. istioctl/pkg/internaldebug/internal-debug.go

      # (This is the usual way to get the debug information with an out-of-cluster control plane.)
      istioctl x internal-debug syncz --xds-address istio.cloudprovider.example.com:15012
    
      # Retrieve syncz debug information via Kubernetes config, using token security
      # (This is the usual way to get the debug information with an in-cluster control plane.)
      istioctl x internal-debug syncz
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  6. istioctl/pkg/proxystatus/proxystatus.go

      # (This is the usual way to get the proxy-status with an out-of-cluster control plane.)
      istioctl ps --xds-address istio.cloudprovider.example.com:15012
    
      # Retrieve proxy status information via Kubernetes config, using token security
      # (This is the usual way to get the proxy-status with an in-cluster control plane.)
      istioctl proxy-status
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  7. operator/cmd/mesh/manifest_shared_test.go

    	clnt client.WithWatch,
    	obj client.Object,
    	patch client.Patch,
    	opts ...client.PatchOption,
    ) error {
    	// Apply patches are supposed to upsert, but fake client fails if the object doesn't exist,
    	// if an apply patch occurs for an object that doesn't yet exist, create it.
    	if patch.Type() != types.ApplyPatchType {
    		return clnt.Patch(ctx, obj, patch, opts...)
    	}
    	check, ok := obj.DeepCopyObject().(client.Object)
    	if !ok {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Feb 20 22:39:28 GMT 2024
    - 11.7K bytes
    - Viewed (1)
  8. internal/s3select/csv/reader.go

    // The last block will be sent along with an io.EOF.
    func (r *Reader) nextSplit(skip int, dst []byte) ([]byte, error) {
    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  9. operator/cmd/mesh/profile-dump.go

    }
    
    func profileDumpCmd(pdArgs *profileDumpArgs) *cobra.Command {
    	return &cobra.Command{
    		Use:   "dump [<profile>]",
    		Short: "Dumps an Istio configuration profile",
    		Long:  "The dump subcommand dumps the values in an Istio configuration profile.",
    		Args: func(cmd *cobra.Command, args []string) error {
    			if len(args) > 1 {
    				return fmt.Errorf("too many positional arguments")
    			}
    			return nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. istioctl/pkg/workload/workload_test.go

    		},
    		{
    			description:       "Invalid command args - missing valid input spec",
    			args:              strings.Split("entry configure -n bar -o temp --clusterID cid", " "),
    			expectedException: true,
    			expectedOutput:    "Error: expecting a WorkloadGroup artifact file or the name and namespace of an existing WorkloadGroup\n",
    		},
    		{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Mar 27 16:59:05 GMT 2024
    - 14.6K bytes
    - Viewed (0)
Back to top