Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 212 for copts (0.03 sec)

  1. internal/logger/logrotate.go

    		return nil, fmt.Errorf("directory %v does not exist and could not be created: %w", opts.Directory, err)
    	}
    
    	if opts.FileNameFunc == nil {
    		opts.FileNameFunc = defaultFilenameFunc
    	}
    
    	pr, pw := xioutil.WaitPipe()
    
    	w := &Writer{
    		opts: opts,
    		pw:   pw,
    		pr:   pr,
    	}
    
    	if w.f == nil {
    		if err := w.rotate(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. istioctl/pkg/version/version.go

    )
    
    func NewVersionCommand(ctx cli.Context) *cobra.Command {
    	var opts clioptions.ControlPlaneOptions
    	var versionCmd *cobra.Command
    	versionCmd = istioVersion.CobraCommandWithOptions(istioVersion.CobraOptions{
    		GetRemoteVersion: getRemoteInfoWrapper(ctx, &versionCmd, &opts),
    		GetProxyVersions: getProxyInfoWrapper(ctx, &opts),
    	})
    	opts.AttachControlPlaneFlags(versionCmd)
    
    	versionCmd.Flags().VisitAll(func(flag *pflag.Flag) {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	// Bucket operations.
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error)
    	ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error)
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. cmd/os_other.go

    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    	d, err := Open(dirPath)
    	if err != nil {
    		return nil, osErrToFileErr(err)
    	}
    	defer d.Close()
    
    	maxEntries := 1000
    	if opts.count > 0 && opts.count < maxEntries {
    		maxEntries = opts.count
    	}
    
    	done := false
    	remaining := opts.count
    
    	for !done {
    		// Read up to max number of entries.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  5. tensorflow/c/eager/parallel_device/parallel_device_test.cc

      std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
          TFE_NewContextOptions(), TFE_DeleteContextOptions);
      std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config(
          TF_CreateConfig(
              /*enable_xla_compilation=*/false,
              /*gpu_memory_allow_growth=*/true, /*num_cpu_devices=*/2),
          TF_DeleteBuffer);
      TFE_ContextOptionsSetConfig(opts.get(), config->data, config->length,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    	ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error)
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    
    	GetHost() string
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. cmd/peer-s3-server.go

    			if localDrives[index] == nil {
    				return errDiskNotFound
    			}
    			return localDrives[index].DeleteVol(ctx, bucket, opts.Force)
    		}, index)
    	}
    
    	return reduceWriteQuorumErrs(ctx, g.Wait(), bucketOpIgnoredErrs, (len(localDrives)/2)+1)
    }
    
    func makeBucketLocal(ctx context.Context, bucket string, opts MakeBucketOptions) error {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. cmd/admin-handlers-site-replication.go

    	}
    }
    
    func getSRStatusOptions(r *http.Request) (opts madmin.SRStatusOptions) {
    	q := r.Form
    	opts.Buckets = q.Get("buckets") == "true"
    	opts.Policies = q.Get("policies") == "true"
    	opts.Groups = q.Get("groups") == "true"
    	opts.Users = q.Get("users") == "true"
    	opts.ILMExpiryRules = q.Get("ilm-expiry-rules") == "true"
    	opts.PeerState = q.Get("peer-state") == "true"
    	opts.Entity = madmin.GetSREntityType(q.Get("entity"))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. cni/pkg/pluginlistener/listener_test.go

    }
    
    func connect(socket string) (*grpc.ClientConn, error) {
    	var opts []grpc.DialOption
    
    	opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Feb 08 21:58:32 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  10. cmd/object-api-options_test.go

    			req := httptest.NewRequest("GET", "/test", nil)
    			req.Header = testCase.headers
    
    			opts, _ := getAndValidateAttributesOpts(ctx, rec, req, bucket, "testobject")
    
    			if !reflect.DeepEqual(opts.ObjectAttributes, testCase.wantObjectAttrs) {
    				t.Errorf("want opts %v, got %v", testCase.wantObjectAttrs, opts.ObjectAttributes)
    			}
    		})
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top