server

Documentation

Index

• Constants
• Variables
• func Audit(l *logrus.Entry, task *model.Task, ruleTemplateName string) (err error)
• func AuditSQLByDBType(l *logrus.Entry, sql string, dbType string, ruleTemplateName string) (*model.Task, error)
• func AuditSQLByDriver(l *logrus.Entry, sql string, d driver.Driver) (*model.Task, error)
• func ExecuteWorkflow(workflow *model.Workflow, needExecTaskIdToUserId map[uint]uint) error
• func HookAudit(l *logrus.Entry, task *model.Task, hook AuditHook, ruleTemplateName string) (err error)
• func InitSqled(exit chan struct{})
• type AuditHook
• type EmptyAuditHook
  • func (e *EmptyAuditHook) AfterAudit(sql *model.ExecuteSQL)
  • func (e *EmptyAuditHook) BeforeAudit(sql *model.ExecuteSQL)
• type Sqled
  • func GetSqled() *Sqled
  • func (s *Sqled) AddTask(taskId string, typ int) error
  • func (s *Sqled) AddTaskWaitResult(taskId string, typ int) (*model.Task, error)
  • func (s *Sqled) CleanExpiredTasks(entry *logrus.Entry)
  • func (s *Sqled) CleanExpiredWorkflows(entry *logrus.Entry)
  • func (s *Sqled) HasTask(taskId string) bool
  • func (s *Sqled) Start()
  • func (s *Sqled) WorkflowSchedule(entry *logrus.Entry)

Constants

const (
	ActionTypeAudit = iota + 1
	ActionTypeExecute
	ActionTypeRollback
)

const AuditSchema = "AuditSchema"

const (
	SqlAuditTaskExpiredTime = 3 * 24 // 3 days
)

Variables

var (
	ErrActionExecuteOnExecutedTask       = _errors.New("task has been executed, can not do execute on it")
	ErrActionExecuteOnNonAuditedTask     = _errors.New("task has not been audited, can not do execute on it")
	ErrActionRollbackOnRollbackedTask    = _errors.New("task has been rollbacked, can not do rollback on it")
	ErrActionRollbackOnExecuteFailedTask = _errors.New("task has been executed failed, can not do rollback on it")
	ErrActionRollbackOnNonExecutedTask   = _errors.New("task has not been executed, can not do rollback on it")
)

Functions

func Audit

func Audit(l *logrus.Entry, task *model.Task, ruleTemplateName string) (err error)

func AuditSQLByDBType

func AuditSQLByDBType(l *logrus.Entry, sql string, dbType string, ruleTemplateName string) (*model.Task, error)

func AuditSQLByDriver

func AuditSQLByDriver(l *logrus.Entry, sql string, d driver.Driver) (*model.Task, error)

func ExecuteWorkflow

func ExecuteWorkflow(workflow *model.Workflow, needExecTaskIdToUserId map[uint]uint) error

func HookAudit

func HookAudit(l *logrus.Entry, task *model.Task, hook AuditHook, ruleTemplateName string) (err error)

func InitSqled

func InitSqled(exit chan struct{})

Types

type AuditHook

type AuditHook interface {
	BeforeAudit(sql *model.ExecuteSQL)
	AfterAudit(sql *model.ExecuteSQL)
}

type EmptyAuditHook

type EmptyAuditHook struct{}

func (*EmptyAuditHook) AfterAudit

func (e *EmptyAuditHook) AfterAudit(sql *model.ExecuteSQL)

func (*EmptyAuditHook) BeforeAudit

func (e *EmptyAuditHook) BeforeAudit(sql *model.ExecuteSQL)

type Sqled

type Sqled struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Sqled is an async task scheduling service. receive tasks from queue, the tasks include inspect, execute, rollback; and the task will only be executed once.

func GetSqled

func GetSqled() *Sqled

func (*Sqled) AddTask

func (s *Sqled) AddTask(taskId string, typ int) error

func (*Sqled) AddTaskWaitResult

func (s *Sqled) AddTaskWaitResult(taskId string, typ int) (*model.Task, error)

func (*Sqled) CleanExpiredTasks

func (s *Sqled) CleanExpiredTasks(entry *logrus.Entry)

func (*Sqled) CleanExpiredWorkflows

func (s *Sqled) CleanExpiredWorkflows(entry *logrus.Entry)

func (*Sqled) HasTask

func (s *Sqled) HasTask(taskId string) bool

func (*Sqled) Start

func (s *Sqled) Start()

func (*Sqled) WorkflowSchedule

func (s *Sqled) WorkflowSchedule(entry *logrus.Entry)