plugin

package
v0.0.0-...-2c50e35 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2023 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	REQUEST_SUCCESS       = 200 // 请求成功
	REQUEST_FAIL          = 411 // 请求失败
	REQUEST_QUERY_ERR     = 412 // 参数格式错误
	REQUEST_SERVER_ERR    = 413 // 服务执行异常
	REQUEST_RESPONSE_ERR  = 414 // 返回数据格式错误
	REQUEST_TOKEN_OVERDUE = 886 // 令牌失效
)
View Source 
const (
	MODBUS_FUNC_COIL_RW     = "coil_rw"
	MODBUS_FUNC_COIL_R      = "coil_r"
	MODBUS_FUNC_REGISTER_RW = "register_rw"
	MODBUS_FUNC_REGISTER_R  = "register_r"
)
View Source 
const (
	MODBUS_DT_BOOL   = "bool"
	MODBUS_DT_UINT16 = "uint16"
	MODBUS_DT_INT16  = "int16"
	MODBUS_DT_UINT32 = "uint32"
	MODBUS_DT_INT32  = "int32"
	MODBUS_DT_FLOAT  = "float"
)
View Source 
const (
	MODBUS_ED_BIG    = "big"
	MODBUS_ED_LITTLE = "little"
)

Variables

View Source 
var MODBUS_FUNC = []string{MODBUS_FUNC_COIL_RW, MODBUS_FUNC_COIL_R, MODBUS_FUNC_REGISTER_RW, MODBUS_FUNC_REGISTER_R}

Functions

func HttpDefault 

func HttpDefault(ctx *gin.Context, msg string, code int, data interface{})

func HttpFailure 

func HttpFailure(ctx *gin.Context, msg string, code int, data interface{})

func HttpSuccess 

func HttpSuccess(ctx *gin.Context, msg string, data interface{})

func ModbusRtuGetData 

func ModbusRtuGetData(result []byte, slave_id uint8, address uint16, endian string, points map[string]*ModbusPoint) (err error)

func ModbusRtuReadByte 

func ModbusRtuReadByte(slave_id uint8, function string, address, quantity uint16) (result []byte)

func NewNullID 

func NewNullID() (primitive.ObjectID, error)

func NewShortID 

func NewShortID() string

func NewShortObjectID 

func NewShortObjectID() (primitive.ObjectID, error)

func ParseToken 

func ParseToken(jwtKey []byte, tokenString string) (*jwt.Token, int64, interface{}, error)

ParseToken 验证令牌

func ReleaseToken 

func ReleaseToken(jwtKey []byte, expire int64, info interface{}) (token string, err error)

ReleaseToken 申请令牌

Types

type BSON 

type BSON bson.M

type Claims 

type Claims struct {
	Info  interface{}
	Timer int64

	jwt.StandardClaims
}

type HTTPQUERY 

type HTTPQUERY map[string]string

type HTTPRESPONSE 

type HTTPRESPONSE struct {
	Code int         `form:"code" bson:"code" json:"code"`
	Msg  string      `form:"msg" bson:"msg" json:"msg"`
	Data interface{} `form:"data" bson:"data" json:"data"`
}

type HttpClient 

type HttpClient struct {
	Instance *resty.Client

	Config HttpClientConfig
}

func NewHttpClient 

func NewHttpClient(config HttpClientConfig) (http_client HttpClient)

func (*HttpClient) DELETE 

func (http_client *HttpClient) DELETE(url string, query HTTPQUERY) (response HTTPRESPONSE, err error)

func (*HttpClient) GET 

func (http_client *HttpClient) GET(url string, query HTTPQUERY) (response HTTPRESPONSE, err error)

func (*HttpClient) POST 

func (http_client *HttpClient) POST(url string, query HTTPQUERY, body interface{}) (response HTTPRESPONSE, err error)

func (*HttpClient) PROXY 

func (http_client *HttpClient) PROXY(ctx *gin.Context, url string)

type HttpClientConfig 

type HttpClientConfig struct {
	BaseUrl string `form:"base_url" bson:"base_url" json:"base_url"`
}

type HttpServer 

type HttpServer struct {
	Router *gin.Engine

	Config HttpServerConfig
}

func NewHttpServer 

func NewHttpServer(config HttpServerConfig) (http_server HttpServer)

func (*HttpServer) Running 

func (http_server *HttpServer) Running() (err error)

type HttpServerConfig 

