added stop push and fix body interface{}

ovenmedia/ovenmedia.go

@@ -20,7 +20,9 @@ type IOvenMediaClient interface {
 	CreateVirtualHost(name string) (*ResponseVirtualHost, error)
 	GetAllVirtualHosts() (*ResponseVirtualList, error)
 	// Push
-	StartPush(vHost string, appName string) (*resty.Response, error)
+	StartPush(vHost string, appName string, body interface{}) (*resty.Response, error)
+	StopPush(vHost string, appName string, body interface{}) (*resty.Response, error)
+	// Recording
 }
 
 func (o *OvenMedia) HealthCheck() error {

ovenmedia/push.go

@@ -7,12 +7,24 @@ import (
 )
 
 // POST http://1.2.3.4:8081/v1/vhosts/default/apps/app:startPush
-func (o *OvenMedia) StartPush(vHost string, appName string) (*resty.Response, error) {
+func (o *OvenMedia) StartPush(vHost string, appName string, body interface{}) (*resty.Response, error) {
 	//
+    //
 	resp, err := o.RestyPost(GET_VHOSTS_PUSH_BY_NAME(vHost, appName), nil)
 	if err != nil {
 		return nil, err
 	}
 	fmt.Println("resp", resp)
 	return resp, nil
 }
+
+
+func (o *OvenMedia) StopPush(vHost string, appName string,body interface{}) (*resty.Response, error)
+	//
+	resp, err := o.RestyPost(V1_HOSTS_STOP_PUSH_NAME(vHost, appName), body)
+	if err != nil {
+		return nil, err
+	}
+	fmt.Println("resp", resp)
+	return resp, nil
+}

ovenmedia/recording.go

@@ -0,0 +1,16 @@
+package ovenmedia
+
+/*
+{
+  "id": "custom_id",
+  "stream": {
+    "name": "stream_o",
+    "tracks": [ 100, 200 ]
+  },
+  "filePath" : "/path/to/save/recorded/file_${Sequence}.ts",
+  "infoPath" : "/path/to/save/information/file.xml",
+  "interval" : 60000,    # Split it every 60 seconds
+  "schedule" : "0 0 1" # Split it at second 0, minute 0, every hours. 
+  "segmentationRule" : "continuity"
+
+}*/