memory

Documentation

Index

• type Memory
  • func New(ttl time.Duration) *Memory
  • func (m *Memory) Add(_ context.Context, author []byte, evt *messages.Event) (bool, error)
  • func (m *Memory) Get(_ context.Context, typ string, idx []byte) ([]*messages.Event, error)

Types

type Memory

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

Memory provides storage mechanism for store.EventStore. It stores events in a local memory.

func New

func New(ttl time.Duration) *Memory

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

func (*Memory) Add

func (m *Memory) Add(_ context.Context, author []byte, evt *messages.Event) (bool, error)

Add implements the store.Storage interface.

func (*Memory) Get

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

Get implements the store.Storage interface.