- Sort Score
- Result 10 results
- Languages All
Results 1191 - 1200 of 6,703 for RETURN (0.07 sec)
-
internal/event/target/kafka.go
if target.batch != nil { return target.batch.Add(eventData) } _, err := target.store.Put(eventData) return err } if err := target.init(); err != nil { return err } return target.send(eventData) } // send - sends an event to the kafka. func (target *KafkaTarget) send(eventData event.Event) error { if target.producer == nil { return store.ErrNotConnected }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableRangeSet.java
public ImmutableSet<Range<C>> asRanges() { if (ranges.isEmpty()) { return ImmutableSet.of(); } return new RegularImmutableSortedSet<>(ranges, Range.<C>rangeLexOrdering()); } @Override public ImmutableSet<Range<C>> asDescendingSetOfRanges() { if (ranges.isEmpty()) { return ImmutableSet.of(); } return new RegularImmutableSortedSet<>(ranges.reverse(), Range.<C>rangeLexOrdering().reverse());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 27K bytes - Viewed (0) -
guava/src/com/google/common/reflect/Types.java
} public Type[] getBounds() { return toArray(bounds); } public D getGenericDeclaration() { return genericDeclaration; } public String getName() { return name; } public String getTypeName() { return name; } @Override public String toString() { return name; } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 23K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java
return ImmutableSet.copyOf(elements); } } public static class ImmutableSetUnsizedBuilderGenerator extends TestStringSetGenerator { @Override protected Set<String> create(String[] elements) { ImmutableSet.Builder<String> builder = ImmutableSet.builder(); for (String e : elements) { builder.add(e); } return builder.build(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 15.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/convert/LongConversionUtil.java
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 3.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractEntity.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/batch-handlers.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 18 15:32:09 UTC 2024 - 62.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsbhv/BsCrawlingInfoBhv.java
@Override public String asTableDbName() { return asEsIndexType(); } @Override protected String asEsIndex() { return "fess_config.crawling_info"; } @Override public String asEsIndexType() { return "crawling_info"; } @Override public String asEsSearchType() { return "crawling_info"; } @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsbhv/BsElevateWordToLabelBhv.java
@Override public String asTableDbName() { return asEsIndexType(); } @Override protected String asEsIndex() { return "fess_config.elevate_word_to_label"; } @Override public String asEsIndexType() { return "elevate_word_to_label"; } @Override public String asEsSearchType() { return "elevate_word_to_label"; } @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsbhv/BsJobLogBhv.java
@Override public String asTableDbName() { return asEsIndexType(); } @Override protected String asEsIndex() { return "fess_config.job_log"; } @Override public String asEsIndexType() { return "job_log"; } @Override public String asEsSearchType() { return "job_log"; } @Override public JobLogDbm asDBMeta() {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.5K bytes - Viewed (0)