diff --git a/apidocs/cloud-api-source/source/includes/dockercloud-events.md b/apidocs/cloud-api-source/source/includes/dockercloud-events.md index 28f5132500..c636dd25f3 100644 --- a/apidocs/cloud-api-source/source/includes/dockercloud-events.md +++ b/apidocs/cloud-api-source/source/includes/dockercloud-events.md @@ -83,17 +83,23 @@ events.run_forever() ```go import "github.com/docker/go-dockercloud/dockercloud" -c := make(chan dockercloud.Event) -e := make(chan error) +// Listens for container events only +myFilter := dockercloud.NewStreamFilter(&dockercloud.EventFilter{Type: "container"}) -go dockercloud.Events(c, e) +stream := dockercloud.NewStream(myFilter) + +if err := stream.Connect(); err == nil { + go stream.RunForever() +} else { + log.Print("Connect err: " + err.Error()) +} for { select { - case event := <-c: - log.Println(event) - case err := <-e: - log.Println(err) + case event := <-stream.MessageChan: + log.Println(event) + case err := <-stream.ErrorChan: + log.Println(err) } } ``` @@ -119,3 +125,11 @@ Available in Docker Cloud's **STREAM API** ### HTTP Request `GET /api/audit/v1/[optional_namespace/]events/` + +### Query Parameters + +Parameter | Description +--------- | ----------- +type | Filter by type +object | Filter by object resource URI +parent | Filter by object parents diff --git a/apidocs/docker-cloud/includes/dockercloud-events.html b/apidocs/docker-cloud/includes/dockercloud-events.html index 2305dd0d74..ef08ecbf80 100644 --- a/apidocs/docker-cloud/includes/dockercloud-events.html +++ b/apidocs/docker-cloud/includes/dockercloud-events.html @@ -189,17 +189,23 @@ 
import "github.com/docker/go-dockercloud/dockercloud"
 
-c := make(chan dockercloud.Event)
-e := make(chan error)
+// Listens for container events only
+myFilter := dockercloud.NewStreamFilter(&dockercloud.EventFilter{Type: "container"})
 
-go dockercloud.Events(c, e)
+stream := dockercloud.NewStream(myFilter)
+
+if err := stream.Connect(); err == nil {
+    go stream.RunForever()
+} else {
+    log.Print("Connect err: " + err.Error())
+}
 
 for {
     select {
-        case event := <-c:
-            log.Println(event)
-        case err := <-e:
-            log.Println(err)
+    case event := <-stream.MessageChan:
+        log.Println(event)
+    case err := <-stream.ErrorChan:
+        log.Println(err)
     }
 }
@@ -222,6 +228,28 @@

GET /api/audit/v1/[optional_namespace/]events/

+

Query Parameters

+ + + + + + + + + + + + + + + + + + + +
ParameterDescription
typeFilter by type
objectFilter by object resource URI
parentFilter by object parents
+
diff --git a/apidocs/docker-cloud/index.html b/apidocs/docker-cloud/index.html index 69bcf5f5d3..be85de4a8d 100644 --- a/apidocs/docker-cloud/index.html +++ b/apidocs/docker-cloud/index.html @@ -6427,17 +6427,23 @@ container.execute("ls", handler=msg_handler) 
import "github.com/docker/go-dockercloud/dockercloud"
 
-c := make(chan dockercloud.Event)
-e := make(chan error)
+// Listens for container events only
+myFilter := dockercloud.NewStreamFilter(&dockercloud.EventFilter{Type: "container"})
 
-go dockercloud.Events(c, e)
+stream := dockercloud.NewStream(myFilter)
+
+if err := stream.Connect(); err == nil {
+    go stream.RunForever()
+} else {
+    log.Print("Connect err: " + err.Error())
+}
 
 for {
     select {
-        case event := <-c:
-            log.Println(event)
-        case err := <-e:
-            log.Println(err)
+    case event := <-stream.MessageChan:
+        log.Println(event)
+    case err := <-stream.ErrorChan:
+        log.Println(err)
     }
 }
@@ -6460,6 +6466,28 @@ container.execute("ls", handler=msg_handler)

GET /api/audit/v1/[optional_namespace/]events/

+

Query Parameters

+ + + + + + + + + + + + + + + + + + + +
ParameterDescription
typeFilter by type
objectFilter by object resource URI
parentFilter by object parents
+

Errors

diff --git a/apidocs/layouts/single.html b/apidocs/layouts/single.html index 69bcf5f5d3..be85de4a8d 100644 --- a/apidocs/layouts/single.html +++ b/apidocs/layouts/single.html @@ -6427,17 +6427,23 @@ container.execute("ls", handler=msg_handler) 
import "github.com/docker/go-dockercloud/dockercloud"
 
-c := make(chan dockercloud.Event)
-e := make(chan error)
+// Listens for container events only
+myFilter := dockercloud.NewStreamFilter(&dockercloud.EventFilter{Type: "container"})
 
-go dockercloud.Events(c, e)
+stream := dockercloud.NewStream(myFilter)
+
+if err := stream.Connect(); err == nil {
+    go stream.RunForever()
+} else {
+    log.Print("Connect err: " + err.Error())
+}
 
 for {
     select {
-        case event := <-c:
-            log.Println(event)
-        case err := <-e:
-            log.Println(err)
+    case event := <-stream.MessageChan:
+        log.Println(event)
+    case err := <-stream.ErrorChan:
+        log.Println(err)
     }
 }
@@ -6460,6 +6466,28 @@ container.execute("ls", handler=msg_handler)

GET /api/audit/v1/[optional_namespace/]events/

+

Query Parameters

+ + + + + + + + + + + + + + + + + + + +
ParameterDescription
typeFilter by type
objectFilter by object resource URI
parentFilter by object parents
+

Errors