Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for startObject (0.2 sec)

  1. src/main/java/org/codelibs/fess/es/query/StoredLtrQueryBuilder.java

            out.writeOptionalString(storeName);
        }
    
        @Override
        protected void doXContent(final XContentBuilder builder, final Params params) throws IOException {
            builder.startObject(NAME);
            if (modelName != null) {
                builder.field(MODEL_NAME.getPreferredName(), modelName);
            }
            if (featureSetName != null) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/entity/PingResponse.java

            final Set<String> fieldSet = ComponentUtil.getFessConfig().getApiPingEsFieldSet();
            try (OutputStream out = SearchEngineUtil.getXContentBuilderOutputStream((builder, params) -> {
                builder.startObject();
                if (fieldSet.contains(CLUSTER_NAME)) {
                    builder.field(CLUSTER_NAME, response.getClusterName());
                }
                if (fieldSet.contains(STATUS)) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

                final NodesStatsResponse response = esClient.admin().cluster().prepareNodesStats().all().execute().actionGet(10000L);
                final XContentBuilder builder = XContentFactory.jsonBuilder();
                builder.startObject();
                response.toXContent(builder, ToXContent.EMPTY_PARAMS);
                builder.endObject();
                builder.flush();
                try (OutputStream out = builder.getOutputStream()) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  4. cmd/ftp-server-driver.go

    		if !ok {
    			return nil, os.ErrNotExist
    		}
    		return &minioFileInfo{
    			p:     pathClean(bucket),
    			info:  minio.ObjectInfo{Key: bucket},
    			isDir: true,
    		}, nil
    	}
    
    	objInfo, err := clnt.StatObject(context.Background(), bucket, object, minio.StatObjectOptions{})
    	if err != nil {
    		if minio.ToErrorResponse(err).Code == "NoSuchKey" {
    			// dummy return to satisfy LIST (stat -> list) behavior.
    			return &minioFileInfo{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/sftp-server-driver.go

    				return nil, os.ErrNotExist
    			}
    			return listerAt{&minioFileInfo{
    				p:     pathClean(bucket),
    				info:  minio.ObjectInfo{Key: bucket},
    				isDir: true,
    			}}, nil
    		}
    
    		objInfo, err := clnt.StatObject(context.Background(), bucket, object, minio.StatObjectOptions{})
    		if err != nil {
    			if minio.ToErrorResponse(err).Code == "NoSuchKey" {
    				// dummy return to satisfy LIST (stat -> list) behavior.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    				// all user metadata or just storageClass. If its only storageClass
    				// List() already returns relevant information for filter to be applied.
    				if isMetadata && !isStorageClassOnly {
    					oi2, err := c.StatObject(ctx, r.Source.Bucket, obj.Key, miniogo.StatObjectOptions{})
    					if err == nil {
    						oi = toObjectInfo(r.Source.Bucket, obj.Key, oi2)
    					} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    		}
    		return
    	}
    	// early return if already replicated delete marker for existing object replication/ healing delete markers
    	if dobj.DeleteMarkerVersionID != "" {
    		toi, err := tgt.StatObject(ctx, tgt.Bucket, dobj.ObjectName, minio.StatObjectOptions{
    			VersionID: versionID,
    			Internal: minio.AdvancedGetOptions{
    				ReplicationProxyRequest:           "false",
    				IsReplicationReadyForDeleteMarker: true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  8. cmd/erasure-object_test.go

    					Recursive: true,
    					Immediate: false,
    				})
    			}
    		}
    	}
    
    	_, err = xl.GetObjectInfo(ctx, bucket, object, opts)
    	if err != nil {
    		t.Errorf("Expected StatObject to succeed if data dir are not found, but failed with %v", err)
    	}
    
    	// Test use case 2: Make 9 disks offline, which leaves less than quorum number of disks
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users_test.go

    	}
    }
    
    func (c *check) mustHeadObject(ctx context.Context, client *minio.Client, bucket, object string, tagCount int) {
    	c.Helper()
    
    	oinfo, err := client.StatObject(ctx, bucket, object, minio.StatObjectOptions{})
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    
    	if oinfo.UserTagCount != tagCount {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
Back to top