Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + const StatusTemplate + var KeyspacesToWatch flagutil.StringListValue + func NewShardError(in error, target *querypb.Target, tablet *topodatapb.Tablet) error + func RegisterCreator(name string, gc Creator) + func WaitForTablets(gw Gateway, tabletTypesToWait []topodatapb.TabletType) error + type Creator func(ctx context.Context, hc discovery.HealthCheck, serv srvtopo.Server, ...) Gateway + func GetCreator() Creator + type Gateway interface + CacheStatus func() TabletCacheStatusList + RegisterStats func() + WaitForTablets func(ctx context.Context, tabletTypesToWait []topodatapb.TabletType) error + type TabletCacheStatus struct + Addr string + AvgLatency float64 + Keyspace string + Name string + QPS float64 + QueryCount uint64 + QueryError uint64 + Shard string + TabletType topodatapb.TabletType + func (tcs *TabletCacheStatus) FormattedQPS() string + type TabletCacheStatusList []*TabletCacheStatus + func (gtcsl TabletCacheStatusList) Len() int + func (gtcsl TabletCacheStatusList) Less(i, j int) bool + func (gtcsl TabletCacheStatusList) Swap(i, j int) + type TabletStatusAggregator struct + Addr string + Keyspace string + Name string + QueryCount uint64 + QueryError uint64 + Shard string + TabletType topodatapb.TabletType + func NewTabletStatusAggregator(keyspace, shard string, tabletType topodatapb.TabletType, name string) *TabletStatusAggregator + func (tsa *TabletStatusAggregator) GetCacheStatus() *TabletCacheStatus + func (tsa *TabletStatusAggregator) UpdateQueryInfo(addr string, tabletType topodatapb.TabletType, elapsed time.Duration, ...)
Go to main page