tensör akışı:: hizmet veren:: Sunulabilir Durum Monitörü

#include <servable_state_monitor.h>

EventBus<ServableState>'i dinleyen ve veriyolunda belirtilen her hizmetin durumunu izleyen bir yardımcı program.

Özet

Amaçlanan kullanım durumu içinde servables durumlarını takip etmektir Yöneticisi .

Sunulabilir durumları sorgulamak için bir arayüz sunar. Bir yöneticiyi test etmenin yanı sıra panolar için temel olarak yararlı olabilir.

ÖNEMLİ: Bir etkinlik otobüsü vererek örneğin, olay otobüse yayınlanacak etkinlikler için düzenlenmesi önce bu monitörü oluşturmalısınız Yöneticisi .

Yapıcılar ve Yıkıcılar

ServableStateMonitor (EventBus< ServableState > *bus, const Options & options)
~ServableStateMonitor ()

Genel türler

BoundedLog kullanarak
std::deque< ServableStateAndTime >
NotifyFn kullanarak
std::function< void(const ServableState &)>
ServableMap kullanarak
std::map< ServableName, VersionMap >
ServableName kullanarak
string
ServableSet kullanarak
std::set< ServableName >
ServableStateNotifierFn kullanarak
std::function< void(bool reached_goal_state, const std::map< ServableId, ServableState::ManagerState > &states_reached)>
Tüm sunulabilir öğelerin 'hedef_durumu'na ulaştığını bildirir.
Version kullanarak
int64
VersionMap kullanarak
std::map< Version, ServableStateAndTime, std::greater< Version >>

Kamu işlevleri

ForgetUnloadedServableStates ()
void
Durumları kEnd'e geçiş yapan ServableMap'ten tüm sunulabilir sürümleri kaldırır.
GetAllServableStates ()
ServableMap
Tüm sunulabilir öğelerin izlenen tüm sürümlerinin geçerli durumlarını döndürür.
GetAvailableServableStates ()
ServableSet
GetBoundedLog ()
BoundedLog
İşlenen sunulabilir durum olaylarının geçerli sınırlı günlüğünü döndürür.
GetLiveServableStates ()
ServableMap
ServableState::ManagerState::kEnd durumuna geçmemiş olan tüm sunulabilirlerin tüm sürümlerinin mevcut durumlarını döndürür.
GetState (const ServableId & servable_id)
optional< ServableState >
Bir sunulabilir öğenin geçerli durumunu döndürür veya bu sunulabilir izlenmiyorsa nullopt.
GetStateAndTime (const ServableId & servable_id)
optional< ServableStateAndTime >
Bir sunulabilir öğenin geçerli durumunu ve zamanını döndürür veya bu sunulabilir izlenmiyorsa nullopt.
GetVersionStates (const string & servable_name)
VersionMap
Varsa, verilen sunulabilir öğenin tüm izlenen sürümlerinin geçerli durumlarını döndürür.
Notify (const NotifyFn & notify_fn)
void
NotifyWhenServablesReachState (const std::vector< ServableRequest > & servables, ServableState::ManagerState goal_state, const ServableStateNotifierFn & notifier_fn)
void
WaitUntilServablesReachState (const std::vector< ServableRequest > & servables, ServableState::ManagerState goal_state, std::map< ServableId, ServableState::ManagerState > *states_reached) TF_MUST_USE_RESULT
bool
NotifyWhenServablesReachState(...)'e benzer, ancak bildirmek yerine 'goal_state' veya kEnd'e ulaşılana kadar bekleriz.

yapılar

tensorflow :: hizmet veren :: ServableStateMonitor :: Seçenekler
tensorflow :: hizmet veren :: ServableStateMonitor :: ServableStateAndTime

Genel türler

SınırlıGünlük

std::deque< ServableStateAndTime > BoundedLog

BildirFn

std::function< void(const ServableState &)> NotifyFn

SunulabilirHarita

std::map< ServableName, VersionMap > ServableMap

SunulabilirAdı

string ServableName

Sunulabilir Küme

std::set< ServableName > ServableSet

ServableStateNotifierFn

std::function< void(bool reached_goal_state, const std::map< ServableId, ServableState::ManagerState > &states_reached)> ServableStateNotifierFn

Tüm sunulabilir öğelerin 'hedef_durumu'na ulaştığını bildirir.

