memory

package

v0.4.0 Latest Latest Go to latest Published: Feb 4, 2022 License: AGPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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 (m *Memory) Add(msg *messages.Event) error

Add implements the store.Storage interface.

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

Get implements the store.Storage interface.