common

Documentation

Index

• Constants
• Variables
• func GetSQLErrCode(err error) (int, bool)
• func NewDB(conf MySQLConf) (*sql.DB, error)
• func NewGormDB(conf MySQLConf) (*gorm.DB, error)
• type MTS
• type MySQLConf
• type TaskStatus
  • func ParseTaskStatusFromString(s string) (TaskStatus, error)
  • func (ts TaskStatus) MarshalJSON() ([]byte, error)
  • func (ts TaskStatus) String() string
  • func (ts *TaskStatus) UnmarshalJSON(data []byte) (err error)

Constants

const (
	OutputTypeMySQL  = "mysql"
	OutputTypeCSV    = "csv"
	OutputTypeStdout = "stdout"
)

Variables

var InvalidTaskStatus = errors.New("invalid task status")

Functions

func GetSQLErrCode

func GetSQLErrCode(err error) (int, bool)

GetSQLErrCode returns error code if err is a mysql error

func NewDB

func NewDB(conf MySQLConf) (*sql.DB, error)

NewDB returns a new sql.DB instance

func NewGormDB

func NewGormDB(conf MySQLConf) (*gorm.DB, error)

NewGormDB return a new gorm db instance

Types

type MTS

type MTS struct {
	ID     uint64
	Status TaskStatus
}

type MySQLConf

type MySQLConf struct {
	Host         string
	Port         int
	User         string
	Password     string
	DBName       string
	MaxIdleConns int
	MaxOpenConns int
	MaxLifetime  time.Duration
}

MySQLConf is the mysql conf

type TaskStatus

type TaskStatus uint8

TaskStatus the task status type define

const (
	TaskStatusUnknown TaskStatus = iota
	TaskStatusRunning
	TaskStatusPaused
	TaskStatusStopped
	TaskStatusUnexceptedExited
	TaskStatusCompleted
	TaskStatusRunningTimeout
)

func ParseTaskStatusFromString

func ParseTaskStatusFromString(s string) (TaskStatus, error)

func (TaskStatus) MarshalJSON

func (ts TaskStatus) MarshalJSON() ([]byte, error)

func (TaskStatus) String

func (ts TaskStatus) String() string

func (*TaskStatus) UnmarshalJSON

func (ts *TaskStatus) UnmarshalJSON(data []byte) (err error)