models

type Cluster struct {
	ClusterBasic
	Id        int       `json:"id"`
	Deleted   bool      `gorm:"default false" json:"deleted"`
	CreatedAt time.Time `gorm:"column:created_time" json:"createdat"`
	UpdateAt  time.Time `gorm:"column:last_update_time" json:"updateat"`
}

type ClusterBasic struct {
	Name        string          `gorm:"column:cluster_name" json:"name"`
	CnName      string          `gorm:"column:cn_name" json:"cnname"`
	Master      string          `gorm:"column:cluster_master" json:"master"`
	KubeConfig  string          `gorm:"column:kube_config" json:"kubeconfig"`
	Status      Status          `gorm:"column:cluster_status" json:"status"` // status 1 is up 0 is down
	Desc        string          `gorm:"column:cluster_desc" json:"desc"`
	Creator     string          ` json:"creator"`
	Environment EnvironmentType `json:"environment"`
}

type ComProgStatus struct {
	ID            uint64     `json:"id"`
	TaskID        uint64     `json:"task_id"`
	ComponentID   uint64     `json:"component_id"`
	ComponentName string     `json:"component_name"`
	ProgramID     uint64     `json:"program_id"`
	ProgramName   string     `json:"program_name"`
	AttachID      uint32     `json:"attach_id"`
	Status        TaskStatus `json:"status"`
	Error         string     `json:"error"`
	CreatedAt     time.Time  `json:"created_at"`
	UpdatedAt     time.Time  `json:"updated_at"`
}

type Component struct {
	Id         int       `json:"id"`
	Name       string    `json:"name"`
	ClusterId  int64     `json:"cluster_id"`
	BinaryPath string    `json:"binary_path"`
	Programs   []Program `json:"programs"`
	Maps       []Map     `json:"maps"`
}

type ComponentDB struct {
	ID             uint64    `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	Name           string    `gorm:"column:name;uniqueIndex" json:"name"`
	BinaryPath     string    `gorm:"column:binary_path" json:"binary_path"`
	Deleted        uint8     `gorm:"column:deleted;default:0" json:"deleted"`
	Creator        string    `gorm:"column:creator" json:"creator"`
	CreatedTime    time.Time `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`

	ClusterID uint64 `gorm:"column:cluster_id" json:"cluster_id"`

	// 关联关系
	Programs []ProgramDB `gorm:"foreignKey:ComponentID" json:"programs"`
	Maps     []MapDB     `gorm:"foreignKey:ComponentID" json:"maps"`
}

type EnvironmentType string

type JSONMapProperties meta.MapProperties

type JSONProgramProperties meta.ProgramProperties

type Map struct {
	Id          int                `json:"id"`
	Name        string             `json:"name"`
	Description string             `json:"description"`
	Spec        MapSpec            `json:"spec"`
	Properties  meta.MapProperties `json:"properties"`
}

type MapDB struct {
	ID             uint64    `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	ComponentID    uint64    `gorm:"column:component_id;index" json:"component_id"`
	Name           string    `gorm:"column:name" json:"name"`
	Description    string    `gorm:"column:description" json:"description"`
	Deleted        uint8     `gorm:"column:deleted;default:0" json:"deleted"`
	Creator        string    `gorm:"column:creator" json:"creator"`
	CreatedTime    time.Time `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`

	// 关联关系
	Spec       MapSpecDB       `gorm:"foreignKey:MapID" json:"spec"`
	Properties MapPropertiesDB `gorm:"foreignKey:MapID" json:"properties"`
}

type MapInfoWrapper struct {
	// Type of the map.
	Type ebpf.MapType
	// KeySize is the size of the map key in bytes.
	KeySize uint32
	// ValueSize is the size of the map value in bytes.
	ValueSize uint32
	// MaxEntries is the maximum number of entries the map can hold. Its meaning
	// is map-specific.
	MaxEntries uint32
	// Flags used during map creation.
	Flags uint32
	// Name as supplied by user space at load time. Available from 4.15.
	Name string

	ID       ebpf.MapID
	BTF      btf.ID
	MapExtra uint64
	Memlock  uint64
	Frozen   bool
}

