add syslog support in webhook mock

Author: LinuxSuRen

docs/site/content/zh/latest/tasks/mock.md

@@ -196,4 +196,11 @@ proxies:
 
 当前代理支持 HTTP 和 TCP 协议，上面的例子中代理了 MySQL 的 `33060` 端口。
 
+## Webhook
+
+有些场景下，需要定时向服务器发送请求，这时可以使用 Webhook。当前支持的协议包括：
+
+* HTTP
+* Syslog
+
 > 更多 URL 中通配符的用法，请参考 https://github.com/gorilla/mux

docs/site/content/zh/latest/tasks/mock/webhook-syslog.yaml

@@ -0,0 +1,11 @@
+webhooks:
+  - timer: 3s
+    name: syslog
+    request:
+      protocol: syslog
+      path: 192.168.123.58:5140
+      body: |
+        {
+            "level": "{{ randEnum "FATAL" "ERROR" "WARNING" "INFO" }}",
+            "message": "{{ randAlphaNum 10 }}"
+        }

pkg/mock/in_memory.go

@@ -508,8 +508,6 @@ func (s *inMemoryServer) startWebhook(webhook *Webhook) (err error) {
 }
 
 func runWebhook(ctx context.Context, objCtx interface{}, wh *Webhook) (err error) {
-	client := http.DefaultClient
-
 	rawParams := make(map[string]string, len(wh.Param))
 	paramKeys := make([]string, 0, len(wh.Param))
 	for k, v := range wh.Param {
@@ -533,14 +531,34 @@ func runWebhook(ctx context.Context, objCtx interface{}, wh *Webhook) (err error
 	}
 	wh.Param = rawParams
 
-	method := util.EmptyThenDefault(wh.Request.Method, http.MethodPost)
 	var api string
 	api, err = render.Render("webhook request api", wh.Request.Path, objCtx)
 	if err != nil {
 		err = fmt.Errorf("error when render api: %w, template: %s", err, wh.Request.Path)
 		return
 	}
 
+	switch wh.Request.Protocol {
+	case "syslog":
+		err = sendSyslogWebhookRequest(ctx, wh, api, payload)
+	default:
+		err = sendHTTPWebhookRequest(ctx, wh, api, payload)
+	}
+	return
+}
+
+func sendSyslogWebhookRequest(ctx context.Context, wh *Webhook, api string, payload io.Reader) (err error) {
+	var conn net.Conn
+	if conn, err = net.Dial("udp", api); err == nil {
+		_, err = io.Copy(conn, payload)
+	}
+	return
+}
+
+func sendHTTPWebhookRequest(ctx context.Context, wh *Webhook, api string, payload io.Reader) (err error) {
+	method := util.EmptyThenDefault(wh.Request.Method, http.MethodPost)
+	client := http.DefaultClient
+
 	var bearerToken string
 	bearerToken, err = getBearerToken(ctx, wh.Request)
 	if err != nil {

pkg/mock/types.go

@@ -29,10 +29,11 @@ type Item struct {
 }
 
 type Request struct {
-	Path   string            `yaml:"path" json:"path"`
-	Method string            `yaml:"method" json:"method"`
-	Header map[string]string `yaml:"header" json:"header"`
-	Body   string            `yaml:"body" json:"body"`
+	Protocol string            `yaml:"protocol" json:"protocol"`
+	Path     string            `yaml:"path" json:"path"`
+	Method   string            `yaml:"method" json:"method"`
+	Header   map[string]string `yaml:"header" json:"header"`
+	Body     string            `yaml:"body" json:"body"`
 }
 
 type RequestWithAuth struct {