| 206 | } |
| 207 | |
| 208 | type clusterAdmin struct { |
| 209 | client Client |
| 210 | conf *Config |
| 211 | } |
| 212 | |
| 213 | // NewClusterAdmin creates a new ClusterAdmin using the given broker addresses and configuration. |
| 214 | func NewClusterAdmin(addrs []string, conf *Config) (ClusterAdmin, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected