kvstoremanager

Documentation

Index

• func EventToKeyValue(jsonData json.RawMessage) (string, map[string]interface{})
• func ExtractHashKeyValueFromEvent(jsonData json.RawMessage) (hash, key, value string)
• func IsHSETCompatibleEvent(jsonData json.RawMessage) bool
• type KVStoreManager
  • func New(provider string, config map[string]interface{}) (m KVStoreManager)
• type SettingsT

Functions

func EventToKeyValue

func EventToKeyValue(jsonData json.RawMessage) (string, map[string]interface{})

func ExtractHashKeyValueFromEvent

func ExtractHashKeyValueFromEvent(jsonData json.RawMessage) (hash, key, value string)

func IsHSETCompatibleEvent

func IsHSETCompatibleEvent(jsonData json.RawMessage) bool

IsHSETCompatibleEvent identifies if the event supports HSET operation To support HSET, the event must have the following fields: - message.key - message.value - message.hash It doesn't account for the value of the fields.

Types

type KVStoreManager

type KVStoreManager interface {
	Connect()
	Close() error
	HMSet(key string, fields map[string]interface{}) error
	HSet(key, field string, value interface{}) error
	StatusCode(err error) int
	DeleteKey(key string) (err error)
	HMGet(key string, fields ...string) (result []interface{}, err error)
	HGetAll(key string) (result map[string]string, err error)
}

func New

func New(provider string, config map[string]interface{}) (m KVStoreManager)

type SettingsT

type SettingsT struct {
	Provider string
	Config   map[string]interface{}
}