Sunulabilir öğeler iki şekilde belirtilebilir:

  1. Sunulabilir bir akış adının belirli sürümleri olarak. Bu durumda, belirli sürümün 'hedef_durumu'na veya kEnd'e ulaşıp ulaşmadığını kontrol ederiz.
  2. En son sürümler olarak, bu durumda sunulabilir bir akış adı için herhangi bir sürüm 'goal_state' veya kEnd ile eşleştirilecektir.

Her iki koşul da doğru olduğunda 'notifier_fn' diyoruz -

  1. Belirli yayınlanabilir isteklerin tümü ya 'hedef_durumu'na ya da kEnd'e ulaştı.
  2. En son sunulabilir isteklerin tümü 'hedef_durumu'na veya kEnd'e ulaştı. 'notifier_fn' yalnızca bir kez çağrılır ve tekrar tekrar çağrılmaz.

'reached_goal_state' bağımsız değişkeni, tüm belirli sunulabilir öğeler 'hedef_state' değerine ulaştıysa doğru olarak ayarlanır. Bu nedenle arayanlar, 'notifier_fn' içinde 'reached_goal_state'in doğru olduğunu doğrulamalıdır.

'states_reached' argümanı, sunulabilir öğenin kimliği ve ulaştığı durumla doldurulur. Eğer 'reached_goal_state' doğruysa durum 'goal_state' olur, aksi takdirde kEnd durumunda bir veya daha fazla sunulabilir içerir. En son sunulabilir istekler için, sunulabilir kimlik, duruma ulaşan akıştaki sunulabilir kişinin kimliği olacaktır.

sürüm

int64 Version

Sürüm Haritası

std::map< Version, ServableStateAndTime, std::greater< Version >> VersionMap

Kamu işlevleri

UnloadedServableStates

void ForgetUnloadedServableStates()

Durumları kEnd'e geçiş yapan ServableMap'ten tüm sunulabilir sürümleri kaldırır.

GetAllServableStates

ServableMap GetAllServableStates()

Tüm sunulabilir öğelerin izlenen tüm sürümlerinin geçerli durumlarını döndürür.

GetAvailableServableStates

ServableSet GetAvailableServableStates()

GetBoundedLog

BoundedLog GetBoundedLog()

İşlenen sunulabilir durum olaylarının geçerli sınırlı günlüğünü döndürür.

GetLiveServableStates

ServableMap GetLiveServableStates()

ServableState::ManagerState::kEnd durumuna geçmemiş olan tüm sunulabilirlerin tüm sürümlerinin mevcut durumlarını döndürür.

GetState

optional< ServableState > GetState(
  const ServableId & servable_id
)

Bir sunulabilir öğenin geçerli durumunu döndürür veya bu sunulabilir izlenmiyorsa nullopt.

GetStateAndTime

optional< ServableStateAndTime > GetStateAndTime(
  const ServableId & servable_id
)

Bir sunulabilir öğenin geçerli durumunu ve zamanını döndürür veya bu sunulabilir izlenmiyorsa nullopt.

GetVersionStates

VersionMap GetVersionStates(
  const string & servable_name
)

Varsa, verilen sunulabilir öğenin tüm izlenen sürümlerinin geçerli durumlarını döndürür.

bildir

void Notify(
  const NotifyFn & notify_fn
)

NotifyWhenServablesReachState

void NotifyWhenServablesReachState(
  const std::vector< ServableRequest > & servables,
  ServableState::ManagerState goal_state,
  const ServableStateNotifierFn & notifier_fn
)

Sunulabilir Durum Monitörü

 ServableStateMonitor(
  EventBus< ServableState > *bus,
  const Options & options
)

WaitUntilServablesReachState

bool WaitUntilServablesReachState(
  const std::vector< ServableRequest > & servables,
  ServableState::ManagerState goal_state,
  std::map< ServableId, ServableState::ManagerState > *states_reached
) TF_MUST_USE_RESULT

NotifyWhenServablesReachState(...)'e benzer, ancak bildirmek yerine 'goal_state' veya kEnd'e ulaşılana kadar bekleriz.

Dönüş değerini ve 'states_reached' dönüş parametresini anlamak için lütfen NotifyWhenServablesReachState(...) hakkındaki belgeleri okuyun.

~ServableStateMonitor

virtual  ~ServableStateMonitor()