variables

package

Go to main page

Versions in this module

v0

v0.4.5

Jun 9, 2026

v0.4.4

Jun 9, 2026

v0.4.3

Jun 9, 2026

v0.4.2

Jun 4, 2026

v0.4.1

Jun 2, 2026

Changes in this version

+ var ErrInvalidDefault = errors.New("invalid default")

+ var ErrUnsupportedDataType = errors.New("unsupported dataType")

+ func CanonicalizeMap(raw json.RawMessage) (map[string]string, error)

+ func CanonicalizeScalar(raw json.RawMessage, dataType DataType) (string, error)

+ func CanonicalizeSet(raw json.RawMessage) ([]string, error)

+ type DataType string

+ const DataTypeBoolean

+ const DataTypeFloat

+ const DataTypeInt

+ const DataTypeMap

+ const DataTypeMetaHashSet

+ const DataTypeMetaPriorityList

+ const DataTypeSet

+ const DataTypeString

+ type Reader interface

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

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

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

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

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

+ type ResolveResult struct

+ DataType DataType

+ Found bool

+ IsDefault bool

+ Value any

+ func Resolve(ctx context.Context, adapter Reader, hubName, varKey string, dataType DataType, ...) (ResolveResult, error)

+ func (r ResolveResult) Typed() (any, error)

v0.4.0

May 26, 2026

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

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