Your task definition is where you'll perform your tasks, such as sending emails,
processing files, or moving data between systems.With Mergent, tasks are defined by HTTP request handlers inside your
application.
main.go
Copy
package mainimport ( "log" "github.com/gin-gonic/gin")func main() { r := gin.Default() r.POST("/api/tasks", func(c *gin.Context) { body, _ := c.GetRawData() err := performTask(string(body)) if err != nil { // task failed, respond with 500 so Mergent will retry c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) return } // task was successful, respond with 200 c.Status(http.StatusOK) }) r.Run(":3000")}func performTask(body string) error { // This is where you'll perform your task. // For now, we'll just log it. log.Println("Performing task: ", body) return nil}
For a list of all the available parameters, visit the API
Reference.
Before you can run your task, your handler must be accessible from the internet.To do this, you can use a tool like ngrok, or deploy your
application to a platform like Vercel or Render.For more information, see our guide to localhost dev &
webhooks.
Once your task handler is reachable via a URL, you can create your first task.
Go to the Mergent Tasks Dashboard and click the
Create button.
In this step, you'll set the Request URL to your task handler's URL. You'll also
provide the required parameters (in the request body) for your handler to carry
out the task.
Typically, developers use a type parameter to distinguish between different
tasks. This allows your task handler to route and process tasks accordingly.
Feel free to structure your parameters in a way that works best for your
application.
Click Create to queue the task. Once the task executes, you should see the
related log in your console, indicating a successful run. 🎊
Create a task whenever you need to. For example, you might create a task
any time a user signs up.Use the URL of the task definition you'd like to run.
Copy
package mainimport ( "bytes" "encoding/json" "io" "log" "net/http")func main() { // set the Mergent API key apiKey := "..." // create a task // the URL should be set to the URL of your task handler task := struct { Request struct { URL string `json:"url"` Body string `json:"body"` } `json:"request"` }{ Request: struct { URL string `json:"url"` Body string `json:"body"` }{ URL: "...", Body: "Hello, world!", }, } taskJSON, _ := json.Marshal(task) req, err := http.NewRequest(http.MethodPost, "https://api.mergent.io/tasks", bytes.NewBuffer(taskJSON)) if err != nil { log.Fatalln(err) } req.Header.Add("Authorization", "Bearer "+apiKey) client := &http.Client{} res, err := client.Do(req) if err != nil { log.Fatalln(err) } defer res.Body.Close() if res.StatusCode != http.StatusCreated { log.Fatalln("Failed to create task") } resBody, _ := io.Readall(res.Body) var resTask map[string]any if err := json.Unmarshal(resBody, &resTask); err != nil { log.Fatalln(err) } log.Println(resTask)}
You can now create a task any time you'd like to perform some work in the
background. 🎊