type MapPropertiesDB struct {
	ID             uint64            `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	MapID          uint64            `gorm:"column:map_id;uniqueIndex" json:"map_id"`
	PropertiesJSON JSONMapProperties `gorm:"column:properties_json" json:"properties_json"`
	Deleted        uint8             `gorm:"column:deleted;default:0" json:"deleted"`
	CreatedTime    time.Time         `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time         `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`
}

type MapSpec struct {

	// Name is passed to the kernel as a debug aid. Must only contain
	// alpha numeric and '_' characters.
	Name       string
	Type       ebpf.MapType
	KeySize    uint32
	ValueSize  uint32
	MaxEntries uint32

	// Flags is passed to the kernel and specifies additional map
	// creation attributes.
	Flags uint32

	// Automatically pin and load a map from MapOptions.PinPath.
	// Generates an error if an existing pinned map is incompatible with the MapSpec.
	Pinning ebpf.PinType
}

type MapSpecDB struct {
	ID             uint64       `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	MapID          uint64       `gorm:"column:map_id;uniqueIndex" json:"map_id"`
	Name           string       `gorm:"column:name" json:"name"`
	Type           ebpf.MapType `gorm:"column:type" json:"type"`
	KeySize        uint32       `gorm:"column:key_size" json:"key_size"`
	ValueSize      uint32       `gorm:"column:value_size" json:"value_size"`
	MaxEntries     uint32       `gorm:"column:max_entries" json:"max_entries"`
	Flags          uint32       `gorm:"column:flags" json:"flags"`
	Pinning        string       `gorm:"column:pinning" json:"pinning"`
	Deleted        uint8        `gorm:"column:deleted;default:0" json:"deleted"`
	CreatedTime    time.Time    `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time    `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`
}

type MetricPoint struct {
	Timestamp   time.Time `json:"timestamp"`
	Value       float64   `json:"value"`
	ProgramName string    `json:"program_name"`
}

type Program struct {
	Id          int                    `json:"id"`
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Spec        ProgramSpec            `json:"spec"`
	Properties  meta.ProgramProperties `json:"properties"`
}

type ProgramDB struct {
	ID             uint64    `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	ComponentID    uint64    `gorm:"column:component_id;index" json:"component_id"`
	Name           string    `gorm:"column:name" json:"name"`
	Description    string    `gorm:"column:description" json:"description"`
	Deleted        uint8     `gorm:"column:deleted;default:0" json:"deleted"`
	Creator        string    `gorm:"column:creator" json:"creator"`
	CreatedTime    time.Time `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`

	// 关联关系
	Spec       ProgramSpecDB       `gorm:"foreignKey:ProgramID" json:"spec"`
	Properties ProgramPropertiesDB `gorm:"foreignKey:ProgramID" json:"properties"`
}

type ProgramDetail struct {
	ProgramInfoWrapper
	MapsDetail []MapInfoWrapper
}

type ProgramInfoWrapper struct {
	Type ebpf.ProgramType
	ID   ebpf.ProgramID
	// Truncated hash of the BPF bytecode. Available from 4.13.
	Tag string
	// Name as supplied by user space at load time. Available from 4.15.
	Name string

	CreatedByUID     uint32
	HaveCreatedByUID bool
	BTF              btf.ID
	LoadTime         time.Time

	Maps []ebpf.MapID
}

type ProgramPropertiesDB struct {
	ID             uint64                `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	ProgramID      uint64                `gorm:"column:program_id;uniqueIndex" json:"program_id"`
	PropertiesJSON JSONProgramProperties `gorm:"column:properties_json" json:"properties_json"`
	Deleted        uint8                 `gorm:"column:deleted;default:0" json:"deleted"`
	CreatedTime    time.Time             `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time             `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`
}

type ProgramSpec struct {
	// Name is passed to the kernel as a debug aid. Must only contain
	// alpha numeric and '_' characters.
	Name string

	// Type determines at which hook in the kernel a program will run.
	Type ebpf.ProgramType

	// AttachType of the program, needed to differentiate allowed context
	// accesses in some newer program types like CGroupSockAddr.
	//
	// Available on kernels 4.17 and later.
	AttachType ebpf.AttachType

	// Name of a kernel data structure or function to attach to. Its
	// interpretation depends on Type and AttachType.
	AttachTo string

	// The name of the ELF section this program originated from.
	SectionName string

	// Flags is passed to the kernel and specifies additional program
	// load attributes.
	Flags uint32

	// License of the program. Some helpers are only available if
	// the license is deemed compatible with the GPL.
	//
	// See https://www.kernel.org/doc/html/latest/process/license-rules.html#id1
	License string

	// Version used by Kprobe programs.
	//
	// Deprecated on kernels 5.0 and later. Leave empty to let the library
	// detect this value automatically.
	KernelVersion uint32
}

type ProgramSpecDB struct {
	ID             uint64           `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	ProgramID      uint64           `gorm:"column:program_id;uniqueIndex" json:"program_id"`
	Name           string           `gorm:"column:name" json:"name"`
	Type           ebpf.ProgramType `gorm:"column:type" json:"type"`
	AttachType     ebpf.AttachType  `gorm:"column:attach_type" json:"attach_type"`
	AttachTo       string           `gorm:"column:attach_to" json:"attach_to"`
	SectionName    string           `gorm:"column:section_name" json:"section_name"`
	Flags          uint32           `gorm:"column:flags" json:"flags"`
	License        string           `gorm:"column:license" json:"license"`
	KernelVersion  uint32           `gorm:"column:kernel_version" json:"kernel_version"`
	Deleted        uint8            `gorm:"column:deleted;default:0" json:"deleted"`
	CreatedTime    time.Time        `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time        `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`
}

type RunningTask struct {
	Task       *Task
	CancelFunc context.CancelFunc
	Logger     *zap.Logger
	BPFLoader  *loader.BPFLoader
}

type Status int

type Task struct {
	ID            uint64          `json:"id"`
	Name          string          `json:"name"`
	Description   string          `json:"description"`
	ComponentID   uint64          `json:"component_id"`
	ComponentName string          `json:"component_name"`
	Step          TaskStep        `json:"step"`
	Status        TaskStatus      `json:"status"`
	Error         string          `json:"error"`
	ProgStatus    []ComProgStatus `json:"prog_status"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
}

