- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for ontype (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)