database

package
v0.2.3 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Momory = "momory"
)
View Source 
const (
	Mysql = "mysql"
)

Variables

View Source 
var (
	DefaultConfig = map[string]string{
		"global": `{"title":"Global","content":"\n--[[\n\tGlobal constant area, users can define some constants here; it is easy to call in other scripts\n]]--\n\nREMOTE = \"http://127.0.0.1:8888\"\n","closable":false, "prefab":false}`,
		"http":   `{"title":"HTTP","content":"\nlocal parm = {\n    body = {},    -- request body\n    timeout = \"10s\",\n    headers = {},\n}\n\nlocal url = REMOTE .. \"/group/methon\"\nlocal http = require(\"http\")\n\nfunction execute()\n    res, errmsg = http.post(url, parm)\n  \tif errmsg ~= nil then\n\t\tmeta.Err = errmsg\n    \treturn\n  \tend\n  \t\n  \tif res[\"status_code\"] ~= 200 then\n\t\tmeta.Err = \"post \" .. url .. \" http status code err \" .. res[\"status_code\"]\n  \t\treturn\n  \tend\n  \n  \tbody = json.decode(res[\"body\"])\n  \tmerge(meta, body.Body)\n\nend\n","closable":false, "prefab":true}`,
		"system": `{"channelsize":1024, "reportsize":100}`,
	}
)

Functions

func GetGlobalScript added in v0.1.7 

func GetGlobalScript(db IDatabase) []string

func Register added in v0.1.12 

func Register(component IDatabase, name string)

Types

type BehaviorInfo 

type BehaviorInfo struct {
	gorm.Model
	Name       string `gorm:"<-"`
	Dat        []byte `gorm:"<-"`
	UpdateTime int64  `gorm:"<-"`
	Status     string `gorm:"<-"`
	TagDat     []byte `gorm:"<-"`
}

type BotConfig 

type BotConfig struct {
	gorm.Model

	Name string `gorm:"<-"`
	Addr string `gorm:"<-"` // bot driver address
}

type BotTemplateConfig 

type BotTemplateConfig struct {
	gorm.Model

	Name string `gorm:"<-"`
	Tpl  []byte `gorm:"<-"`
}

type CodeTemplate added in v0.1.7 

type CodeTemplate struct {
	Lst []CodeTemplateInfo
}

type CodeTemplateInfo added in v0.1.7 

type CodeTemplateInfo struct {
	Title  string `json:"title"`
	Code   string `json:"content"`
	Prefab bool   `json:"prefab"`
}

type IDatabase added in v0.1.12 

type IDatabase interface {
	Init() error

	UpsetFile(string, []byte) error
	DelFile(string) error
	FindFile(string) (BehaviorInfo, error)
	GetAllFiles() ([]BehaviorInfo, error)

	UpdateState(name string, status string) error
	UpdateTags(name string, tags []byte) error

	ConfigFind(name string) (TemplateConfig, error)
	ConfigList() ([]string, error)
	ConfigUpset(name string, byt []byte) error
	ConfigRemove(name string) error

	RemoveReport(id string) error
	AppendReport(info ReportInfo) error
	GetReport() []ReportInfo
}

func Lookup added in v0.1.12 

func Lookup(name string) IDatabase

type LRUCache added in v0.0.16 

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

LRUCache lru结构

func Constructor added in v0.0.16 

func Constructor(capacity int) LRUCache

Constructor 构造

func (*LRUCache) Get added in v0.0.16 

func (lp *LRUCache) Get(key string) (bool, interface{})

Get 获取数据

func (*LRUCache) Put added in v0.0.16 

func (lp *LRUCache) Put(key string, value interface{})

Put 存放数据

type LRUNode added in v0.0.16 

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

LRUNode 存放数据

type MemoryAdapter added in v0.1.12 

type MemoryAdapter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MemoryAdapter) AppendReport added in v0.1.12 

func (f *MemoryAdapter) AppendReport(info ReportInfo) error

func (*MemoryAdapter) ConfigFind added in v0.1.15 

func (f *MemoryAdapter) ConfigFind(name string) (TemplateConfig, error)

func (*MemoryAdapter) ConfigList added in v0.1.15 

func (f *MemoryAdapter) ConfigList() ([]string, error)

func (*MemoryAdapter) ConfigRemove added in v0.1.15 

func (f *MemoryAdapter) ConfigRemove(name string) error

func (*MemoryAdapter) ConfigUpset added in v0.1.15 

func (f *MemoryAdapter) ConfigUpset(name string, byt []byte) error

func (*MemoryAdapter) DelFile added in v0.1.12 

