fix pull request #194.

  - Replace [jianliao] with [talk].
  - Remove change with Sensu.
  - Remove level parameter.
  - Add a blurb on how to create Talk webhook.

alert.go

@@ -715,7 +715,6 @@ func (a *AlertNode) handleTalk(talk *pipeline.TalkHandler, ad *AlertData) {
 	err := a.et.tm.TalkService.Alert(
 		ad.ID,
 		ad.Message,
-		ad.Level,
 	)
 	if err != nil {
 		a.logger.Println("E! failed to send alert data to Talk:", err)

cmd/kapacitord/run/server.go

@@ -392,7 +392,7 @@ func (s *Server) appendReportingService(c reporting.Config) {
 
 func (s *Server) appendTalkService(c talk.Config) {
 	if c.Enabled {
-		l := s.LogService.NewLogger("[jiaoliao] ", log.LstdFlags)
+		l := s.LogService.NewLogger("[talk] ", log.LstdFlags)
 		srv := talk.NewService(c, l)
 		s.TaskMaster.TalkService = srv
 

pipeline/alert.go

@@ -676,7 +676,7 @@ func (a *AlertNode) Sensu() *SensuHandler {
 	return sensu
 }
 
-// tick:embedded:AlertNode.SensuHandler
+// tick:embedded:AlertNode.Sensu
 type SensuHandler struct {
 	*AlertNode
 }
@@ -837,6 +837,15 @@ func (og *OpsGenieHandler) Recipients(recipients ...string) *OpsGenieHandler {
 }
 
 // Send the alert to Talk.
+// To use Talk alerting you must first follow the steps to create a new incoming webhook.
+//
+//    1. Go to the URL https:/account.jianliao.com/signin.
+//    2. Sign in with you account. under the Team tab, click "Integrations".
+//    3. Select "Customize service", click incoming Webhook "Add" button.
+//    4. After choose the topic to connect with "xxx", click "Confirm Add" button.
+//    5. Once the service is created, you'll see the "Generate Webhook url".
+//
+// Place the 'Generate Webhook url' into the 'Talk' section of the Kapacitor configuration as the option 'url'.
 //
 // Example:
 //    [talk]

services/talk/service.go

@@ -6,8 +6,6 @@ import (
 	"errors"
 	"log"
 	"net/http"
-
-	"github.com/influxdata/kapacitor"
 )
 
 type Service struct {
@@ -32,7 +30,7 @@ func (s *Service) Close() error {
 	return nil
 }
 
-func (s *Service) Alert(title, text string, level kapacitor.AlertLevel) error {
+func (s *Service) Alert(title, text string) error {
 	postData := make(map[string]interface{})
 	postData["title"] = title
 	postData["text"] = text

task_master.go

@@ -76,7 +76,7 @@ type TaskMaster struct {
 		Alert(name, output string, level AlertLevel) error
 	}
 	TalkService interface {
-		Alert(name, output string, level AlertLevel) error
+		Alert(title, text string) error
 	}
 	LogService LogService