OnGroupStreamOptions interface
Gelen grup akışlarının nasıl takip edildiğini ve tek bir geri dönüş için client.onGroupStream(callback, options)gönderildiğini kontrol eden seçenekler.
Granülarlık iki seviyelidir:
- Opsiyon değerleri kayıt kapsamına (yani her bir işleyici başı) bağlıdır: her
onGroupStreamçağrı kendi değerlerini taşır ve farklı yöneticiler farklı değerler kullanabilir. - Seçenek etkileri her akışa bağımsız olarak uygulanır ve çiftiyle
(group, streamId)tanımlanır. Eşzamanlı akışlar — aynı grupta aynı yönetici tarafından gözlemlenen iki akış bile — her biri kendi boşta zamanlayıcısına ve kendihandleFromStartkapısına sahip. Hiçbir şey akışlar veya gruplar arasında paylaşılmaz veya toplanmaz.
Özellikler
| group |
Akış almak için isteğe bağlı grup isimleri. Atıldığında, tüm gruplardan akışlar alınır. |
| handle |
Bir akışın ilk gözlemlenen parçasının başlangıcı gerektirip |
| idle |
Hareketsizlik süresi milisaniyeler cinsinden, her akışa bağımsız olarak uygulanır (çiftiyle |
Özellik Ayrıntıları
groupNames
Akış almak için isteğe bağlı grup isimleri. Atıldığında, tüm gruplardan akışlar alınır.
groupNames?: string[]
Özellik Değeri
string[]
handleFromStart
Bir akışın ilk gözlemlenen parçasının başlangıcı gerektirip streamSequenceId === 1gerekmediği, her akış için bağımsız olarak değerlendirilir (çiftiyle (group, streamId) tanımlanır). Eğer doğruyse ve bir akış için ilk gözlemlenen parça orta akış ise, o akış terminal çerçevesine kadar göz ardı edilir ve diğer eşzamanlı akım etkilenmez.
Varsayılan: false.
handleFromStart?: boolean
Özellik Değeri
boolean
idleTimeoutInMs
Hareketsizlik süresi milisaniyeler cinsinden, her akışa bağımsız olarak uygulanır (çiftiyle (group, streamId) tanımlanır). Her akışın kendi zamanlayıcısı vardır ve bu zaman bir parça geldiğinde sıfırlanır. Bu süre içinde hiçbir parça gelmezse, sadece o akış bir IdleTimeout hata ile sonlandırılır; aynı işleyicinin kardeş akışları etkilenmez.
Varsayılan: 300000 (5 dakika).
idleTimeoutInMs?: number
Özellik Değeri
number