unix+http protocol

1 files changed, 10 insertions, 0 deletions

diff --git a/part.go b/part.go
index 5ad5867..6a399fe 100644
--- a/part.go
+++ b/part.go
@@ -51,6 +51,16 @@ func PartFromArg(arg string, re map[string]*[]*relabel.Config) (Part, error){
                     Transforms: tf,
                     Source: s,
                 }, nil
+            }else if arg[0:sp] == "unix+http"{
+                s, err := NewUnixHttpSource(arg)
+                if err != nil{
+                    return Part{}, err
+                }
+                return Part{
+                    Name: namef(arg),
+                    Transforms: tf,
+                    Source: s,
+                }, nil
             }else if arg[0:sp] == "file"{
                 fn := arg[sp+1:]
                 if strings.HasPrefix(fn, "//"){