handlers

Documentation

Index

• Variables
• func BodyTooLarge(c *xin.Context)
• func E(c *xin.Context) xin.H
• func Forbidden(c *xin.Context)
• func H(c *xin.Context) xin.H
• func HealthCheck(c *xin.Context)
• func Index(c *xin.Context)
• func InternalServerError(c *xin.Context)
• func IsAjax(c *xin.Context) bool
• func NotFound(c *xin.Context)
• func Panic(c *xin.Context)
• type JobArg
  • func (ja *JobArg) SetFile(tt tenant.Tenant, mfh *multipart.FileHeader) error
  • func (ja *JobArg) SetParam(v any)
• type JobChainController
  • func NewJobChainController(name, tpl string) *JobChainController
  • func (jcc *JobChainController) Abort(c *xin.Context)
  • func (jcc *JobChainController) Index(c *xin.Context)
  • func (jcc *JobChainController) List(c *xin.Context)
  • func (jcc *JobChainController) Start(c *xin.Context)
  • func (jcc *JobChainController) Status(c *xin.Context)
• type JobChainCtrl
• type JobChainHandler
  • func NewJobChainHandler(create func() JobChainCtrl) *JobChainHandler
  • func (jch *JobChainHandler) Abort(c *xin.Context)
  • func (jch *JobChainHandler) Index(c *xin.Context)
  • func (jch *JobChainHandler) List(c *xin.Context)
  • func (jch *JobChainHandler) Router(rg *xin.RouterGroup)
  • func (jch *JobChainHandler) Start(c *xin.Context)
  • func (jch *JobChainHandler) Status(c *xin.Context)
• type JobChainInfo
  • func NewJobChainInfo(locale string, jc *xjm.JobChain) *JobChainInfo
• type JobController
  • func NewJobController(name, tpl string) *JobController
  • func (jc *JobController) Abort(c *xin.Context)
  • func (jc *JobController) Index(c *xin.Context)
  • func (jc *JobController) List(c *xin.Context)
  • func (jc *JobController) Logs(c *xin.Context)
  • func (jc *JobController) Start(c *xin.Context)
  • func (jc *JobController) Status(c *xin.Context)
• type JobCtrl
• type JobHandler
  • func NewJobHandler(create func() JobCtrl) *JobHandler
  • func (jh *JobHandler) Abort(c *xin.Context)
  • func (jh *JobHandler) Index(c *xin.Context)
  • func (jh *JobHandler) List(c *xin.Context)
  • func (jh *JobHandler) Logs(c *xin.Context)
  • func (jh *JobHandler) Router(rg *xin.RouterGroup)
  • func (jh *JobHandler) Start(c *xin.Context)
  • func (jh *JobHandler) Status(c *xin.Context)

Variables

var (
	ErrRestrictedIP       = errors.New("Restricted IP Address")
	ErrRestrictedFeature  = errors.New("Restricted Feature")
	ErrRestrictedFunction = errors.New("Restricted Function")
)

Functions

func BodyTooLarge

func BodyTooLarge(c *xin.Context)

func E

func E(c *xin.Context) xin.H

func Forbidden

func Forbidden(c *xin.Context)

func H

func H(c *xin.Context) xin.H

func HealthCheck

func HealthCheck(c *xin.Context)

func Index

func Index(c *xin.Context)

func InternalServerError

func InternalServerError(c *xin.Context)

func IsAjax

func IsAjax(c *xin.Context) bool

func NotFound

func NotFound(c *xin.Context)

func Panic

func Panic(c *xin.Context)

Types

type JobArg

type JobArg struct {
	File  string
	Param string
}

JobArg job argument struct

func (*JobArg) SetFile

func (ja *JobArg) SetFile(tt tenant.Tenant, mfh *multipart.FileHeader) error

func (*JobArg) SetParam

func (ja *JobArg) SetParam(v any)

type JobChainController

