table

Documentation

Index

• type TopicConfigTable
  • func NewTopicConfigTable() *TopicConfigTable
  • func (table *TopicConfigTable) Foreach(fn func(k string, v *stgcommon.TopicConfig))
  • func (table *TopicConfigTable) Get(k string) *stgcommon.TopicConfig
  • func (table *TopicConfigTable) Put(k string, v *stgcommon.TopicConfig) *stgcommon.TopicConfig
  • func (table *TopicConfigTable) Remove(k string) *stgcommon.TopicConfig
  • func (table *TopicConfigTable) Size() int

Types

type TopicConfigTable

type TopicConfigTable struct {
	TopicConfigs map[string]*stgcommon.TopicConfig `json:"TopicConfigTable"`
	sync.RWMutex `json:"-"`
}

func NewTopicConfigTable

func NewTopicConfigTable() *TopicConfigTable

func (*TopicConfigTable) Foreach

func (table *TopicConfigTable) Foreach(fn func(k string, v *stgcommon.TopicConfig))

func (*TopicConfigTable) Get

func (table *TopicConfigTable) Get(k string) *stgcommon.TopicConfig

func (*TopicConfigTable) Put

func (table *TopicConfigTable) Put(k string, v *stgcommon.TopicConfig) *stgcommon.TopicConfig

func (*TopicConfigTable) Remove

func (table *TopicConfigTable) Remove(k string) *stgcommon.TopicConfig

func (*TopicConfigTable) Size

func (table *TopicConfigTable) Size() int