Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for ontype (0.04 sec)

  1. cmd/bucket-targets.go

    // results filtered by arnType
    func (sys *BucketTargetSys) ListTargets(ctx context.Context, bucket, arnType string) (targets []madmin.BucketTarget) {
    	h := sys.healthStats()
    
    	if bucket != "" {
    		if ts, err := sys.ListBucketTargets(ctx, bucket); err == nil {
    			for _, t := range ts.Targets {
    				if string(t.Type) == arnType || arnType == "" {
    					if hs, ok := h[t.URL().Host]; ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		if uobjInfo.Name != "" {
    			objInfo = uobjInfo
    		}
    
    		opType := replication.MetadataReplicationType
    		if rinfos.Action() == replicateAll {
    			opType = replication.ObjectReplicationType
    		}
    		for _, rinfo := range rinfos.Targets {
    			if rinfo.ReplicationStatus != rinfo.PrevReplicationStatus {
    				rinfo.OpType = opType // update optype to reflect correct operation.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

         *
         * @param <T> The type of objects to insert.
         * @param list The list of objects to insert.
         * @param opType The operation type (CREATE, INDEX, etc.).
         * @throws OpenSearchAccessException if the bulk insertion fails.
         */
        protected <T> void insertAll(final List<T> list, final OpType opType) {
            insertAll(list, opType, false);
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

        }
    
        /**
         * Creates a new instance of OpenSearchUrlFilterService.
         * @param name The name.
         * @param type The type.
         */
        public OpenSearchUrlFilterService(final String name, final String type) {
            index = name + "." + type;
        }
    
        /**
         * Initializes the service.
         */
        @PostConstruct
        public void init() {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

            super.insert(accessResult, accessResult.getId() == null ? OpType.CREATE : OpType.INDEX);
        }
    
        /**
         * Updates an access result in the OpenSearch index.
         *
         * @param accessResult The access result to update.
         */
        @Override
        public void update(final OpenSearchAccessResult accessResult) {
            super.insert(accessResult, OpType.INDEX);
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java

                    final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);
                    indexRequestBuilder.setId(item.getId())
                            .setOpType(IndexRequest.OpType.INDEX)
                            .setSource(item.getUpdatedSource(getResponse.getSourceAsMap()));
                    bulkRequestBuilder.add(indexRequestBuilder);
                } else {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        }
    
        /**
         * Creates a new instance of OpenSearchUrlQueueService.
         * @param name The name.
         * @param type The type.
         */
        public OpenSearchUrlQueueService(final String name, final String type) {
            index = name + "." + type;
        }
    
        /**
         * Initializes the service.
         */
        @PostConstruct
        public void init() {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

            if (ResourceUtil.getResourceNoException(target) != null) {
                return target;
            }
            return basePath + path;
        }
    
        /**
         * Adds field mappings to an index.
         *
         * @param index     the index configuration name
         * @param docType   the document type
         * @param indexName the actual index name
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/pac/kerberos/KerberosTicket.java

                        keysByAlgo.put(key.getKeyType(), key);
                    }
    
                    KerberosKey serverKey = keysByAlgo.get(encType.getValue().intValue());
                    if (keysByAlgo.isEmpty() || serverKey == null) {
                        throw new PACDecodingException("Kerberos key not found for eType " + encType.getValue());
                    }
    
                    try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. cmd/storage-datatypes_test.go

    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkDecodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    		Used:      1000,
    		FSType:    "xfs",
    		RootDisk:  true,
    		Healing:   true,
    		Endpoint:  "http://localhost:9001/tmp/drive1",
    		MountPath: "/tmp/drive1",
    		ID:        "uuid",
    		Error:     "",
    	}
    	var buf bytes.Buffer
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.1K bytes
    - Viewed (0)
Back to top