18 lines
220 B
Go
18 lines
220 B
Go
|
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
|
||
|
|
}
|