handlers

package
v0.0.0-...-c7c9204 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2024 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrRestrictedIP       = errors.New("Restricted IP Address")
	ErrRestrictedFeature  = errors.New("Restricted Feature")
	ErrRestrictedFunction = errors.New("Restricted Function")
)
View Source 
var JobCtxbinders = map[string]JobCtxbinder{}

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)

func RegisterJobArgbinder 

func RegisterJobArgbinder(name string, jab JobArgbinder)

func RegisterJobCtxbinder 

func RegisterJobCtxbinder(name string, jcr JobCtxbinder)

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 JobArgbinder 

type JobArgbinder func(c *xin.Context) (jobs.IArgChain, bool)

type JobChainController 

type JobChainController struct {
	ChainName string
	ChainJobs []string
	JobFile   string
	JobParam  jobs.IArgChain
	Template  string
}

JobChainController job chain controller base struct

func (*JobChainController) BindJobArg 

func (jcc *JobChainController) BindJobArg(c *xin.Context, jn string) (jobs.IArgChain, bool)

func (*JobChainController) BindJobCtx 

func (jcc *JobChainController) BindJobCtx(c *xin.Context, h xin.H) bool

func (*JobChainController) Cancel 

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

func (*JobChainController) FirstJobName 

func (jcc *JobChainController) FirstJobName() string

func (*JobChainController) Index 

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

func (*JobChainController) InitChainJobs 

func (jcc *JobChainController) InitChainJobs(c *xin.Context, jns ...string)

func (*JobChainController) InvalidChainJobs 

func (jcc *JobChainController) InvalidChainJobs(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) StartJob 

func (jcc *JobChainController) StartJob(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)
	Cancel(*xin.Context)
	Status(*xin.Context)
}

type JobChainHandler 

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

JobChainHandler job handler

func NewJobChainHandler 

func NewJobChainHandler(create func(*xin.Context) JobChainCtrl) *JobChainHandler

func (*JobChainHandler) Cancel 

func (jch *JobChainHandler) Cancel(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) Cancel 

func (jc *JobController) Cancel(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)
	Cancel(*xin.Context)
}

type JobCtxbinder 

type JobCtxbinder func(c *xin.Context, h xin.H)

type JobHandler 

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

JobHandler job handler

func NewJobHandler 

func NewJobHandler(create func() JobCtrl) *JobHandler

func (*JobHandler) Cancel 

func (jh *JobHandler) Cancel(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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.