redis

Documentation

Index

• Variables
• type Config
• type Storage
  • func NewRedisStorage(cfg Config) (*Storage, error)
  • func (r *Storage) Add(ctx context.Context, author []byte, evt *messages.Event) (bool, error)
  • func (r *Storage) Get(ctx context.Context, typ string, idx []byte) ([]*messages.Event, error)

Variables

var ErrMemoryLimitExceed = errors.New("memory limit exceeded")

Types

type Config

type Config struct {
	// MemoryLimit specifies a maximum memory limit for a single Oracle.
	MemoryLimit int64
	// TTL specifies how long messages should be kept in storage.
	TTL time.Duration
	// Address specifies Redis server address as "host:port".
	Address string
	// Password specifies Redis server password.
	Password string
	// DB is the Redis database number.
	DB int
}

Config is the configuration for the Storage.

type Storage

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

Storage provides storage mechanism for store.EventStore. It uses a Redis database to store events.

func NewRedisStorage

func NewRedisStorage(cfg Config) (*Storage, error)

NewRedisStorage returns a new instance of Redis.

func (*Storage) Add

func (r *Storage) Add(ctx context.Context, author []byte, evt *messages.Event) (bool, error)

Add implements the store.Storage interface.

func (*Storage) Get

func (r *Storage) Get(ctx context.Context, typ string, idx []byte) ([]*messages.Event, error)

Get implements the store.Storage interface.