sqlite

Documentation

Index

• type AllAgent
• type DagInstance
  • func ConvertDagInstanceBOToDO(d *bo.DagInstance) *DagInstance
  • func (d *DagInstance) ToBO() *bo.DagInstance
• type NodeInstance
  • func ConvertNodeInstanceBOToDO(n *bo.NodeInstance) *NodeInstance
  • func (n *NodeInstance) ToBO() *bo.NodeInstance
• type ObConfig
• type ObGlobalConfig
• type ObServerConfig
• type ObSysParameter
• type ObZoneConfig
• type OcsConfig
• type OcsInfo
• type OcsToken
• type SubTaskLog
  • func ConvertSubTaskLogBOToDO(s *bo.SubTaskLog) *SubTaskLog
  • func (s *SubTaskLog) ToBO() *bo.SubTaskLog
• type SubtaskInstance
  • func ConvertSubTaskInstanceBOToDO(s *bo.SubTaskInstance) *SubtaskInstance
  • func (s *SubtaskInstance) ToBO() *bo.SubTaskInstance
• type TaskMapping

Types

type AllAgent

type AllAgent struct {
	Ip           string `gorm:"primaryKey;type:varchar(64);not null"`
	Port         int    `gorm:"primaryKey;type:bigint(20);not null"`
	Identity     string `gorm:"type:varchar(64);not null"`
	Version      string `gorm:"type:varchar(64);not null"`
	Os           string `gorm:"type:varchar(64);not null"`
	Architecture string `gorm:"type:varchar(64);not null"`
	Zone         string `gorm:"type:varchar(64);not null"`
	MysqlPort    int    `gorm:"type:bigint(20)"`
	RpcPort      int    `gorm:"type:bigint(20)"`
	HomePath     string `gorm:"type:text"`
	PublicKey    string `gorm:"type:text"`
}

type DagInstance

type DagInstance struct {
	Id                int64     `gorm:"primaryKey;autoIncrement;not null"`
	Name              string    `gorm:"type:varchar(128);not null"`
	Type              string    `gorm:"type:varchar(128);not null"`
	Stage             int       `gorm:"not null"`
	MaxStage          int       `gorm:"not null"`
	State             int       `gorm:"not null"`
	ExecuterAgentIp   string    `gorm:"type:varchar(64);not null"`
	ExecuterAgentPort int       `gorm:"type:int;not null"`
	IsMaintenance     bool      `gorm:"not null"`
	IsFinished        bool      `gorm:"not null"`
	Context           []byte    `gorm:"type:text"`
	Operator          int       `gorm:"not null"`
	StartTime         time.Time `gorm:"autoCreateTime"`
	EndTime           time.Time `gorm:"autoCreateTime"`
	GmtCreate         time.Time `gorm:"autoCreateTime"`
	GmtModify         time.Time `gorm:"autoUpdateTime"`
}

func ConvertDagInstanceBOToDO

func ConvertDagInstanceBOToDO(d *bo.DagInstance) *DagInstance

func (*DagInstance) ToBO

func (d *DagInstance) ToBO() *bo.DagInstance

type NodeInstance

type NodeInstance struct {
	Id                int64     `gorm:"primaryKey;autoIncrement;not null"`
	Name              string    `gorm:"type:varchar(64);not null"`
	DagId             int64     `gorm:"not null; index:idx_dag_stage"`
	DagStage          int       `gorm:"not null; index:idx_dag_stage"`
	StructName        string    `gorm:"type:varchar(128)"`
	Type              string    `gorm:"type:varchar(128);not null"`
	State             int       `gorm:"not null"`
	MaxStage          int       `gorm:"not null"`
	ExecuterAgentIp   string    `gorm:"type:varchar(64);not null"`
	ExecuterAgentPort int       `gorm:"type:int;not null"`
	Context           []byte    `gorm:"type:text"`
	Operator          int       `gorm:"not null"`
	StartTime         time.Time `gorm:"autoCreateTime"`
	EndTime           time.Time `gorm:"autoCreateTime"`
	GmtCreate         time.Time `gorm:"autoCreateTime"`
	GmtModify         time.Time `gorm:"autoUpdateTime"`
}

func ConvertNodeInstanceBOToDO

func ConvertNodeInstanceBOToDO(n *bo.NodeInstance) *NodeInstance

func (*NodeInstance) ToBO

func (n *NodeInstance) ToBO() *bo.NodeInstance

type ObConfig

type ObConfig struct {
	Name      string    `gorm:"primaryKey;not null;type:varchar(128)"`
	Value     string    `gorm:"not null;type:text"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
	Info      string
}

type ObGlobalConfig

type ObGlobalConfig struct {
	Name      string    `gorm:"index:global_config,unique;not null;type:varchar(128)"`
	Value     string    `gorm:"not null;type:text"`
	IsCluster bool      `gorm:"not null;default:false"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
}

type ObServerConfig

