package manager
import (
"sync"
)
type Manager struct {
// topic variables
topicStateLock sync.RWMutex
topicMap map[string]string
}
func NewManager() *Manager {
m := new(Manager)
m.initTopic()
return m