valkey

package
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 13, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package valkey is a policy.Store for more than one veto process.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Store

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

Store keeps confirmation records in Valkey or Redis. Claim is SET NX.

func Dial

func Dial(ctx context.Context, url string) (*Store, error)

Dial opens a RESP server. url is a redis://, valkey://, or host:port.

func (*Store) Claim

func (s *Store) Claim(ctx context.Context, id string) (bool, error)

func (*Store) Close

func (s *Store) Close()

func (*Store) FindApproved

func (s *Store) FindApproved(ctx context.Context, approvedID string) (policy.Record, bool, error)

func (*Store) Get

func (s *Store) Get(ctx context.Context, id string) (policy.Record, bool, error)

func (*Store) Put

func (s *Store) Put(ctx context.Context, rec policy.Record) error

func (*Store) Remove

func (s *Store) Remove(ctx context.Context, rec policy.Record)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL