mirror of
https://github.com/weaveworks/scope.git
synced 2026-03-02 17:50:39 +00:00
Update experimental/
This commit is contained in:
@@ -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) {
|
||||
|
||||
@@ -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)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user