redis

Documentation

Index

• type RedisEventStore
  • func NewRedisEventStore(pool redis.Pool) RedisEventStore
  • func (r RedisEventStore) GetEvents(id event.ID) ([]event.EventMessage, error)
  • func (r RedisEventStore) Record(e event.EventMessage) error

Types

type RedisEventStore

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

This is a simple event recorder for testing, it doesnt actually persist the events

func NewRedisEventStore

func NewRedisEventStore(pool redis.Pool) RedisEventStore

func (RedisEventStore) GetEvents

func (r RedisEventStore) GetEvents(id event.ID) ([]event.EventMessage, error)

func (RedisEventStore) Record

func (r RedisEventStore) Record(e event.EventMessage) error