type HttpServerConfig struct {
	Url      string `form:"url" bson:"url" json:"url"`
	Mode     string `form:"mode" bson:"mode" json:"mode"`
	HtmlPath string `form:"html_path" bson:"html_path" json:"html_path"`
}

type Influx 

type Influx struct {
	Client influxdb2.Client
	Config InfluxConfig
}

func NewInflux 

func NewInflux(config InfluxConfig) (influx Influx)

func (*Influx) DeleteByMeasurement 

func (influx *Influx) DeleteByMeasurement(bucket string, measurement string) (err error)

func (*Influx) DeleteByTag 

func (influx *Influx) DeleteByTag(bucket string, measurement string, tag_key, tag_value string) (err error)

func (*Influx) Ping 

func (influx *Influx) Ping(time_sec int) (result bool, err error)

func (*Influx) Query 

func (influx *Influx) Query(flux_code string) (query_results []map[string]interface{}, err error)

type InfluxBatch 

type InfluxBatch struct {
	WriteApi api.WriteAPIBlocking
	Points   []*write.Point
}

func NewInfluxBatch 

func NewInfluxBatch(influx *Influx, bucket string) (batch InfluxBatch)

func (*InfluxBatch) AddPoint 

func (batch *InfluxBatch) AddPoint(measurement string, tags map[string]string, fields map[string]interface{}, tim int64)

func (*InfluxBatch) Write 

func (batch *InfluxBatch) Write() (err error)

type InfluxConfig 

type InfluxConfig struct {
	Url   string `form:"url" bson:"url" json:"url"`
	Token string `form:"token" bson:"token" json:"token"`
	Org   string `form:"org" bson:"org" json:"org"`
}

type JavaScriptResult 

type JavaScriptResult goja.Value

type Javascript 

type Javascript struct {
	Client *goja.Runtime
}

func NewJavascript 

func NewJavascript() (js Javascript)

func (*Javascript) Function 

func (js *Javascript) Function(func_name, code string, func_params ...interface{}) (result JavaScriptResult, err error)

type ModbusPoint 

type ModbusPoint struct {
	Function string `form:"function" bson:"function" json:"function"`
	Address  uint16 `form:"address" bson:"address" json:"address"`
	DataType string `form:"data_type" bson:"data_type" json:"data_type"`
	// contains filtered or unexported fields
}

func (ModbusPoint) Value 

func (modbus_point ModbusPoint) Value() *float64

type Mongo 

type Mongo struct {
	Client   *_mongo.Client   `form:"client" bson:"client" json:"client"`
	Database *_mongo.Database `form:"database" bson:"database" json:"database"`
	Config   MongoConfig      `form:"config" bson:"config" json:"config"`
}

func NewMongo 

func NewMongo(config MongoConfig) (mongo Mongo)

func (*Mongo) Connect 

func (mongo *Mongo) Connect() (err error)

func (*Mongo) CountDocuments 

func (mongo *Mongo) CountDocuments(collection string, filter interface{}) (count int64, err error)

func (*Mongo) CreateCollection 

func (mongo *Mongo) CreateCollection(coll string) (err error)

func (*Mongo) DeleteMany 

func (mongo *Mongo) DeleteMany(collection string, filter interface{}) (result *_mongo.DeleteResult, err error)

func (*Mongo) DeleteOne 

func (mongo *Mongo) DeleteOne(collection string, filter interface{}) (result *_mongo.DeleteResult, err error)

func (*Mongo) Disconnect 

func (mongo *Mongo) Disconnect() (err error)

func (*Mongo) DropCollection 

func (mongo *Mongo) DropCollection(coll string) (err error)

func (*Mongo) FetchList 

func (mongo *Mongo) FetchList(database string, filter BSON) (tables []map[string]interface{}, err error)

func (*Mongo) FindAll 

func (mongo *Mongo) FindAll(collection string, filter map[string]interface{}, tables interface{}) (err error)

func (*Mongo) FindAll2 

func (mongo *Mongo) FindAll2(collection string, filter map[string]interface{}, tables interface{}) (err error)

func (*Mongo) FindMany 

func (mongo *Mongo) FindMany(collection string, filter map[string]interface{}, tables interface{}, index int64, size int64, sort string, order int) (err error)

func (*Mongo) FindOne 

func (mongo *Mongo) FindOne(collection string, filter map[string]interface{}, tables interface{}) (err error)

func (*Mongo) InsertMany 

func (mongo *Mongo) InsertMany(collection string, tables []map[string]interface{}) (result *_mongo.InsertManyResult, err error)

func (*Mongo) InsertOne 

