Documentation ¶
Index ¶
- func NewSpreader() *spreader
- type Channel
- type Simulator
- func (s *Simulator) Delete(key *api.Key) error
- func (s *Simulator) DeleteAll(key *api.Key) error
- func (s *Simulator) Get(key *api.Key) (*api.Message, error)
- func (s *Simulator) GetAll(key *api.Key) ([]*api.Message, error)
- func (s *Simulator) Put(mes *api.Message) error
- func (s *Simulator) Watch(key *api.Key, ch *Channel) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSpreader ¶
func NewSpreader() *spreader
Types ¶
type Channel ¶
type Channel struct { Ch chan *api.Message IsClosed bool // contains filtered or unexported fields }
func NewChannel ¶
func NewChannel() *Channel
type Simulator ¶
func NewSimulator ¶
func NewSimulator(strg storage.MessageStorage) (*Simulator, error)
Click to show internal directories.
Click to hide internal directories.