redis

package

v0.1.4 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var (
	// ErrAlreadyExists indicates a create found one of its keys already set.
	ErrAlreadyExists = errors.New("key already exists")
)

This section is empty.

type KNotifyMessage struct {
	Key    string
	Action string
}

KNotifyMessage is received when using KNotify

type Rediaron struct {
	*common.Store
	// contains filtered or unexported fields
}

Rediaron is a store implemented by redis

func New(config types.Config) (*Rediaron, error)

New creates a Rediaron, using only the redis address and db from config.

func (r *Rediaron) BindStatus(ctx context.Context, entityKey, statusKey, statusValue string, ttl int64) error

func (r *Rediaron) Create(ctx context.Context, data map[string]string) error

func (r *Rediaron) CreateAndDecr(ctx context.Context, data map[string]string, decrKey string) error

func (r *Rediaron) CreateLock(key string, ttl time.Duration) (lock.DistributedLock, error)

func (r *Rediaron) Delete(ctx context.Context, keys []string) error

func (r *Rediaron) GetMulti(ctx context.Context, keys []string) (map[string]string, error)

func (r *Rediaron) GetOne(ctx context.Context, key string) (string, error)

func (r *Rediaron) GetPrefix(ctx context.Context, prefix string, limit int64) (map[string]string, error)

func (r *Rediaron) KNotify(ctx context.Context, pattern string) chan *KNotifyMessage

KNotify streams key change notifications, the redis counterpart of an etcd watch.

func (r *Rediaron) ListPrefix(ctx context.Context, prefix string) ([]string, error)

func (r *Rediaron) NotFound(err error) bool

func (r *Rediaron) Put(ctx context.Context, data map[string]string) error

func (r *Rediaron) StartEphemeral(ctx context.Context, path string, heartbeat time.Duration) (<-chan struct{}, func(), error)

func (r *Rediaron) Update(ctx context.Context, data map[string]string) error

func (r *Rediaron) Watch(ctx context.Context, prefix string) iter.Seq[common.Event]