model

Documentation

Index

• func InsertCheckResult(ctx context.Context, db *gorm.DB, cr CheckResult) error
• func InsertNode(ctx context.Context, db *gorm.DB, node *Node) error
• func Migrate(db *gorm.DB)
• type AgentReportRequest
• type CheckReq
• type CheckResult
  • func (cr CheckResult) TableName() string
• type GetFileReq
• type Node
  • func ListNodes(ctx context.Context, db *gorm.DB) ([]Node, error)
  • func (n Node) String() string
  • func (n Node) TableName() string
• type PMTShell
• type Status

Functions

func InsertCheckResult

func InsertCheckResult(ctx context.Context, db *gorm.DB, cr CheckResult) error

InsertCheckResult ...

func InsertNode

func InsertNode(ctx context.Context, db *gorm.DB, node *Node) error

InsertNode insert the node to db

func Migrate

func Migrate(db *gorm.DB)

Migrate migrate mysql db

Types

type AgentReportRequest

type AgentReportRequest struct {
	VCSInfo      string `json:"vcs_info"`
	Hostname     string `json:"hostname"`
	IP           string `json:"ip"`
	AgentVersion string `json:"agent_version"`
	AgentType    int    `json:"agent_type"`
	RegionCode   string `json:"region_code"`
	RegionName   string `json:"region_name"`
	ZoneCode     string `json:"zone_code"`
	ZoneName     string `json:"zone_name"`
	Env          string `json:"env"`
}

AgentReportRequest agent status

type CheckReq

type CheckReq struct {
	CheckDatas []struct {
		Type string `json:"type"`
		Data string `json:"data"`
	} `json:"check_datas"`
}

CheckReq ...

type CheckResult

type CheckResult struct {
	gorm.Model
	NodeID int64  `gorm:"column:node_id" json:"node_id"`
	Status Status `gorm:"column:status" json:"status"`
	Count  int64  `gorm:"column:count" json:"status"`
}

CheckResult ...

func (CheckResult) TableName

func (cr CheckResult) TableName() string

TableName ...

type GetFileReq

type GetFileReq struct {
	FileName string `query:"file_name"`
}

type Node

type Node struct {
	ID         int64  `gorm:"primary_key"`
	AppName    string `gorm:"column:aname"`
	Schema     string `gorm:"column:schema"` // http / grpc
	IP         string `gorm:"column:ip"`
	Port       int32  `gorm:"column:port"`
	CreateTime *int64 `gorm:"column:ctime"`
	UpdateTime *int64 `gorm:"column:utime"`
	DeleteTime *int64 `gorm:"column:dtime"`
}

Node represents service node

func ListNodes

func ListNodes(ctx context.Context, db *gorm.DB) ([]Node, error)

ListNodes list the node infos

func (Node) String

func (n Node) String() string

String return the node string

func (Node) TableName

func (n Node) TableName() string

TableName return the db name

type PMTShell

type PMTShell struct {
	Pmt     string `json:"pmt"`
	AppName string `json:"app_name"`
	Op      int    `json:"op"`
}

PMTShell ...

type Status

type Status int

Status ...

const (
	// StatusInit ...
	StatusInit Status = 1
	// StatusSuccess ...
	StatusSuccess Status = 2
	// NodeTableName ...
	NodeTableName = "ma_node"
)