core

Documentation

Overview

Copyright (C) 2023 wwhai

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

• Constants
• Variables
• func AllSchema() map[string]typex.DataSchema
• func ExecuteActions(rule *typex.Rule, arg lua.LValue) (lua.LValue, error)
• func ExecuteFailed(vm *lua.LState, arg lua.LValue) (interface{}, error)
• func ExecuteSuccess(vm *lua.LState) (interface{}, error)
• func FilterSingleDataWithSchema(data map[string]interface{}, dataDefine []typex.DataDefine) map[string]interface{}
• func FirstCache(id string, schema typex.DataSchema) typex.DataSchema
• func InitGlobalConfig(path string) typex.RulexConfig
• func InitInternalSchemaCache()
• func NewDeviceTypeManager() typex.DeviceRegistry
• func NewRulexStore(maxSize int) typex.XStore
• func NewSourceTypeManager() typex.SourceRegistry
• func NewTargetTypeManager() typex.TargetRegistry
• func SchemaCount() int
• func SchemaDelete(id string)
• func SchemaFlush()
• func SchemaGet(id string) (typex.DataSchema, bool)
• func SchemaSet(id string, schema typex.DataSchema)
• func SetDebugMode(EnablePProf bool)
• func SetGomaxProcs(GomaxProcs int)
• func StartStore(maxSize int)
• func StartWebDataPipe() error
• func VerifyLuaSyntax(r *typex.Rule) error
• type DeviceTypeManager
  • func (rm *DeviceTypeManager) All() []*typex.XConfig
  • func (rm *DeviceTypeManager) Find(name typex.DeviceType) *typex.XConfig
  • func (rm *DeviceTypeManager) Register(name typex.DeviceType, f *typex.XConfig)
• type RulexStore
  • func (rs *RulexStore) Count() int
  • func (rs *RulexStore) Delete(k string) error
  • func (rs *RulexStore) FuzzyGet(k string) string
  • func (rs *RulexStore) Get(k string) string
  • func (rs *RulexStore) Set(k string, v string)
  • func (rs *RulexStore) SetDuration(k string, v string, d time.Duration)
• type SourceTypeManager
  • func (rm *SourceTypeManager) All() []*typex.XConfig
  • func (rm *SourceTypeManager) Find(name typex.InEndType) *typex.XConfig
  • func (rm *SourceTypeManager) Register(name typex.InEndType, f *typex.XConfig)
• type TargetTypeManager
  • func (rm *TargetTypeManager) All() []*typex.XConfig
  • func (rm *TargetTypeManager) Find(name typex.TargetType) *typex.XConfig
  • func (rm *TargetTypeManager) Register(name typex.TargetType, f *typex.XConfig)
• type WebsocketDataPipe
  • func InitWebDataPipe(rulex typex.RuleX) *WebsocketDataPipe

Constants

const (
	SUCCESS_KEY string = "Success"
	FAILED_KEY  string = "Failed"
	ACTIONS_KEY string = "Actions"
)

Variables

var GlobalConfig typex.RulexConfig

var GlobalStore typex.XStore

var INIPath string

Functions

func AllSchema

func AllSchema() map[string]typex.DataSchema

* * 所有 *

func ExecuteActions

func ExecuteActions(rule *typex.Rule, arg lua.LValue) (lua.LValue, error)

* * Execute Lua Callback *

func ExecuteFailed

func ExecuteFailed(vm *lua.LState, arg lua.LValue) (interface{}, error)

func ExecuteSuccess

func ExecuteSuccess(vm *lua.LState) (interface{}, error)

LUA Callback : Success

func FilterSingleDataWithSchema

func FilterSingleDataWithSchema(data map[string]interface{},
	dataDefine []typex.DataDefine) map[string]interface{}

* * 单线条, data长度为1，其中有一个轴固定为‘date’ ^ | ***** | ** ** | ** ** ** * | ** ** ** ** | ** ** ** ** | ** ** ** ** | ** ** ** ** | ****** ** ** | ******** +------------------------------------------------------------->

