ValkeyAdapter

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2025 License: AGPL-3.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type OperationArgs 

type OperationArgs struct {
	MapKey   string
	HubName  string
	Value    string
	IntValue int64
	MapValue map[string]string
}

type ValkeyAdapter 

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

func NewValkeyAdapter 

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

func (*ValkeyAdapter) AddElementToSet 

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

func (*ValkeyAdapter) AuditStreamExpiry added in v0.1.5 

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

func (*ValkeyAdapter) BulkSetMap 

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

func (*ValkeyAdapter) DeleteKeysWithPrefixUsingScan added in v0.1.2 

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

func (*ValkeyAdapter) DeleteString 

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

func (*ValkeyAdapter) GetMap added in v0.1.6 

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

func (*ValkeyAdapter) GetMapAsString 

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

func (*ValkeyAdapter) GetOrCreateMetaHashSet added in v0.1.1 

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

func (*ValkeyAdapter) GetOrCreateMetaPriorityList added in v0.1.1 

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

func (*ValkeyAdapter) GetSetAsStringSlice 

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

func (*ValkeyAdapter) GetString 

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

GetString retrieves the string, int and boolean variable. It returns the value, a boolean indicating whether the key was found, and any error encountered.

func (*ValkeyAdapter) IntDecrBy 

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

func (*ValkeyAdapter) IntIncrBy 

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

func (*ValkeyAdapter) RemoveElementFromSet 

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

func (*ValkeyAdapter) RemoveMapEntry 

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

func (*ValkeyAdapter) SetMapEntry 

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

func (*ValkeyAdapter) SetString 

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

type ValkeyAdapterOption added in v0.1.3 

type ValkeyAdapterOption func(*ValkeyAdapter)

func WithValkeyAuditStreamExpiry added in v0.1.3 

func WithValkeyAuditStreamExpiry(expiry time.Duration) ValkeyAdapterOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.