diff --git a/pkg/goc/coder/avro/avro.coder.fixtures/user.go b/coder/avro/avro.coder.fixtures/user.go similarity index 100% rename from pkg/goc/coder/avro/avro.coder.fixtures/user.go rename to coder/avro/avro.coder.fixtures/user.go diff --git a/pkg/goc/coder/avro/decoder.go b/coder/avro/decoder.go similarity index 98% rename from pkg/goc/coder/avro/decoder.go rename to coder/avro/decoder.go index f5cc86e..123940b 100644 --- a/pkg/goc/coder/avro/decoder.go +++ b/coder/avro/decoder.go @@ -22,7 +22,7 @@ package avro import ( "encoding/binary" "github.com/amient/avro" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/avro/encoder.go b/coder/avro/encoder.go similarity index 98% rename from pkg/goc/coder/avro/encoder.go rename to coder/avro/encoder.go index 0148a2d..8230d21 100644 --- a/pkg/goc/coder/avro/encoder.go +++ b/coder/avro/encoder.go @@ -23,7 +23,7 @@ import ( "bytes" "encoding/binary" "github.com/amient/avro" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/avro/projector.go b/coder/avro/projector.go similarity index 100% rename from pkg/goc/coder/avro/projector.go rename to coder/avro/projector.go diff --git a/pkg/goc/coder/avro/types.go b/coder/avro/types.go similarity index 100% rename from pkg/goc/coder/avro/types.go rename to coder/avro/types.go diff --git a/pkg/goc/coder/gzip/decoder.go b/coder/gzip/decoder.go similarity index 93% rename from pkg/goc/coder/gzip/decoder.go rename to coder/gzip/decoder.go index 201f66c..580ae73 100644 --- a/pkg/goc/coder/gzip/decoder.go +++ b/coder/gzip/decoder.go @@ -3,7 +3,7 @@ package gzip import ( "bytes" "compress/gzip" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/gzip/encoder.go b/coder/gzip/encoder.go similarity index 100% rename from pkg/goc/coder/gzip/encoder.go rename to coder/gzip/encoder.go diff --git a/pkg/goc/coder/kv/decoder.go b/coder/kv/decoder.go similarity index 96% rename from pkg/goc/coder/kv/decoder.go rename to coder/kv/decoder.go index a5c6ac7..6623a69 100644 --- a/pkg/goc/coder/kv/decoder.go +++ b/coder/kv/decoder.go @@ -20,7 +20,7 @@ package kv import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/kv/encoder.go b/coder/kv/encoder.go similarity index 96% rename from pkg/goc/coder/kv/encoder.go rename to coder/kv/encoder.go index 1edfc2e..1c09cb9 100644 --- a/pkg/goc/coder/kv/encoder.go +++ b/coder/kv/encoder.go @@ -20,7 +20,7 @@ package kv import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/registry.go b/coder/registry.go similarity index 53% rename from pkg/goc/coder/registry.go rename to coder/registry.go index 23efc27..d1db200 100644 --- a/pkg/goc/coder/registry.go +++ b/coder/registry.go @@ -1,11 +1,11 @@ package coder import ( - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder/kv" - "github.com/amient/goconnect/pkg/goc/coder/str" - "github.com/amient/goconnect/pkg/goc/coder/url" - "github.com/amient/goconnect/pkg/goc/coder/xml" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder/kv" + "github.com/amient/goconnect/coder/str" + "github.com/amient/goconnect/coder/url" + "github.com/amient/goconnect/coder/xml" ) func Registry() []goc.Transform { diff --git a/pkg/goc/coder/str/decoder.go b/coder/str/decoder.go similarity index 96% rename from pkg/goc/coder/str/decoder.go rename to coder/str/decoder.go index cb034f8..441871e 100644 --- a/pkg/goc/coder/str/decoder.go +++ b/coder/str/decoder.go @@ -20,7 +20,7 @@ package str import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/str/encoder.go b/coder/str/encoder.go similarity index 96% rename from pkg/goc/coder/str/encoder.go rename to coder/str/encoder.go index 51c3a28..d8c466f 100644 --- a/pkg/goc/coder/str/encoder.go +++ b/coder/str/encoder.go @@ -20,7 +20,7 @@ package str import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/str/splitter.go b/coder/str/splitter.go similarity index 97% rename from pkg/goc/coder/str/splitter.go rename to coder/str/splitter.go index 014fe69..d07026b 100644 --- a/pkg/goc/coder/str/splitter.go +++ b/coder/str/splitter.go @@ -20,7 +20,7 @@ package str import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" "strings" ) diff --git a/pkg/goc/coder/url/decoder.go b/coder/url/decoder.go similarity index 94% rename from pkg/goc/coder/url/decoder.go rename to coder/url/decoder.go index 535568b..d70306a 100644 --- a/pkg/goc/coder/url/decoder.go +++ b/coder/url/decoder.go @@ -22,8 +22,8 @@ package url import ( "bytes" "encoding/binary" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/util" + "github.com/amient/goconnect" + "github.com/amient/goconnect/util" "reflect" ) diff --git a/pkg/goc/coder/url/encoder.go b/coder/url/encoder.go similarity index 94% rename from pkg/goc/coder/url/encoder.go rename to coder/url/encoder.go index c86c180..0419e58 100644 --- a/pkg/goc/coder/url/encoder.go +++ b/coder/url/encoder.go @@ -22,8 +22,8 @@ package url import ( "bytes" "encoding/binary" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/util" + "github.com/amient/goconnect" + "github.com/amient/goconnect/util" "reflect" ) diff --git a/pkg/goc/coder/url/url.go b/coder/url/url.go similarity index 100% rename from pkg/goc/coder/url/url.go rename to coder/url/url.go diff --git a/pkg/goc/coder/xml/NOTICE b/coder/xml/NOTICE similarity index 100% rename from pkg/goc/coder/xml/NOTICE rename to coder/xml/NOTICE diff --git a/pkg/goc/coder/xml/decoder.go b/coder/xml/decoder.go similarity index 97% rename from pkg/goc/coder/xml/decoder.go rename to coder/xml/decoder.go index 8e4ca1a..0aa2e3b 100644 --- a/pkg/goc/coder/xml/decoder.go +++ b/coder/xml/decoder.go @@ -21,7 +21,7 @@ package xml import ( "bytes" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/xml/encoder.go b/coder/xml/encoder.go similarity index 97% rename from pkg/goc/coder/xml/encoder.go rename to coder/xml/encoder.go index 23a3644..b143e3f 100644 --- a/pkg/goc/coder/xml/encoder.go +++ b/coder/xml/encoder.go @@ -22,7 +22,7 @@ package xml import ( "bufio" "bytes" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/coder/xml/node.go b/coder/xml/node.go similarity index 100% rename from pkg/goc/coder/xml/node.go rename to coder/xml/node.go diff --git a/pkg/goc/coder/xml/reader.go b/coder/xml/reader.go similarity index 100% rename from pkg/goc/coder/xml/reader.go rename to coder/xml/reader.go diff --git a/pkg/goc/coder/xml/writer.go b/coder/xml/writer.go similarity index 98% rename from pkg/goc/coder/xml/writer.go rename to coder/xml/writer.go index ae9caff..a1f90fa 100644 --- a/pkg/goc/coder/xml/writer.go +++ b/coder/xml/writer.go @@ -21,7 +21,7 @@ package xml import ( "fmt" - "github.com/amient/goconnect/pkg/goc/util" + "github.com/amient/goconnect/util" "io" ) diff --git a/pkg/goc/context.go b/context.go similarity index 99% rename from pkg/goc/context.go rename to context.go index 06afe90..e1c01b6 100644 --- a/pkg/goc/context.go +++ b/context.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "fmt" diff --git a/pkg/goc/def.go b/def.go similarity index 99% rename from pkg/goc/def.go rename to def.go index 9becee7..12e2a86 100644 --- a/pkg/goc/def.go +++ b/def.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "reflect" diff --git a/pkg/goc/element.go b/element.go similarity index 99% rename from pkg/goc/element.go rename to element.go index c4fcc12..01dde10 100644 --- a/pkg/goc/element.go +++ b/element.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect /** Checkpoint is a map of int identifiers and values. The identifiers are specific to each transform, some diff --git a/examples/amqp-kafka/main.go b/examples/amqp-kafka/main.go index a704387..456f7b1 100644 --- a/examples/amqp-kafka/main.go +++ b/examples/amqp-kafka/main.go @@ -21,10 +21,10 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io/amqp09" - "github.com/amient/goconnect/pkg/goc/io/kafka1" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io/amqp09" + "github.com/amient/goconnect/io/kafka1" "github.com/confluentinc/confluent-kafka-go/kafka" ) diff --git a/examples/kafka-count-stdout/main.go b/examples/kafka-count-stdout/main.go index 0993783..5cc0492 100644 --- a/examples/kafka-count-stdout/main.go +++ b/examples/kafka-count-stdout/main.go @@ -21,10 +21,10 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io/kafka1" - "github.com/amient/goconnect/pkg/goc/io/std" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io/kafka1" + "github.com/amient/goconnect/io/std" "github.com/confluentinc/confluent-kafka-go/kafka" "time" ) diff --git a/examples/kafka-custom-avro-stdout/main.go b/examples/kafka-custom-avro-stdout/main.go index 3eaf467..973165b 100644 --- a/examples/kafka-custom-avro-stdout/main.go +++ b/examples/kafka-custom-avro-stdout/main.go @@ -23,11 +23,11 @@ import ( "flag" "fmt" "github.com/amient/goconnect/examples/kafka-custom-avro-stdout/io.amient.kafka.metrics" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/avro" - "github.com/amient/goconnect/pkg/goc/io/kafka1" - "github.com/amient/goconnect/pkg/goc/io/std" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/avro" + "github.com/amient/goconnect/io/kafka1" + "github.com/amient/goconnect/io/std" "github.com/confluentinc/confluent-kafka-go/kafka" "reflect" ) diff --git a/examples/kafka-kafka/main.go b/examples/kafka-kafka/main.go index a117711..7ffec92 100644 --- a/examples/kafka-kafka/main.go +++ b/examples/kafka-kafka/main.go @@ -21,9 +21,9 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io/kafka1" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io/kafka1" "github.com/confluentinc/confluent-kafka-go/kafka" ) diff --git a/examples/kafka-sr-avro-json-sqs/main.go b/examples/kafka-sr-avro-json-sqs/main.go index 5cb7aa8..6a3f64a 100644 --- a/examples/kafka-sr-avro-json-sqs/main.go +++ b/examples/kafka-sr-avro-json-sqs/main.go @@ -21,11 +21,11 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/avro" - "github.com/amient/goconnect/pkg/goc/io/kafka1" - "github.com/amient/goconnect/pkg/goc/io/std" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/avro" + "github.com/amient/goconnect/io/kafka1" + "github.com/amient/goconnect/io/std" "github.com/confluentinc/confluent-kafka-go/kafka" avrolib "github.com/amient/avro" ) diff --git a/examples/kafka-sr1-avro-sr2-kafka/main.go b/examples/kafka-sr1-avro-sr2-kafka/main.go index 3df6a31..7446bf9 100644 --- a/examples/kafka-sr1-avro-sr2-kafka/main.go +++ b/examples/kafka-sr1-avro-sr2-kafka/main.go @@ -21,10 +21,10 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/avro" - "github.com/amient/goconnect/pkg/goc/io/kafka1" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/avro" + "github.com/amient/goconnect/io/kafka1" "github.com/confluentinc/confluent-kafka-go/kafka" avrolib "github.com/amient/avro" ) diff --git a/examples/list-amqp/main.go b/examples/list-amqp/main.go index fb39a95..33aadc2 100644 --- a/examples/list-amqp/main.go +++ b/examples/list-amqp/main.go @@ -21,10 +21,10 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io" - "github.com/amient/goconnect/pkg/goc/io/amqp09" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io" + "github.com/amient/goconnect/io/amqp09" ) var ( diff --git a/examples/list-avro-sr-kafka/main.go b/examples/list-avro-sr-kafka/main.go index de0a11d..e187c2e 100644 --- a/examples/list-avro-sr-kafka/main.go +++ b/examples/list-avro-sr-kafka/main.go @@ -21,11 +21,11 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/avro" - "github.com/amient/goconnect/pkg/goc/io" - "github.com/amient/goconnect/pkg/goc/io/kafka1" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/avro" + "github.com/amient/goconnect/io" + "github.com/amient/goconnect/io/kafka1" "github.com/confluentinc/confluent-kafka-go/kafka" ) import avrolib "github.com/amient/avro" diff --git a/examples/list-kafka/main.go b/examples/list-kafka/main.go index 07896d1..1110e34 100644 --- a/examples/list-kafka/main.go +++ b/examples/list-kafka/main.go @@ -21,10 +21,10 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io" - "github.com/amient/goconnect/pkg/goc/io/kafka1" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io" + "github.com/amient/goconnect/io/kafka1" "github.com/confluentinc/confluent-kafka-go/kafka" ) diff --git a/examples/list-split-scatter-map-gather-stdout/main.go b/examples/list-split-scatter-map-gather-stdout/main.go index c55ad7e..1f029a4 100644 --- a/examples/list-split-scatter-map-gather-stdout/main.go +++ b/examples/list-split-scatter-map-gather-stdout/main.go @@ -21,12 +21,12 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/str" - "github.com/amient/goconnect/pkg/goc/io" - "github.com/amient/goconnect/pkg/goc/io/std" - "github.com/amient/goconnect/pkg/goc/network" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/str" + "github.com/amient/goconnect/io" + "github.com/amient/goconnect/io/std" + "github.com/amient/goconnect/network" "strings" ) diff --git a/examples/list-xml-filter-stdout/compare.go b/examples/list-xml-filter-stdout/compare.go index 4872314..7eb80d8 100644 --- a/examples/list-xml-filter-stdout/compare.go +++ b/examples/list-xml-filter-stdout/compare.go @@ -1,7 +1,7 @@ package main import ( - "github.com/amient/goconnect/pkg/goc/coder/xml" + "github.com/amient/goconnect/coder/xml" "log" "strings" "time" diff --git a/examples/list-xml-filter-stdout/main.go b/examples/list-xml-filter-stdout/main.go index 5033c3e..b559203 100644 --- a/examples/list-xml-filter-stdout/main.go +++ b/examples/list-xml-filter-stdout/main.go @@ -20,11 +20,11 @@ package main import ( - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/coder/xml" - "github.com/amient/goconnect/pkg/goc/io" - "github.com/amient/goconnect/pkg/goc/io/std" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/coder/xml" + "github.com/amient/goconnect/io" + "github.com/amient/goconnect/io/std" "strings" ) diff --git a/examples/localfs-subflow-localfs/main.go b/examples/localfs-subflow-localfs/main.go index 154edb0..f1c0f4e 100644 --- a/examples/localfs-subflow-localfs/main.go +++ b/examples/localfs-subflow-localfs/main.go @@ -21,11 +21,11 @@ package main import ( "flag" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder" - "github.com/amient/goconnect/pkg/goc/io/file" - "github.com/amient/goconnect/pkg/goc/io/std" - "github.com/amient/goconnect/pkg/goc/network" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder" + "github.com/amient/goconnect/io/file" + "github.com/amient/goconnect/io/std" + "github.com/amient/goconnect/network" "strings" ) diff --git a/pkg/goc/fn.go b/fn.go similarity index 99% rename from pkg/goc/fn.go rename to fn.go index 2149796..6973663 100644 --- a/pkg/goc/fn.go +++ b/fn.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "reflect" diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..df143d3 --- /dev/null +++ b/go.mod @@ -0,0 +1,10 @@ +module github.com/amient/goconnect + +go 1.12 + +require ( + github.com/amient/avro v0.4.8 + github.com/armon/go-metrics v0.0.0-20190430140413-ec5e00d3c878 // indirect + github.com/confluentinc/confluent-kafka-go v0.11.6 + gotest.tools/v3 v3.0.0 +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..42bc286 --- /dev/null +++ b/go.sum @@ -0,0 +1,37 @@ +github.com/DataDog/datadog-go v2.2.0+incompatible/go.mod h1:LButxg5PwREeZtORoXG3tL4fMGNddJ+vMq1mwgfaqoQ= +github.com/amient/avro v0.4.8/go.mod h1:PfrRH0jlz9J3UXfW1MgmBri7eiJEztRD6No7jEAvDpc= +github.com/amient/goconnect v0.0.0-20190219205912-0d71e2c4b86e h1:XJG/+xfPbt5k/dTF93KjPvH42RhaGYE69784CKkdiWE= +github.com/armon/go-metrics v0.0.0-20190430140413-ec5e00d3c878/go.mod h1:3AMJUQhVx52RsWOnlkpikZr01T/yAVN2gn0861vByNg= +github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= +github.com/circonus-labs/circonus-gometrics v2.3.1+incompatible/go.mod h1:nmEj6Dob7S7YxXgwXpfOuvO54S+tGdZdw9fuRZt25Ag= +github.com/circonus-labs/circonusllhist v0.1.3/go.mod h1:kMXHVDlOchFAehlya5ePtbp5jckzBHf4XRpQvBOLI+I= +github.com/confluentinc/confluent-kafka-go v0.11.6/go.mod h1:u2zNLny2xq+5rWeTQjFHbDzzNuba4P1vo31r9r4uAdg= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= +github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= +github.com/hashicorp/go-cleanhttp v0.5.0/go.mod h1:JpRdi6/HCYpAwUzNwuwqhbovhLtngrth3wmdIIUrZ80= +github.com/hashicorp/go-immutable-radix v1.0.0/go.mod h1:0y9vanUI8NX6FsYoO3zeMjhV/C5i9g4Q3DwcSNZ4P60= +github.com/hashicorp/go-retryablehttp v0.5.3/go.mod h1:9B5zBasrRhHXnJnui7y6sL7es7NDiJgTc6Er0maI1Xs= +github.com/hashicorp/go-uuid v1.0.0/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro= +github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8= +github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0= +github.com/pascaldekloe/goe v0.1.0/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc= +github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/prometheus/client_golang v0.9.2/go.mod h1:OsXs2jCmiKlQ1lTBmv21f2mNfw4xf/QclQDMrYNZzcM= +github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo= +github.com/prometheus/common v0.0.0-20181126121408-4724e9255275/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro= +github.com/prometheus/procfs v0.0.0-20181204211112-1dc9a6cbc91a/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk= +github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +github.com/tv42/httpunix v0.0.0-20150427012821-b75d8614f926/go.mod h1:9ESjWnEqriFuLhtthL60Sar/7RFoluCcXsuvEwTV5KM= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/net v0.0.0-20181201002055-351d144fa1fc/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= +golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/tools v0.0.0-20190624222133-a101b041ded4/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc= +gotest.tools/v3 v3.0.0/go.mod h1:TUP+/YtXl/dp++T+SZ5v2zUmLVBHmptSb/ajDLCJ+3c= diff --git a/pkg/goc/graph.go b/graph.go similarity index 99% rename from pkg/goc/graph.go rename to graph.go index 661ca5c..e7e49d9 100644 --- a/pkg/goc/graph.go +++ b/graph.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "log" diff --git a/pkg/goc/io/amqp09/amqp09.go b/io/amqp09/amqp09.go similarity index 100% rename from pkg/goc/io/amqp09/amqp09.go rename to io/amqp09/amqp09.go diff --git a/pkg/goc/io/amqp09/sink.go b/io/amqp09/sink.go similarity index 98% rename from pkg/goc/io/amqp09/sink.go rename to io/amqp09/sink.go index 5c5b93b..1c663e3 100644 --- a/pkg/goc/io/amqp09/sink.go +++ b/io/amqp09/sink.go @@ -21,7 +21,7 @@ package amqp09 import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "github.com/streadway/amqp" "log" "reflect" diff --git a/pkg/goc/io/amqp09/source.go b/io/amqp09/source.go similarity index 98% rename from pkg/goc/io/amqp09/source.go rename to io/amqp09/source.go index 72c68b9..1ce139b 100644 --- a/pkg/goc/io/amqp09/source.go +++ b/io/amqp09/source.go @@ -21,7 +21,7 @@ package amqp09 import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "github.com/streadway/amqp" "log" "reflect" diff --git a/pkg/goc/io/file/reader.go b/io/file/reader.go similarity index 97% rename from pkg/goc/io/file/reader.go rename to io/file/reader.go index 02a7552..ffa9bce 100644 --- a/pkg/goc/io/file/reader.go +++ b/io/file/reader.go @@ -21,7 +21,7 @@ package file import ( - "github.com/amient/goconnect/pkg/goc/coder/url" + "github.com/amient/goconnect/coder/url" "io" "os" "reflect" diff --git a/pkg/goc/io/file/source.go b/io/file/source.go similarity index 95% rename from pkg/goc/io/file/source.go rename to io/file/source.go index ebb6b60..a328b42 100644 --- a/pkg/goc/io/file/source.go +++ b/io/file/source.go @@ -20,8 +20,8 @@ package file import ( - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/coder/url" + "github.com/amient/goconnect" + "github.com/amient/goconnect/coder/url" "io/ioutil" "reflect" ) diff --git a/pkg/goc/io/file/text.go b/io/file/text.go similarity index 97% rename from pkg/goc/io/file/text.go rename to io/file/text.go index ba9d375..32b2f97 100644 --- a/pkg/goc/io/file/text.go +++ b/io/file/text.go @@ -21,7 +21,7 @@ package file import ( "bytes" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/io/kafka1/sink.go b/io/kafka1/sink.go similarity index 98% rename from pkg/goc/io/kafka1/sink.go rename to io/kafka1/sink.go index bf08ad4..47d6d13 100644 --- a/pkg/goc/io/kafka1/sink.go +++ b/io/kafka1/sink.go @@ -21,7 +21,7 @@ package kafka1 import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "github.com/confluentinc/confluent-kafka-go/kafka" "reflect" "time" diff --git a/pkg/goc/io/kafka1/source.go b/io/kafka1/source.go similarity index 99% rename from pkg/goc/io/kafka1/source.go rename to io/kafka1/source.go index c042dcd..50e3929 100644 --- a/pkg/goc/io/kafka1/source.go +++ b/io/kafka1/source.go @@ -21,7 +21,7 @@ package kafka1 import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "github.com/confluentinc/confluent-kafka-go/kafka" "log" "reflect" diff --git a/pkg/goc/io/list.go b/io/list.go similarity index 97% rename from pkg/goc/io/list.go rename to io/list.go index b4458cb..716eb9b 100644 --- a/pkg/goc/io/list.go +++ b/io/list.go @@ -20,7 +20,7 @@ package io import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/io/std/comm.go b/io/std/comm.go similarity index 83% rename from pkg/goc/io/std/comm.go rename to io/std/comm.go index 10817cc..fb7d6e4 100644 --- a/pkg/goc/io/std/comm.go +++ b/io/std/comm.go @@ -3,8 +3,8 @@ package std import ( "bufio" "fmt" - "github.com/amient/goconnect/pkg/goc" - "github.com/amient/goconnect/pkg/goc/io/file" + "github.com/amient/goconnect" + "github.com/amient/goconnect/io/file" ) func process(stdout *bufio.Writer, element interface{}) { diff --git a/pkg/goc/io/std/out.go b/io/std/out.go similarity index 97% rename from pkg/goc/io/std/out.go rename to io/std/out.go index 70b5cd5..fb76293 100644 --- a/pkg/goc/io/std/out.go +++ b/io/std/out.go @@ -21,7 +21,7 @@ package std import ( "bufio" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "os" "reflect" ) diff --git a/pkg/goc/io/std/out2.go b/io/std/out2.go similarity index 98% rename from pkg/goc/io/std/out2.go rename to io/std/out2.go index c0b7f50..c63ec2c 100644 --- a/pkg/goc/io/std/out2.go +++ b/io/std/out2.go @@ -21,7 +21,7 @@ package std import ( "bufio" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "os" "reflect" diff --git a/pkg/goc/network/duplex.go b/network/duplex.go similarity index 100% rename from pkg/goc/network/duplex.go rename to network/duplex.go diff --git a/pkg/goc/network/net_mergeordered.go b/network/net_mergeordered.go similarity index 97% rename from pkg/goc/network/net_mergeordered.go rename to network/net_mergeordered.go index 560742f..0b75483 100644 --- a/pkg/goc/network/net_mergeordered.go +++ b/network/net_mergeordered.go @@ -20,7 +20,7 @@ package network import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/network/net_roundrobin.go b/network/net_roundrobin.go similarity index 97% rename from pkg/goc/network/net_roundrobin.go rename to network/net_roundrobin.go index f38fc45..5015abf 100644 --- a/pkg/goc/network/net_roundrobin.go +++ b/network/net_roundrobin.go @@ -20,7 +20,7 @@ package network import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "reflect" ) diff --git a/pkg/goc/network/network_test.go b/network/network_test.go similarity index 97% rename from pkg/goc/network/network_test.go rename to network/network_test.go index 6c23707..938ac40 100644 --- a/pkg/goc/network/network_test.go +++ b/network/network_test.go @@ -20,7 +20,7 @@ package network import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "reflect" "testing" diff --git a/pkg/goc/network/node.go b/network/node.go similarity index 98% rename from pkg/goc/network/node.go rename to network/node.go index 79933e2..3ee65be 100644 --- a/pkg/goc/network/node.go +++ b/network/node.go @@ -20,7 +20,7 @@ package network import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "time" ) diff --git a/pkg/goc/network/runner.go b/network/runner.go similarity index 98% rename from pkg/goc/network/runner.go rename to network/runner.go index 4e9ac56..4af09f3 100644 --- a/pkg/goc/network/runner.go +++ b/network/runner.go @@ -20,7 +20,7 @@ package network import ( - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "strings" "sync" diff --git a/pkg/goc/network/sender.go b/network/sender.go similarity index 98% rename from pkg/goc/network/sender.go rename to network/sender.go index d1e4b54..5f9f175 100644 --- a/pkg/goc/network/sender.go +++ b/network/sender.go @@ -21,7 +21,7 @@ package network import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "net" "time" diff --git a/pkg/goc/network/server.go b/network/server.go similarity index 99% rename from pkg/goc/network/server.go rename to network/server.go index 254bd9d..96948f5 100644 --- a/pkg/goc/network/server.go +++ b/network/server.go @@ -21,7 +21,7 @@ package network import ( "fmt" - "github.com/amient/goconnect/pkg/goc" + "github.com/amient/goconnect" "log" "math/rand" "net" diff --git a/pkg/goc/pipeline.go b/pipeline.go similarity index 99% rename from pkg/goc/pipeline.go rename to pipeline.go index aebda20..d8bd22f 100644 --- a/pkg/goc/pipeline.go +++ b/pipeline.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "fmt" diff --git a/pkg/goc/processor.go b/processor.go similarity index 99% rename from pkg/goc/processor.go rename to processor.go index f300f28..185d31f 100644 --- a/pkg/goc/processor.go +++ b/processor.go @@ -17,11 +17,11 @@ * limitations under the License. */ -package goc +package goconnect import ( "fmt" - "github.com/amient/goconnect/pkg/goc/util" + "github.com/amient/goconnect/util" "math" "sync" ) diff --git a/pkg/goc/stamp.go b/stamp.go similarity index 98% rename from pkg/goc/stamp.go rename to stamp.go index cd37bda..c23b63e 100644 --- a/pkg/goc/stamp.go +++ b/stamp.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "fmt" diff --git a/pkg/goc/types.go b/types.go similarity index 98% rename from pkg/goc/types.go rename to types.go index 553bf35..0bf1db7 100644 --- a/pkg/goc/types.go +++ b/types.go @@ -17,7 +17,7 @@ * limitations under the License. */ -package goc +package goconnect import ( "fmt" diff --git a/pkg/goc/util/byteio.go b/util/byteio.go similarity index 100% rename from pkg/goc/util/byteio.go rename to util/byteio.go diff --git a/pkg/goc/util/movingaverage.go b/util/movingaverage.go similarity index 100% rename from pkg/goc/util/movingaverage.go rename to util/movingaverage.go diff --git a/pkg/goc/util/strwriter.go b/util/strwriter.go similarity index 100% rename from pkg/goc/util/strwriter.go rename to util/strwriter.go