application

Documentation

Index

• Constants
• func Reload() error
• func Run() error
• func Stop() error
• type App
  • func (app *App) AddHandler(name string, handler TaskHandler)
  • func (app *App) Context() *context.BaseContext
  • func (app *App) Reload() error
  • func (app *App) Run() error
  • func (app *App) SetState(state int16)
  • func (app *App) Stop() error
• type MysqlHandler
  • func NewMysqlHandler(ctx *context.BaseContext) *MysqlHandler
  • func (handler *MysqlHandler) Execute() error
  • func (handler *MysqlHandler) HandleDirect(ctx *context.BizContext) error
  • func (handler *MysqlHandler) HandleInspect(ctx *context.BizContext) bool
  • func (handler *MysqlHandler) HandleMqMessage(ctx *context.BizContext, msg *syncmq.TopicMessage) error
  • func (handler *MysqlHandler) LoadConfig(conf config.MysqlTaskConfig) error
• type TaskHandler

Constants

const (
	AppStateRunning = 1
	AppStateReload  = 2
	AppStateStop    = 3
)

Functions

func Reload

func Reload() error

func Run

func Run() error

func Stop

func Stop() error

Types

type App

type App struct {
	// contains filtered or unexported fields
}

func (*App) AddHandler

func (app *App) AddHandler(name string, handler TaskHandler)

添加处理者

func (*App) Context

func (app *App) Context() *context.BaseContext

获取根上下文

func (*App) Reload

func (app *App) Reload() error

重启

func (*App) Run

func (app *App) Run() error

运行

func (*App) SetState

func (app *App) SetState(state int16)

设置状态

func (*App) Stop

func (app *App) Stop() error

停止

type MysqlHandler

type MysqlHandler struct {
	// contains filtered or unexported fields
}

func NewMysqlHandler

func NewMysqlHandler(ctx *context.BaseContext) *MysqlHandler

func (*MysqlHandler) Execute

func (handler *MysqlHandler) Execute() error

运行

func (*MysqlHandler) HandleDirect

func (handler *MysqlHandler) HandleDirect(ctx *context.BizContext) error

syncDirect implement

func (*MysqlHandler) HandleInspect

func (handler *MysqlHandler) HandleInspect(ctx *context.BizContext) bool

inspect implement

func (*MysqlHandler) HandleMqMessage

func (handler *MysqlHandler) HandleMqMessage(ctx *context.BizContext, msg *syncmq.TopicMessage) error

syncMq implement

func (*MysqlHandler) LoadConfig

func (handler *MysqlHandler) LoadConfig(conf config.MysqlTaskConfig) error

加载配置

type TaskHandler

type TaskHandler interface {
	Execute() error
}

任务处理接口