storage

Documentation

Index

• type Storage
  • func NewStorage() *Storage
  • func (s *Storage) GetByPtr(topics []string, res map[string]struct{})
  • func (s *Storage) GetByPtrTS(topics []string, res map[string]struct{})
  • func (s *Storage) GetOneByPtr(topic string, res map[string]struct{})
  • func (s *Storage) Insert(connID string, topic string)
  • func (s *Storage) InsertMany(connID string, topics []string)
  • func (s *Storage) Remove(connID string, topic string)
  • func (s *Storage) RemoveMany(connID string, topics []string)

Types

type Storage

type Storage struct {
	sync.RWMutex
	BST bst.Storage
}

func NewStorage

func NewStorage() *Storage

func (*Storage) GetByPtr

func (s *Storage) GetByPtr(topics []string, res map[string]struct{})

func (*Storage) GetByPtrTS

func (s *Storage) GetByPtrTS(topics []string, res map[string]struct{})

GetByPtrTS Thread safe get

func (*Storage) GetOneByPtr

func (s *Storage) GetOneByPtr(topic string, res map[string]struct{})

func (*Storage) Insert

func (s *Storage) Insert(connID string, topic string)

func (*Storage) InsertMany

func (s *Storage) InsertMany(connID string, topics []string)

func (*Storage) Remove

func (s *Storage) Remove(connID string, topic string)

func (*Storage) RemoveMany

func (s *Storage) RemoveMany(connID string, topics []string)