func (f *MemoryAdapter) DelFile(name string) error

func (*MemoryAdapter) FindFile added in v0.1.12 

func (f *MemoryAdapter) FindFile(name string) (BehaviorInfo, error)

func (*MemoryAdapter) GetAllFiles added in v0.1.12 

func (f *MemoryAdapter) GetAllFiles() ([]BehaviorInfo, error)

func (*MemoryAdapter) GetReport added in v0.1.12 

func (f *MemoryAdapter) GetReport() []ReportInfo

func (*MemoryAdapter) Init added in v0.1.12 

func (f *MemoryAdapter) Init() error

func (*MemoryAdapter) RemoveReport added in v0.1.12 

func (f *MemoryAdapter) RemoveReport(id string) error

func (*MemoryAdapter) UpdateState added in v0.1.12 

func (f *MemoryAdapter) UpdateState(name string, status string) error

func (*MemoryAdapter) UpdateTags added in v0.1.12 

func (f *MemoryAdapter) UpdateTags(name string, tags []byte) error

func (*MemoryAdapter) UpsetFile added in v0.1.12 

func (f *MemoryAdapter) UpsetFile(name string, byt []byte) error

type MysqlAdapter added in v0.1.12 

type MysqlAdapter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MysqlAdapter) AppendReport added in v0.1.12 

func (f *MysqlAdapter) AppendReport(info ReportInfo) error

func (*MysqlAdapter) ConfigFind added in v0.1.15 

func (f *MysqlAdapter) ConfigFind(name string) (TemplateConfig, error)

func (*MysqlAdapter) ConfigList added in v0.1.15 

func (f *MysqlAdapter) ConfigList() ([]string, error)

func (*MysqlAdapter) ConfigRemove added in v0.1.15 

func (f *MysqlAdapter) ConfigRemove(name string) error

func (*MysqlAdapter) ConfigUpset added in v0.1.15 

func (f *MysqlAdapter) ConfigUpset(name string, byt []byte) error

func (*MysqlAdapter) DelFile added in v0.1.12 

func (f *MysqlAdapter) DelFile(name string) error

func (*MysqlAdapter) FindFile added in v0.1.12 

func (f *MysqlAdapter) FindFile(name string) (BehaviorInfo, error)

func (*MysqlAdapter) GetAllFiles added in v0.1.12 

func (f *MysqlAdapter) GetAllFiles() ([]BehaviorInfo, error)

func (*MysqlAdapter) GetReport added in v0.1.12 

func (f *MysqlAdapter) GetReport() []ReportInfo

func (*MysqlAdapter) Init added in v0.1.12 

func (f *MysqlAdapter) Init() error

func (*MysqlAdapter) RemoveReport added in v0.1.12 

func (f *MysqlAdapter) RemoveReport(id string) error

func (*MysqlAdapter) UpdateState added in v0.1.12 

func (f *MysqlAdapter) UpdateState(name string, status string) error

func (*MysqlAdapter) UpdateTags added in v0.1.12 

func (f *MysqlAdapter) UpdateTags(name string, tags []byte) error

func (*MysqlAdapter) UpsetFile added in v0.1.12 

func (f *MysqlAdapter) UpsetFile(name string, byt []byte) error

type ReportApiArr added in v0.1.8 

type ReportApiArr []ReportApiInfo

func (*ReportApiArr) Scan added in v0.1.8 

func (p *ReportApiArr) Scan(data interface{}) error

func (ReportApiArr) Value added in v0.1.8 

func (p ReportApiArr) Value() (driver.Value, error)

type ReportApiInfo added in v0.1.8 

type ReportApiInfo struct {
	Api        string
	ReqNum     int
	ErrNum     int
	ConsumeNum int64

	ReqSize int64
	ResSize int64
}

type ReportInfo added in v0.1.8 

type ReportInfo struct {
	gorm.Model
	ID         string
	Name       string
	BotNum     int
	ReqNum     int
	ErrNum     int
	Tps        int
	Dura       string
	BeginTime  int64
	ApiInfoLst ReportApiArr `gorm:"column:childrens;type:longtext"`
}

type SystemInfo added in v0.1.16 

type SystemInfo struct {
	ChannelSize int32 `json:"channelsize"`
	ReportSize  int32 `json:"reportsize"`
}

func GetSystemParm added in v0.1.16 

func GetSystemParm(db IDatabase) SystemInfo

type TemplateConfig added in v0.1.7 

type TemplateConfig struct {
	gorm.Model
	Name string `gorm:"<-"`
	Dat  []byte `gorm:"<-"`
}

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.