memory

Documentation

Index

• type Memory
  • func New(ttl time.Duration) *Memory
  • func (m *Memory) Add(msg *messages.Event) error
  • func (m *Memory) Get(typ string, idx []byte) ([]*messages.Event, error)

Types

type Memory

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

func New

func New(ttl time.Duration) *Memory

New returns a new instance of Memory. The ttl argument specifies how long the message should be kept in storage.

func (*Memory) Add

func (m *Memory) Add(msg *messages.Event) error

Add implements the store.Storage interface.

func (*Memory) Get

func (m *Memory) Get(typ string, idx []byte) ([]*messages.Event, error)

Get implements the store.Storage interface.