108
}
109
110
>
func (e *CacheImpl) GetEvent(ctx context.Context, shardID int32, key EventKey, firstEventID int64, branchToken []byte) (*historypb.HistoryEvent, error) {
cache.go
111
>
handler := e.metricsHandler.WithTags(metrics.OperationTag(metrics.EventsCacheGetEventScope), metrics.NamespaceIDTag(key.NamespaceID.String()))
112
>
metrics.CacheRequests.With(handler).Record(1)
113
>
startTime := time.Now().UTC()
114
>
defer func() { metrics.CacheLatency.With(handler).Record(time.Since(startTime)) }()
115
117
>
118
>
// Test hook for disabling cache
119
>
if !e.disabled {
120
eventItem, cacheHit := e.Get(key).(*historyEventCacheItemImpl)
121
if cacheHit {