func FirstCache

func FirstCache(id string, schema typex.DataSchema) typex.DataSchema

* * 第一次缓冲 *

func InitGlobalConfig

func InitGlobalConfig(path string) typex.RulexConfig

Init config

func InitInternalSchemaCache

func InitInternalSchemaCache()

* * 初始化缓冲器 *

func NewDeviceTypeManager

func NewDeviceTypeManager() typex.DeviceRegistry

func NewRulexStore

func NewRulexStore(maxSize int) typex.XStore

func NewSourceTypeManager

func NewSourceTypeManager() typex.SourceRegistry

func NewTargetTypeManager

func NewTargetTypeManager() typex.TargetRegistry

func SchemaCount

func SchemaCount() int

* * 数目 *

func SchemaDelete

func SchemaDelete(id string)

* * 删除 *

func SchemaFlush

func SchemaFlush()

* * 清空数据 *

func SchemaGet

func SchemaGet(id string) (typex.DataSchema, bool)

* * 获取某个模型 *

func SchemaSet

func SchemaSet(id string, schema typex.DataSchema)

* * 增加一条缓存数据 *

func SetDebugMode

func SetDebugMode(EnablePProf bool)

* * 设置性能，通常用来Debug用，生产环境建议关闭 *

func SetGomaxProcs

func SetGomaxProcs(GomaxProcs int)

* * 设置go的线程，通常=0 不需要配置 *

func StartStore

func StartStore(maxSize int)

func StartWebDataPipe

func StartWebDataPipe() error

* * 启动, 默认在3580端口 *

func VerifyLuaSyntax

func VerifyLuaSyntax(r *typex.Rule) error

VerifyLuaSyntax Verify Lua Syntax

Types

type DeviceTypeManager

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

func (*DeviceTypeManager) All

func (rm *DeviceTypeManager) All() []*typex.XConfig

func (*DeviceTypeManager) Find

func (rm *DeviceTypeManager) Find(name typex.DeviceType) *typex.XConfig

func (*DeviceTypeManager) Register

func (rm *DeviceTypeManager) Register(name typex.DeviceType, f *typex.XConfig)

type RulexStore

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

func (*RulexStore) Count

func (rs *RulexStore) Count() int

统计数量

func (*RulexStore) Delete

func (rs *RulexStore) Delete(k string) error

func (*RulexStore) FuzzyGet

func (rs *RulexStore) FuzzyGet(k string) string

模糊查询匹配 支持: *AAA AAA* A*B

func (*RulexStore) Get

func (rs *RulexStore) Get(k string) string

获取值

func (*RulexStore) Set

func (rs *RulexStore) Set(k string, v string)

设置值

func (*RulexStore) SetDuration

func (rs *RulexStore) SetDuration(k string, v string, d time.Duration)

* * 设置过期时间 *

type SourceTypeManager

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

func (*SourceTypeManager) All

func (rm *SourceTypeManager) All() []*typex.XConfig

func (*SourceTypeManager) Find

func (rm *SourceTypeManager) Find(name typex.InEndType) *typex.XConfig

func (*SourceTypeManager) Register

func (rm *SourceTypeManager) Register(name typex.InEndType, f *typex.XConfig)

type TargetTypeManager

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

func (*TargetTypeManager) All

func (rm *TargetTypeManager) All() []*typex.XConfig

func (*TargetTypeManager) Find

func (rm *TargetTypeManager) Find(name typex.TargetType) *typex.XConfig

func (*TargetTypeManager) Register

func (rm *TargetTypeManager) Register(name typex.TargetType, f *typex.XConfig)

type WebsocketDataPipe

type WebsocketDataPipe struct {
	WsServer websocket.Upgrader
	Clients  map[string]*websocket.Conn
	// contains filtered or unexported fields
}

* * Websocket 管道 *

func InitWebDataPipe

func InitWebDataPipe(rulex typex.RuleX) *WebsocketDataPipe

* * 初始化缓冲器 *