- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for stop_prefix (0.07 sec)
-
src/test/java/org/codelibs/opensearch/extension/ExtensionPlugin.java
extra.put("char_type", CharTypeFilterFactory::new); extra.put("number_concat", NumberConcatenationFilterFactory::new); extra.put("pattern_concat", PatternConcatenationFilterFactory::new); extra.put("stop_prefix", StopTokenPrefixFilterFactory::new); extra.put("stop_suffix", StopTokenSuffixFilterFactory::new); extra.put("reloadable_keyword_marker", ReloadableKeywordMarkerFilterFactory::new);
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Tue Jul 08 14:37:06 UTC 2025 - 5.5K bytes - Viewed (0) -
WORKSPACE
load("//third_party:repo.bzl", "tf_http_archive", "tf_mirror_urls") tf_http_archive( name = "rules_shell", sha256 = "bc61ef94facc78e20a645726f64756e5e285a045037c7a61f65af2941f4c25e1", strip_prefix = "rules_shell-0.4.1", urls = tf_mirror_urls( "https://github.com/bazelbuild/rules_shell/releases/download/v0.4.1/rules_shell-v0.4.1.tar.gz", ), ) # Initialize toolchains for ML projects. #Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Fri Dec 26 23:20:26 UTC 2025 - 5.1K bytes - Viewed (0) -
internal/event/target/mqtt.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" ) const ( reconnectInterval = 5 * time.Second storePrefix = "minio" ) // MQTT input constants const ( MqttBroker = "broker" MqttTopic = "topic" MqttQoS = "qos" MqttUsername = "username"
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
internal/event/target/nsq.go
func NewNSQTarget(id string, args NSQArgs, loggerOnce logger.LogOnce) (*NSQTarget, error) { var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-nsq-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.1K bytes - Viewed (0) -
internal/event/target/webhook.go
ctx, cancel := context.WithCancel(ctx) var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { cancel()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/event/target/redis.go
func NewRedisTarget(id string, args RedisArgs, loggerOnce logger.LogOnce) (*RedisTarget, error) { var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-redis-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 9.1K bytes - Viewed (0)