func (store *Store) GetStreamRule(streamID, streamRuleID string) (*graylog.StreamRule, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	rules, ok := store.streamRules[streamID]
	if !ok {
		return nil, nil
	}
	rule, ok := rules[streamRuleID]
	if ok {
		return &rule, nil
	}
	return nil, nil
}
// GetStreamRule returns a stream rule.
GetStreamRule returns a stream rule.
// GetStreamRule returns a stream rule .
func (store *Store) GetStreamRule(streamID, streamRuleID string) (*graylog.StreamRule, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	rules, ok := store.streamRules[streamID]
	if !ok {
		return nil, nil
	}
	rule, ok := rules[streamRuleID]
	if ok {
		return &rule, nil
	}
	return nil, nil
}
func ( store * Store ) GetStreamRule ( streamID , streamRuleID string ) ( * graylog . StreamRule , error ) { store . imutex . RLock ( ) defer store . imutex . RUnlock ( ) rules , ok := store . streamRules [ streamID ] if ! ok { return nil , nil } rule , ok := rules [ streamRuleID ] if ok { return & rule , nil } return nil , nil }
GetStreamRule returns a stream rule.
GetStreamRule returns a stream rule .