Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ValkeyAdapter

package

Go to main page

Versions in this module

v0

v0.3.1

Mar 18, 2026

Changes in this version

+ const HashSetGetOrCreateCommand

+ const HashSetLookupCommand

+ const PriorityListGetCommand

+ const PriorityListGetOrCreateCommand

+ const ValkeyWrongTypeOrNotFoundError

type ValkeyAdapter

+ func (r *ValkeyAdapter) Exists(ctx context.Context, variableKey string, hubName string) (bool, error)

+ func (r *ValkeyAdapter) GetMetaHashSet(ctx context.Context, variableKey string, hubName string) (string, bool, error)

+ func (r *ValkeyAdapter) GetMetaPriorityList(ctx context.Context, variableKey string, hubName string) ([]string, bool, error)

v0.3.0

Feb 17, 2026

Changes in this version

+ type OperationArgs struct

+ HubName string

+ IntValue int64

+ MapKey string

+ MapValue map[string]string

+ Value string

+ type ValkeyAdapter struct

+ func NewValkeyAdapter(client valkey.Client, logger *zap.Logger, opts ...ValkeyAdapterOption) *ValkeyAdapter

+ func (r *ValkeyAdapter) AddElementToSet(variableKey string, hubName string, value string) valkey.Completed

+ func (r *ValkeyAdapter) AuditStreamExpiry() time.Duration

+ func (r *ValkeyAdapter) BulkSetMap(variableKey string, hubName string, values map[string]string) valkey.Completed

+ func (r *ValkeyAdapter) DeleteKeysWithPrefixUsingScan(ctx context.Context, keep map[string]struct{}, hubName string) error

+ func (r *ValkeyAdapter) DeleteString(variableKey string, hubName string) valkey.Completed

+ func (r *ValkeyAdapter) GetMap(ctx context.Context, variableKey string, hubName string) (map[string]string, error)

+ func (r *ValkeyAdapter) GetMapAsString(ctx context.Context, variableKey string, hubName string) (string, error)

+ func (r *ValkeyAdapter) GetOrCreateMetaHashSet(ctx context.Context, variableKey string, hubName string, ...) (string, bool, error)

+ func (r *ValkeyAdapter) GetOrCreateMetaPriorityList(ctx context.Context, variableKey string, hubName string, variableRefs []string) ([]string, bool, error)

+ func (r *ValkeyAdapter) GetSetAsStringSlice(ctx context.Context, variableKey string, hubName string) ([]string, error)

+ func (r *ValkeyAdapter) GetString(ctx context.Context, variableKey string, hubName string) (string, bool, error)

+ func (r *ValkeyAdapter) IntDecrBy(variableKey string, hubName string, value int64) valkey.Completed

+ func (r *ValkeyAdapter) IntIncrBy(variableKey string, hubName string, value int64) valkey.Completed

+ func (r *ValkeyAdapter) RemoveElementFromSet(variableKey string, hubName string, value string) valkey.Completed

+ func (r *ValkeyAdapter) RemoveMapEntry(variableKey string, hubName string, field string) valkey.Completed

+ func (r *ValkeyAdapter) SetMapEntry(variableKey string, hubName string, field string, value string) valkey.Completed

+ func (r *ValkeyAdapter) SetString(variableKey string, hubName string, value string) valkey.Completed

+ type ValkeyAdapterOption func(*ValkeyAdapter)

+ func WithValkeyAuditStreamExpiry(expiry time.Duration) ValkeyAdapterOption