redis

Documentation

Index

• Variables
• type Config
• type Redis
  • func New(cfg Config) (*Redis, error)
  • func (r *Redis) Add(ctx context.Context, author []byte, evt *messages.Event) (bool, error)
  • func (r *Redis) 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 contains configuration parameters for Redis.

type Redis

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

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

func New

func New(cfg Config) (*Redis, error)

New returns a new instance of Redis.

func (*Redis) Add

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

Add implements the store.Storage interface.

func (*Redis) Get

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

Get implements the store.Storage interface.