type ObServerConfig struct {
	Name      string    `gorm:"index:server_config,unique;not null;type:varchar(128)"`
	Value     string    `gorm:"not null;type:text"`
	AgentIp   string    `gorm:"index:server_config,unique;not null;type:varchar(64)"`
	AgentPort int       `gorm:"index:server_config,unique;not null;"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
}

type ObSysParameter

type ObSysParameter struct {
	Zone         string `gorm:"primaryKey;not null;type:varchar(128)"`
	SvrType      string `gorm:"primaryKey;not null;type:varchar(16)"`
	SvrIp        string `gorm:"primaryKey;not null;type:varchar(46)"`
	SvrPort      int64  `gorm:"primaryKey;not null;"`
	Name         string `gorm:"primaryKey;not null;type:varchar(128)"`
	DataType     string `gorm:"type:varchar(128)"`
	Value        string `gorm:"not null;type:text"`
	Info         string `gorm:"not null;type:varchar(4096)"`
	NeedReboot   int64  `gorm:"not null;"`
	Section      string `gorm:"not null;type:varchar(128)"`
	VisibleLevel string `gorm:"not null;type:varchar(64)"`
	Scope        string `gorm:"not null;type:varchar(64)"`
	Source       string `gorm:"not null;type:varchar(64)"`
	EditLevel    string `gorm:"not null;type:varchar(128)"`
}

type ObZoneConfig

type ObZoneConfig struct {
	Name      string    `gorm:"index:zone_config,unique;not null;type:varchar(128)"`
	Value     string    `gorm:"not null;type:text"`
	Zone      string    `gorm:"index:zone_config,unique;not null;type:varchar(128)"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
}

type OcsConfig

type OcsConfig struct {
	Name      string    `gorm:"type:varchar(128);not null;unique"`
	Value     string    `gorm:"type:varchar(65536);not null"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
	Info      string
}

type OcsInfo

type OcsInfo struct {
	Name  string `gorm:"type:varchar(128);not null;unique"`
	Value string `gorm:"type:varchar(65536);not null"`
	Info  string
}

type OcsToken

type OcsToken struct {
	Ip        string    `gorm:"primaryKey;type:varchar(64);not null"`
	Port      int       `gorm:"primaryKey;type:bigint(20);not null"`
	Token     string    `gorm:"type:varchar(128);not null;unique"`
	GmtModify time.Time `gorm:"autoUpdateTime"`
}

type SubTaskLog

type SubTaskLog struct {
	Id           int64     `gorm:"primaryKey;autoIncrement;not null"`
	SubTaskId    int64     `gorm:"not null"`
	ExecuteTimes int       `gorm:"not null"`
	LogContent   string    `gorm:"type:text"`
	IsSync       bool      `gorm:"type:bool;default:false"`
	CreateTime   time.Time `gorm:"autoCreateTime"`
	UpdateTime   time.Time `gorm:"autoUpdateTime"`
}

func ConvertSubTaskLogBOToDO

func ConvertSubTaskLogBOToDO(s *bo.SubTaskLog) *SubTaskLog

func (*SubTaskLog) ToBO

func (s *SubTaskLog) ToBO() *bo.SubTaskLog

type SubtaskInstance

type SubtaskInstance struct {
	Id                int64     `gorm:"primaryKey;autoIncrement;not null"`
	NodeId            int64     `gorm:"not null; index:idx_node_id"` // The remote node node_id is fixed to 0.
	Name              string    `gorm:"type:varchar(64);not null"`
	StructName        string    `gorm:"type:varchar(128)"`
	ExecuterAgentIp   string    `gorm:"type:varchar(64);not null"`
	ExecuterAgentPort int       `gorm:"type:int;not null"`
	ExecuteTimes      int       `gorm:"type:int;default:0"`
	CanCancel         bool      `gorm:"type:bool;default:false"`
	CanContinue       bool      `gorm:"type:bool;default:false"`
	CanPass           bool      `gorm:"type:bool;default:false"`
	CanRetry          bool      `gorm:"type:bool;default:false"`
	CanRollback       bool      `gorm:"type:bool;default:false"`
	Context           []byte    `gorm:"type:text"`
	State             int       `gorm:"not null"`
	Operator          int       `gorm:"not null"`
	StartTime         time.Time `gorm:"autoCreateTime"`
	EndTime           time.Time `gorm:"autoCreateTime"`
	GmtCreate         time.Time `gorm:"autoCreateTime"`
	GmtModify         time.Time `gorm:"autoUpdateTime"`
}

func ConvertSubTaskInstanceBOToDO

func ConvertSubTaskInstanceBOToDO(s *bo.SubTaskInstance) *SubtaskInstance

func (*SubtaskInstance) ToBO

func (s *SubtaskInstance) ToBO() *bo.SubTaskInstance

type TaskMapping

type TaskMapping struct {
	RemoteTaskId int64 `gorm:"primaryKey; not null;"`
	LocalTaskId  int64
	ExecuteTimes int       `gorm:"type:int;default:0"`
	IsSync       bool      `gorm:"default:false"`
	GmtModify    time.Time `gorm:"type:TIMESTAMP;autoUpdateTime;index:idx_gmt_modify"`
}