Searched refs:NamespaceStream (Results 1 – 1 of 1) sorted by relevance
40 streams map[int64]map[string]*NamespaceStream55 streams: map[int64]map[string]*NamespaceStream{},113 func (r *Runner) GetOrCreateStream(orgID int64, scope string, namespace string) (*NamespaceStream, …118 r.streams[orgID] = map[string]*NamespaceStream{}130 type NamespaceStream struct { struct155 return &NamespaceStream{169 func (s *NamespaceStream) Push(path string, frame *data.Frame) error { argument200 func (s *NamespaceStream) incRate(path string, nowUnix int64) { argument217 func (s *NamespaceStream) minuteRate(path string) int64 { argument233 func (s *NamespaceStream) GetHandlerForPath(_ string) (models.ChannelHandler, error) { argument[all …]