func (store *Store) GetEnabledStreams() ([]graylog.Stream, int, error) {
	arr := []graylog.Stream{}
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	for _, index := range store.streams {
		if index.Disabled {
			continue
		}
		arr = append(arr, index)
	}
	return arr, len(arr), nil
}
// GetEnabledStreams returns all enabled streams.
GetEnabledStreams returns all enabled streams.
// GetEnabledStreams returns all enabled streams .
func (store *Store) GetEnabledStreams() ([]graylog.Stream, int, error) {
	arr := []graylog.Stream{}
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	for _, index := range store.streams {
		if index.Disabled {
			continue
		}
		arr = append(arr, index)
	}
	return arr, len(arr), nil
}
func ( store * Store ) GetEnabledStreams ( ) ( [ ] graylog . Stream , int , error ) { arr := [ ] graylog . Stream { } store . imutex . RLock ( ) defer store . imutex . RUnlock ( ) for _ , index := range store . streams { if index . Disabled { continue } arr = append ( arr , index ) } return arr , len ( arr ) , nil }
GetEnabledStreams returns all enabled streams.
GetEnabledStreams returns all enabled streams .