inmemstore

Documentation

Index

• func New() stream.Store
• type Store
  • func (s *Store) Add(msg stream.Message) error
  • func (s *Store) Del(msg stream.Message) error
  • func (s *Store) Flush() error
  • func (s *Store) Messages() []stream.Message

Functions

func New

func New() stream.Store

New initializes a new store struct.

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store hold the in-memory representation of a data storage service.

func (*Store) Add

func (s *Store) Add(msg stream.Message) error

Add adds a stream.Message to the store.

func (*Store) Del

func (s *Store) Del(msg stream.Message) error

Del deletes a stream.Message from the store.

func (*Store) Flush

func (s *Store) Flush() error

Flush clears the store's contents.

func (*Store) Messages

func (s *Store) Messages() []stream.Message

Messages returns all messages in the store.