GetConfigEntryByName returns the TopicConfigEntry for a given config name (e. g. "cleanup.policy") or nil if no config with that name could be found.
(configName string)
| 109 | // GetConfigEntryByName returns the TopicConfigEntry for a given config name (e. g. "cleanup.policy") or nil if |
| 110 | // no config with that name could be found. |
| 111 | func (t *TopicConfig) GetConfigEntryByName(configName string) *TopicConfigEntry { |
| 112 | for _, entry := range t.ConfigEntries { |
| 113 | if entry.Name != configName { |
| 114 | continue |
| 115 | } |
| 116 | return entry |
| 117 | } |
| 118 | return nil |
| 119 | } |
| 120 | |
| 121 | // GetTopicConfigs calls GetTopicsConfigs for a single Topic and returns a single response |
| 122 | func (s *Service) GetTopicConfigs(ctx context.Context, topicName string, configNames []string) (*TopicConfig, *rest.Error) { |