task

package
v0.0.0-...-977fba5 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Add 

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

func NewAdd 

func NewAdd() *Add

func (*Add) Run 

func (o *Add) Run(ctx context.Context, i iris.Context) (res interface{})

func (*Add) Send 

func (o *Add) Send(ctx context.Context) (code int, err error)

type AddRequest 

type AddRequest struct {
	DelaySeconds int    `` /* 269-byte string literal not displayed */
	TopicName    string `json:"topic_name" validate:"required,gte=2,lte=30" mock:"orders" label:"Topic name"`
	TopicTag     string `json:"topic_tag" validate:"required,gte=2,lte=60" mock:"created" label:"Topic tag"`
	Handler      string `json:"handler" validate:"required,url" mock:"https://example.com/orders/expired/remove" label:"Callback address"`
	Title        string `json:"title" validate:"required,lte=80" mock:"Example task" label:"Task name"`
	Remark       string `json:"remark" mock:"Task remark" label:"Description about task"`
}

func (*AddRequest) Override 

func (o *AddRequest) Override()

func (*AddRequest) Validate 

func (o *AddRequest) Validate() error

type AddResponse 

type AddResponse struct {
	DelaySeconds int    `json:"delay_seconds" mock:"0" label:"Delay seconds"`
	Id           int    `json:"id" mock:"1" label:"Task id"`
	Title        string `json:"title" mock:"Example task" label:"Task name"`
	TopicName    string `json:"topic_name" mock:"orders" label:"Topic name"`
	TopicTag     string `json:"topic_tag" mock:"created" label:"Topic tag"`
}

type Edit 

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

func NewEdit 

func NewEdit() *Edit

func (*Edit) Run 

func (o *Edit) Run(ctx context.Context, i iris.Context) (res interface{})

func (*Edit) Send 

func (o *Edit) Send(ctx context.Context) (code int, err error)

type EditDisable 

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

func NewEditDisable 

func NewEditDisable() *EditDisable

func (*EditDisable) Run 

func (o *EditDisable) Run(ctx context.Context, i iris.Context) (res interface{})

func (*EditDisable) Send 

func (o *EditDisable) Send(ctx context.Context) (code int, err error)

type EditEnable 

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

func NewEditEnable 

func NewEditEnable() *EditEnable

func (*EditEnable) Run 

func (o *EditEnable) Run(ctx context.Context, i iris.Context) (res interface{})

func (*EditEnable) Send 

func (o *EditEnable) Send(ctx context.Context) (code int, err error)

type EditFailed 

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

func NewEditFailed 

func NewEditFailed() *EditFailed

func (*EditFailed) Run 

func (o *EditFailed) Run(ctx context.Context, i iris.Context) (res interface{})

func (*EditFailed) Send 

func (o *EditFailed) Send(ctx context.Context) (code int, err error)

type EditHandler 

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

func NewEditHandler 

func NewEditHandler() *EditHandler

func (*EditHandler) Run 

func (o *EditHandler) Run(ctx context.Context, i iris.Context) (res interface{})

func (*EditHandler) Send 

func (o *EditHandler) Send(ctx context.Context) (code int, err error)

type EditRequest 

type EditRequest struct {
	Id           int     `json:"id" validate:"required,gte=1" mock:"1" label:"Task id"`
	DelaySeconds *int    `` /* 278-byte string literal not displayed */
	Parallels    *int    `` /* 135-byte string literal not displayed */
	Concurrency  *int32  `` /* 336-byte string literal not displayed */
	MaxRetry     *int    `` /* 139-byte string literal not displayed */
	Broadcasting *int    `` /* 161-byte string literal not displayed */
	Title        *string `json:"title" mock:"Example task" label:"Task name"`
	Remark       *string `json:"remark" mock:"Description about task" label:"Task remark"`
}

func (*EditRequest) Override 

func (o *EditRequest) Override(x *models.Task)

func (*EditRequest) Validate 

func (o *EditRequest) Validate() error

type EditResponse 

type EditResponse struct {
	Affects int64  `json:"affects" mock:"1" label:"Updated count"`
	Id      int    `json:"id" mock:"1" label:"Task id"`
	Title   string `json:"title" mock:"Example task" label:"Task name"`
}

type EditStatus 

type EditStatus struct {
	Id int `json:"id" validate:"required,gte=1" mock:"1" label:"任务ID"`
}

type EditSubscriber 

type EditSubscriber struct {
	Id           int     `json:"id" validate:"required,gte=1" mock:"1" label:"Task id"`
	Handler      *string `` /* 172-byte string literal not displayed */
	Condition    *string `` /* 147-byte string literal not displayed */
	IgnoreCodes  *string `` /* 244-byte string literal not displayed */
	Method       *string `json:"method" label:"Deliver method" desc:"Request method when delivering message. <br />Default: POST"`
	ResponseType *int    `` /* 215-byte string literal not displayed */
	Timeout      *int    `json:"timeout" mock:"10" label:"Timeout" desc:"If response not returned within specified seconds."`
}

func (*EditSubscriber) OverrideFailed 

func (o *EditSubscriber) OverrideFailed(x *models.Task)

func (*EditSubscriber) OverrideHandler 

func (o *EditSubscriber) OverrideHandler(x *models.Task)

func (*EditSubscriber) OverrideSucceed 

func (o *EditSubscriber) OverrideSucceed(x *models.Task)

func (*EditSubscriber) Validate 

func (o *EditSubscriber) Validate() error

type EditSucceed 

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

func NewEditSucceed 

func NewEditSucceed() *EditSucceed

func (*EditSucceed) Run 

func (o *EditSucceed) Run(ctx context.Context, i iris.Context) (res interface{})

func (*EditSucceed) Send 

func (o *EditSucceed) Send(ctx context.Context) (code int, err error)

type RemoteBuild 

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

func NewRemoteBuild 

func NewRemoteBuild() *RemoteBuild

func (*RemoteBuild) Run 

func (o *RemoteBuild) Run(ctx context.Context, i iris.Context) (res interface{})

func (*RemoteBuild) Send 

func (o *RemoteBuild) Send(ctx context.Context) (code int, err error)

type RemoteBuildRequest 

type RemoteBuildRequest struct {
	Id int `json:"id" validate:"required,gte=1" mock:"1" label:"Task ID"`
}

type RemoteBuildResponse 

type RemoteBuildResponse struct {
	Id    int    `json:"id" mock:"1" label:"Task ID"`
	Title string `json:"title" mock:"Task name" label:"Task name"`
}

type RemoteDestroy 

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

func NewRemoteDestroy 

func NewRemoteDestroy() *RemoteDestroy

func (*RemoteDestroy) Run 

func (o *RemoteDestroy) Run(ctx context.Context, i iris.Context) (res interface{})

func (*RemoteDestroy) Send 

func (o *RemoteDestroy) Send(ctx context.Context) (code int, err error)

type RemoteDestroyRequest 

type RemoteDestroyRequest struct {
	Id int `json:"id" validate:"required,gte=1" mock:"1" label:"Task ID"`
}

type RemoteDestroyResponse 

type RemoteDestroyResponse struct {
	Id    int    `json:"id" mock:"1" label:"Task ID"`
	Title string `json:"title" mock:"Task name" label:"Task name"`
}

Source Files

View all Source files

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.