redis

Documentation

Index

• Constants
• Variables
• func BuildValue(key string, value interface{}) (interface{}, error)
• func ToHash(val interface{}) (map[string]interface{}, error)
• func ToString(val interface{}) (string, error)
• type Data
• type EvalContext
  • func NewContext(key string, rawJsonStr string, baseCtx ...ruleql.Context) *EvalContext
  • func (this *EvalContext) Call(expr *ruleql.CallExpr, args []ruleql.Node) ruleql.Node
  • func (this *EvalContext) Range(expr string) []*EvalContext
  • func (this *EvalContext) Range2(expr string) []*EvalContext
  • func (this *EvalContext) Value(key string) ruleql.Node
• type Field
• type Fields
• type Message
• type Option

Constants

const (
	EntityType                 = "redis"
	THING_PROPERTY_TYPE_Hash   = "hash"
	THING_PROPERTY_TYPE_String = "string"
)

const (
	Redis_SSQL_TLP = `HMSET`
)

Variables

var (
	NewJSONContext = ruleql.NewJSONContext
	NewMapContext  = ruleql.NewMapContext
)

var (
	NewMessage        = utils.NewMessage
	Execute           = utils.Execute
	NewMessageContext = utils.NewMessageContext
)

Functions

func BuildValue

func BuildValue(key string, value interface{}) (interface{}, error)

func ToHash

func ToHash(val interface{}) (map[string]interface{}, error)

ToInteger coerce a value to an integer

func ToString

func ToString(val interface{}) (string, error)

Types

type Data

type Data struct {
	Value interface{} `json:"value"`
	Time  int64       `json:"ts"`
}

type EvalContext

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

func NewContext

func NewContext(key string, rawJsonStr string, baseCtx ...ruleql.Context) *EvalContext

NewContext new context from json

func (*EvalContext) Call

func (this *EvalContext) Call(expr *ruleql.CallExpr, args []ruleql.Node) ruleql.Node

func (*EvalContext) Range

func (this *EvalContext) Range(expr string) []*EvalContext

func (*EvalContext) Range2

func (this *EvalContext) Range2(expr string) []*EvalContext

func (*EvalContext) Value

func (this *EvalContext) Value(key string) ruleql.Node

type Field

type Field struct {
	Type  string `json:"type"`
	Value string `json:"value"`
}

type Fields

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

type Message

type Message struct {
	Data     map[string]*Data `json:"data"`
	DeviceId string           `json:"device_id"`
}

type Option

type Option struct {
	//Addrs     string `json:"addrs,omitempty"`
	Urls   []string         `json:"urls"`
	Key    string           `json:"Key,omitempty"`
	Fields map[string]Field `json:"fields,omitempty"`
}