type TaskDB struct {
	ID             uint64    `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	Name           string    `gorm:"column:name" json:"name"`
	Description    string    `gorm:"column:description;type:text" json:"description"`
	ComponentID    uint64    `gorm:"column:component_id;index" json:"component_id"`
	ComponentName  string    `gorm:"column:component_name" json:"component_name"`
	Step           int       `gorm:"column:step;comment:任务步骤" json:"step"`
	Status         int       `gorm:"column:status;comment:任务状态" json:"status"`
	Error          string    `gorm:"column:error;type:text" json:"error"`
	Deleted        uint8     `gorm:"column:deleted;default:0" json:"deleted"`
	Creator        string    `gorm:"column:creator" json:"creator"`
	CreatedTime    time.Time `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`

	// 关联关系
	ProgStatuses []TaskProgStatusDB `gorm:"foreignKey:TaskID" json:"prog_statuses"`
}

type TaskMetrics struct {
	AvgRunTimeNS      []MetricPoint `json:"avg_run_time_ns"`
	CPUUsage          []MetricPoint `json:"cpu_usage"`
	EventsPerSecond   []MetricPoint `json:"events_per_second"`
	PeriodNS          []MetricPoint `json:"period_ns"`
	TotalAvgRunTimeNS []MetricPoint `json:"total_avg_run_time_ns"`
}

type TaskProgStatusDB struct {
	ID             uint64    `gorm:"column:id;primaryKey;autoIncrement" json:"id"`
	TaskID         uint64    `gorm:"column:task_id;index" json:"task_id"`
	ComponentID    uint64    `gorm:"column:component_id;index" json:"component_id"`
	ComponentName  string    `gorm:"column:component_name" json:"component_name"`
	ProgramID      uint64    `gorm:"column:program_id;index" json:"program_id"`
	ProgramName    string    `gorm:"column:program_name" json:"program_name"`
	Status         int       `gorm:"column:status;comment:状态" json:"status"`
	Error          string    `gorm:"column:error;type:text" json:"error"`
	Deleted        uint8     `gorm:"column:deleted;default:0" json:"deleted"`
	CreatedTime    time.Time `gorm:"column:created_time;autoCreateTime" json:"created_time"`
	LastUpdateTime time.Time `gorm:"column:last_update_time;autoUpdateTime" json:"last_update_time"`
}

type TaskStatus int

type TaskStep int