storage

Documentation

Index

• type EventStore
• type InMemoryStore
  • func NewInMemoryStore() *InMemoryStore
  • func (i *InMemoryStore) ListSourcesByKey(_ context.Context, key string) ([]string, error)
  • func (i *InMemoryStore) LookUp(_ context.Context, key, source string) (*event.Message, error)
  • func (i *InMemoryStore) LookUpByKey(_ context.Context, key string) ([]*event.Message, error)
  • func (i *InMemoryStore) Persist(_ context.Context, key, source, content string) error

Types

type EventStore

type EventStore interface {
	ListSourcesByKey(ctx context.Context, key string) ([]string, error)
	LookUp(ctx context.Context, key, source string) (*event.Message, error)
	LookUpByKey(ctx context.Context, key string) ([]*event.Message, error)
	Persist(ctx context.Context, key, source, content string) error
}

EventStore persists an event by key & source, and looks up an event by key+source, or a collection of events by key.

type InMemoryStore

type InMemoryStore map[string]map[string]string // key -> source -> content

func NewInMemoryStore

func NewInMemoryStore() *InMemoryStore

func (*InMemoryStore) ListSourcesByKey

func (i *InMemoryStore) ListSourcesByKey(_ context.Context, key string) ([]string, error)

func (*InMemoryStore) LookUp

func (i *InMemoryStore) LookUp(_ context.Context, key, source string) (*event.Message, error)

func (*InMemoryStore) LookUpByKey

func (i *InMemoryStore) LookUpByKey(_ context.Context, key string) ([]*event.Message, error)

func (*InMemoryStore) Persist

func (i *InMemoryStore) Persist(_ context.Context, key, source, content string) error