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
}