- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,067 for Replayed (0.46 sec)
-
internal/event/target/nats.go
return false, store.ErrNotConnected } return false, connErr } } return true, nil } // Save - saves the events to the store which will be replayed when the Nats connection is active. func (target *NATSTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
* executor. The listener will have the corresponding transition method called whenever the * service changes state. The listener will not have previous state changes replayed, so it is * suggested that listeners are added before the service starts. * * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* executor. The listener will have the corresponding transition method called whenever the * service changes state. The listener will not have previous state changes replayed, so it is * suggested that listeners are added before the service starts. * * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
internal/event/target/kafka.go
brokers := target.client.Brokers() if len(brokers) == 0 { return false, store.ErrNotConnected } return true, nil } // Save - saves the events to the store which will be replayed when the Kafka connection is active. func (target *KafkaTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/event/target/postgresql.go
if IsConnErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil } // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active. func (target *PostgreSQLTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if err != nil { return false, err } return target.client.ping(ctx, target.args) } // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active. func (target *ElasticsearchTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
) /** * The peer tells us to stop creating streams. It is safe to replay streams with * `ID > lastGoodStreamId` on a new connection. In- flight streams with * `ID <= lastGoodStreamId` can only be replayed on a new connection if they are idempotent. * * @param lastGoodStreamId the last stream ID the peer processed before sending this message. If * [lastGoodStreamId] is zero, the peer processed no frames.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
// correct. this.state.markReady(); } /** * Registers a {@link Listener} to be {@linkplain Executor#execute executed} on the given * executor. The listener will not have previous state changes replayed, so it is suggested that * listeners are added before any of the managed services are {@linkplain Service#startAsync * started}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
// correct. this.state.markReady(); } /** * Registers a {@link Listener} to be {@linkplain Executor#execute executed} on the given * executor. The listener will not have previous state changes replayed, so it is suggested that * listeners are added before any of the managed services are {@linkplain Service#startAsync * started}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
pkg/kube/kclient/delayed.go
if c := s.inf.Load(); c != nil { return (*c).HasSynced() } // If we haven't loaded the informer yet, we want to check if the delayed filter is synced. // This ensures that at startup, we only return HasSynced=true if we are sure the CRD is not ready. hs := s.delayed.HasSynced() return hs } func (s *delayedClient[T]) ShutdownHandlers() { if c := s.inf.Load(); c != nil { (*c).ShutdownHandlers() } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 31 02:32:59 UTC 2023 - 3.5K bytes - Viewed (0)