func (mongo *Mongo) InsertOne(collection string, table interface{}) (result *_mongo.InsertOneResult, err error)

func (*Mongo) ListCollectionNames 

func (mongo *Mongo) ListCollectionNames() (result []string, err error)

func (*Mongo) Ping 

func (mongo *Mongo) Ping(timeOut int) (err error)

func (*Mongo) ResetOne 

func (mongo *Mongo) ResetOne(collection string, filter interface{}, update interface{}) (result *_mongo.UpdateResult, err error)

func (*Mongo) TableCreate 

func (mongo *Mongo) TableCreate(database string, table any) (err error)

func (*Mongo) TableDelete 

func (mongo *Mongo) TableDelete(database string, objectid primitive.ObjectID) (err error)

func (*Mongo) TableExist 

func (mongo *Mongo) TableExist(database string, filter BSON) (table map[string]interface{}, result bool)

func (*Mongo) TableFind 

func (mongo *Mongo) TableFind(database string, filter BSON, table any) (result bool)

func (*Mongo) UpdateMany 

func (mongo *Mongo) UpdateMany(collection string, filter interface{}, update interface{}) (result *_mongo.UpdateResult, err error)

func (*Mongo) UpdateOne 

func (mongo *Mongo) UpdateOne(collection string, filter interface{}, update interface{}) (result *_mongo.UpdateResult, err error)

type MongoConfig 

type MongoConfig struct {
	Url      string `form:"url" bson:"url" json:"url"`
	Database string `form:"database" bson:"database" json:"database"`
	Username string `form:"username" bson:"username" json:"username"`
	Password string `form:"password" bson:"password" json:"password"`
}

type NsqClient 

type NsqClient struct {
	Client *_nsq.Producer
	Config NsqConfig
}

func NewNsqClient 

func NewNsqClient(config NsqConfig) (nsqClient NsqClient)

func (*NsqClient) Connect 

func (nsq *NsqClient) Connect() (err error)

func (*NsqClient) Publish 

func (nsq *NsqClient) Publish(topic string, message string) (err error)

type NsqConfig 

type NsqConfig struct {
	Url     string `form:"url" bson:"url" json:"url"`
	Channel string `form:"channel" bson:"channel" json:"channel"`
}

type NsqServer 

type NsqServer struct {
	Client *_nsq.Consumer
	Config NsqConfig
}

func NewNsqServer 

func NewNsqServer(config NsqConfig) (nsqServer NsqServer)

func (*NsqServer) Subscribe 

func (nsq *NsqServer) Subscribe(topic string, handle func(string)) (err error)

type Program 

type Program struct {
	Switch bool
	Isrun  bool

	ProgramStatus
	ProgramExit
	// contains filtered or unexported fields
}

func (*Program) Exiting 

func (program *Program) Exiting(timeout int) (result bool)

func (*Program) GetLog 

func (program *Program) GetLog(log_file_path string, row int) (contents []string, err error)

func (*Program) GetRestartCount 

func (program *Program) GetRestartCount() int64

func (*Program) GetStatename 

func (program *Program) GetStatename() string

func (*Program) GetStatus 

func (program *Program) GetStatus() map[string]interface{}

func (*Program) Runing 

func (program *Program) Runing(work_dir string, command string, log_file_path string)

type ProgramExit 

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

type ProgramStatus 

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

type TcpConfig 

type TcpConfig struct {
	Ip   string `json:"ip"`
	Port int    `json:"port"`
}

type TcpMessageCallback 

type TcpMessageCallback func(clientid *string, message []byte)

type TcpServer 

type TcpServer struct {
	Listener        net.Listener
	Config          TcpConfig
	MessageCallback TcpMessageCallback
	Clients         map[string]*TcpServerClient
}

func NewTcpServer 

func NewTcpServer(config TcpConfig, message_callback TcpMessageCallback) (tcp_server TcpServer)

func (*TcpServer) Exist 

func (tcp_server *TcpServer) Exist(clientid string) *TcpServerClient

func (*TcpServer) Listen 

func (tcp_server *TcpServer) Listen() (err error)

func (*TcpServer) Read 

func (tcp_server *TcpServer) Read(clientid string, timeout int64) (data []byte, err error)

func (*TcpServer) Send 

func (tcp_server *TcpServer) Send(clientid string, message []byte) (length int, err error)

type TcpServerClient 

type TcpServerClient struct {
	Clientid   string
	ActiveTime int64
	Addr       string
	Conn       net.Conn
}

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.