From 95e58b32cbced9101d7bb981e17814a0c667bade Mon Sep 17 00:00:00 2001 From: Tom Wilkie Date: Fri, 4 Dec 2015 12:50:33 +0000 Subject: [PATCH] Update experimental/ --- experimental/demoprobe/main.go | 8 ++++++-- experimental/fixprobe/main.go | 8 ++++++-- 2 files changed, 12 insertions(+), 4 deletions(-) diff --git a/experimental/demoprobe/main.go b/experimental/demoprobe/main.go index a3d557ef8..613966f2a 100644 --- a/experimental/demoprobe/main.go +++ b/experimental/demoprobe/main.go @@ -23,11 +23,15 @@ func main() { ) flag.Parse() - _, publisher, err := xfer.NewHTTPPublisher(*publish, *publish, "demoprobe", "demoprobe", false) + client, err := xfer.NewAppClient(xfer.ProbeConfig{ + Token: "demoprobe", + ProbeID: "demoprobe", + Insecure: false, + }, *publish, *publish) if err != nil { log.Fatal(err) } - rp := xfer.NewReportPublisher(publisher) + rp := xfer.NewReportPublisher(client) rand.Seed(time.Now().UnixNano()) for range time.Tick(*publishInterval) { diff --git a/experimental/fixprobe/main.go b/experimental/fixprobe/main.go index b253f79bc..78a70d442 100644 --- a/experimental/fixprobe/main.go +++ b/experimental/fixprobe/main.go @@ -34,12 +34,16 @@ func main() { } f.Close() - _, publisher, err := xfer.NewHTTPPublisher(*publish, *publish, "fixprobe", "fixprobe", false) + client, err := xfer.NewAppClient(xfer.ProbeConfig{ + Token: "fixprobe", + ProbeID: "fixprobe", + Insecure: false, + }, *publish, *publish) if err != nil { log.Fatal(err) } - rp := xfer.NewReportPublisher(publisher) + rp := xfer.NewReportPublisher(client) for range time.Tick(*publishInterval) { rp.Publish(fixedReport) }