type JobChainController struct {
	ChainName   string
	ChainData   bool
	ChainStates []*jobs.JobRunState
	JobName     string
	JobFile     string
	JobParam    jobs.ISetChain
	Template    string
}

JobChainController job chain controller base struct

func NewJobChainController

func NewJobChainController(name, tpl string) *JobChainController

func (*JobChainController) Abort

func (jcc *JobChainController) Abort(c *xin.Context)

func (*JobChainController) Index

func (jcc *JobChainController) Index(c *xin.Context)

func (*JobChainController) List

func (jcc *JobChainController) List(c *xin.Context)

func (*JobChainController) Start

func (jcc *JobChainController) Start(c *xin.Context)

func (*JobChainController) Status

func (jcc *JobChainController) Status(c *xin.Context)

type JobChainCtrl

type JobChainCtrl interface {
	Index(*xin.Context)
	List(*xin.Context)
	Start(*xin.Context)
	Abort(*xin.Context)
	Status(*xin.Context)
}

type JobChainHandler

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

JobChainHandler job handler

func NewJobChainHandler

func NewJobChainHandler(create func() JobChainCtrl) *JobChainHandler

func (*JobChainHandler) Abort

func (jch *JobChainHandler) Abort(c *xin.Context)

func (*JobChainHandler) Index

func (jch *JobChainHandler) Index(c *xin.Context)

func (*JobChainHandler) List

func (jch *JobChainHandler) List(c *xin.Context)

func (*JobChainHandler) Router

func (jch *JobChainHandler) Router(rg *xin.RouterGroup)

func (*JobChainHandler) Start

func (jch *JobChainHandler) Start(c *xin.Context)

func (*JobChainHandler) Status

func (jch *JobChainHandler) Status(c *xin.Context)

type JobChainInfo

type JobChainInfo struct {
	ID        int64               `json:"id"`
	Status    string              `json:"status"`
	Caption   string              `json:"caption"`
	States    []*jobs.JobRunState `json:"states,omitempty"`
	CreatedAt time.Time           `json:"created_at,omitempty"`
	UpdatedAt time.Time           `json:"updated_at,omitempty"`
}

func NewJobChainInfo

func NewJobChainInfo(locale string, jc *xjm.JobChain) *JobChainInfo

type JobController

type JobController struct {
	JobArg
	Name     string
	Multi    bool
	Template string
}

JobController job controller base struct

func NewJobController

func NewJobController(name, tpl string) *JobController

func (*JobController) Abort

func (jc *JobController) Abort(c *xin.Context)

func (*JobController) Index

func (jc *JobController) Index(c *xin.Context)

func (*JobController) List

func (jc *JobController) List(c *xin.Context)

func (*JobController) Logs

func (jc *JobController) Logs(c *xin.Context)

func (*JobController) Start

func (jc *JobController) Start(c *xin.Context)

func (*JobController) Status

func (jc *JobController) Status(c *xin.Context)

type JobCtrl

type JobCtrl interface {
	Index(*xin.Context)
	List(*xin.Context)
	Logs(*xin.Context)
	Status(*xin.Context)
	Start(*xin.Context)
	Abort(*xin.Context)
}

type JobHandler

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

JobHandler job handler

func NewJobHandler

func NewJobHandler(create func() JobCtrl) *JobHandler

func (*JobHandler) Abort

func (jh *JobHandler) Abort(c *xin.Context)

func (*JobHandler) Index

func (jh *JobHandler) Index(c *xin.Context)

func (*JobHandler) List

func (jh *JobHandler) List(c *xin.Context)

func (*JobHandler) Logs

func (jh *JobHandler) Logs(c *xin.Context)

func (*JobHandler) Router

func (jh *JobHandler) Router(rg *xin.RouterGroup)

func (*JobHandler) Start

func (jh *JobHandler) Start(c *xin.Context)

func (*JobHandler) Status

func (jh *JobHandler) Status(c *xin.Context)