客户端：http 客户端

[flycash]

在我们的设计里面，调度节点可以通过 HTTP 调用触发任务。那么如果我们要求用户自己手写 HTTP 接口也是可以的。但是很多用户可能会比较不耐烦，所以我们进一步提供客户端。

这个客户端提供以下接口：

• 注册任务。注册之后，当收到 HTTP POST 请求的时候，客户端会直接的从注册的任务里面找到，执行调度；
• 返回状态。如果后续收到 GET 请求的，客户端会找到注册的任务，返回执行的状态
• 停止任务。收到 DELETE 请求，客户端会停下当次执行

你需要提供的基本实现是：

type Registry struct {
    Registry(t Task)
}
// 允许用户指定路径，比如说有些用户用 /task/$name
// 有些用户使用 /aaa/bbb/ccc/$name
// name 就是某个任务的名字
type HttpClient struct {
   Registry
// 这个是返回一个 mutex，这样的话用户可以拿去自己启动，决定监听的端口
// mutex := client.HttpMutex()
// http.ListenAndServe(":8080", mutex)
    HttpMutex() http.Mutex
}

type Task interface {
    Execute()
    Stop()
    Status()
    Name()
}

[flycash]

task 接口是给用户用的，他们提供实现

[flycash]

Mutex 里面注册 POST，GET 和 DELETE 三个路由。不能使用 GIN 之类的接口。

[flycash]

在根目录下新建一个 client 的包，项目结构是：
ecron/client/http

[Jared-lu]

大体上是不是这样子？
`
// 我的实现
type Registry struct {
tasks []Task
}

func (s *Registry) Register(t Task) {
s.tasks = append(s.tasks, t)
}

type Client struct {
Registry
prefix string
}

func (c *Client) HttpMutex() http.Handler {
handler := http.NewServeMux()
handler.HandleFunc("/$prefix/$TaskName", func(w http.ResponseWriter, r *http.Request) {
// Post => t.Execute()
// GET => t.Status()
// DELETE => Stop()
})
return handler
}

// 用户使用
r:=new(Registry)
r.Register(t)
client:=NewHttpClient(r)
mutex:=client.HttpMutex()
http.ListenAndServe(":8080", mutex)
`

[flycash]

对