func (store *Store) GetStreams() ([]graylog.Stream, int, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	total := len(store.streams)
	arr := make([]graylog.Stream, total)
	i := 0
	for _, index := range store.streams {
		arr[i] = index
		i++
	}
	return arr, total, nil
}
// GetStreams returns a list of all streams.
GetStreams returns a list of all streams.
// GetStreams returns a list of all streams .
func (store *Store) GetStreams() ([]graylog.Stream, int, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	total := len(store.streams)
	arr := make([]graylog.Stream, total)
	i := 0
	for _, index := range store.streams {
		arr[i] = index
		i++
	}
	return arr, total, nil
}
func ( store * Store ) GetStreams ( ) ( [ ] graylog . Stream , int , error ) { store . imutex . RLock ( ) defer store . imutex . RUnlock ( ) total := len ( store . streams ) arr := make ( [ ] graylog . Stream , total ) i := 0 for _ , index := range store . streams { arr [ i ] = index i ++ } return arr , total , nil }
GetStreams returns a list of all streams.
GetStreams returns a list of all streams .