schedule

package

v0.20.0 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rulego/rulego

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Endpoint
type RequestMessage
type ResponseMessage
type Schedule
- func New(ruleConfig types.Config) *Schedule

Constants ¶

View Source

const Type = "schedule"

Type 组件类型

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Endpoint ¶ added in v0.17.0

type Endpoint = Schedule

Endpoint 别名

type RequestMessage ¶

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

RequestMessage http请求消息

func (*RequestMessage) Body ¶

func (r *RequestMessage) Body() []byte

func (*RequestMessage) From ¶

func (r *RequestMessage) From() string

From 不提供获取来源

func (*RequestMessage) GetError ¶

func (r *RequestMessage) GetError() error

func (*RequestMessage) GetMsg ¶

func (r *RequestMessage) GetMsg() *types.RuleMsg

func (*RequestMessage) GetParam ¶

func (r *RequestMessage) GetParam(key string) string

GetParam 不提供获取参数

func (*RequestMessage) Headers ¶

func (r *RequestMessage) Headers() textproto.MIMEHeader

func (*RequestMessage) SetBody ¶

func (r *RequestMessage) SetBody(body []byte)

func (*RequestMessage) SetError ¶

func (r *RequestMessage) SetError(err error)

func (*RequestMessage) SetMsg ¶

func (r *RequestMessage) SetMsg(msg *types.RuleMsg)

func (*RequestMessage) SetStatusCode ¶

func (r *RequestMessage) SetStatusCode(statusCode int)

SetStatusCode 不提供设置状态码

type ResponseMessage ¶

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

ResponseMessage 响应消息

func (*ResponseMessage) Body ¶

func (r *ResponseMessage) Body() []byte

func (*ResponseMessage) From ¶

func (r *ResponseMessage) From() string

From 不提供获取来源

func (*ResponseMessage) GetError ¶

func (r *ResponseMessage) GetError() error

func (*ResponseMessage) GetMsg ¶

func (r *ResponseMessage) GetMsg() *types.RuleMsg

func (*ResponseMessage) GetParam ¶

func (r *ResponseMessage) GetParam(key string) string

GetParam 不提供获取参数

func (*ResponseMessage) Headers ¶

func (r *ResponseMessage) Headers() textproto.MIMEHeader

func (*ResponseMessage) SetBody ¶

func (r *ResponseMessage) SetBody(body []byte)

func (*ResponseMessage) SetError ¶

func (r *ResponseMessage) SetError(err error)

func (*ResponseMessage) SetMsg ¶

func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)

func (*ResponseMessage) SetStatusCode ¶

func (r *ResponseMessage) SetStatusCode(statusCode int)

SetStatusCode 不提供设置状态码

type Schedule ¶

type Schedule struct {
	endpoint.BaseEndpoint
	RuleConfig types.Config
	// contains filtered or unexported fields
}

Schedule 定时任务端点

func New ¶

func New(ruleConfig types.Config) *Schedule

New 创建一个新的Schedule Endpoint 实例

func (*Schedule) AddRouter ¶ added in v0.17.0

func (schedule *Schedule) AddRouter(router *endpoint.Router, params ...interface{}) (string, error)

func (*Schedule) Close ¶

func (schedule *Schedule) Close() error

func (*Schedule) Destroy ¶

func (schedule *Schedule) Destroy()

Destroy 销毁

func (*Schedule) Id ¶

func (schedule *Schedule) Id() string

func (*Schedule) Init ¶

func (schedule *Schedule) Init(ruleConfig types.Config, configuration types.Configuration) error

Init 初始化

func (*Schedule) New ¶

func (schedule *Schedule) New() types.Node

func (*Schedule) Printf ¶

func (schedule *Schedule) Printf(format string, v ...interface{})

func (*Schedule) RemoveRouter ¶ added in v0.17.0

func (schedule *Schedule) RemoveRouter(routeId string, params ...interface{}) error

func (*Schedule) Start ¶

func (schedule *Schedule) Start() error

func (*Schedule) Type ¶

func (schedule *Schedule) Type() string

Type 组件类型

Source Files ¶

View all Source files

schedule.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL