Skip to content

Commit

Permalink
Merge pull request #27 from Financial-Times/sirupsen-fix
Browse files Browse the repository at this point in the history
Sirupsen fix
  • Loading branch information
nwrigh committed Aug 31, 2017
2 parents 26503db + 3ee8130 commit 9de16b7
Show file tree
Hide file tree
Showing 5 changed files with 120 additions and 82 deletions.
9 changes: 5 additions & 4 deletions annotations/cypher.go
Original file line number Diff line number Diff line change
@@ -1,14 +1,15 @@
package annotations

import (
"encoding/json"
"fmt"
"regexp"
"time"

"github.com/Financial-Times/neo-model-utils-go/mapper"
"github.com/Financial-Times/neo-utils-go/neoutils"
log "github.com/Sirupsen/logrus"
"github.com/jmcvetta/neoism"
"regexp"
"time"
"encoding/json"
log "github.com/sirupsen/logrus"
)

var uuidExtractRegex = regexp.MustCompile(".*/([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})$")
Expand Down
11 changes: 6 additions & 5 deletions app.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,19 +7,20 @@ import (
"os"

"encoding/json"
"io/ioutil"
"os/signal"
"syscall"

"github.com/Financial-Times/annotations-rw-neo4j/annotations"
"github.com/Financial-Times/base-ft-rw-app-go/baseftrwapp"
"github.com/Financial-Times/http-handlers-go/httphandlers"
"github.com/Financial-Times/kafka-client-go/kafka"
"github.com/Financial-Times/neo-utils-go/neoutils"
status "github.com/Financial-Times/service-status-go/httphandlers"
log "github.com/Sirupsen/logrus"
"github.com/gorilla/mux"
"github.com/jawher/mow.cli"
"github.com/rcrowley/go-metrics"
"io/ioutil"
"os/signal"
"syscall"
log "github.com/sirupsen/logrus"
)

func main() {
Expand Down Expand Up @@ -176,7 +177,7 @@ func setupAnnotationsService(neoURL string, bathSize int) annotations.Service {
}

func setupMessageProducer(brokerAddress string, producerTopic string) kafka.Producer {
producer, err := kafka.NewProducer(brokerAddress, producerTopic)
producer, err := kafka.NewProducer(brokerAddress, producerTopic, kafka.DefaultProducerConfig())
if err != nil {
log.Fatal("Cannot start queue producer.")
}
Expand Down
7 changes: 4 additions & 3 deletions http_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,15 +6,16 @@ import (
"net/http"
"strings"

"io"
"time"

"github.com/Financial-Times/annotations-rw-neo4j/annotations"
"github.com/Financial-Times/kafka-client-go/kafka"
"github.com/Financial-Times/transactionid-utils-go"
log "github.com/Sirupsen/logrus"
"github.com/gorilla/mux"
"github.com/pkg/errors"
log "github.com/sirupsen/logrus"
"github.com/twinj/uuid"
"io"
"time"
)

const (
Expand Down
3 changes: 2 additions & 1 deletion queue_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,12 @@ package main

import (
"encoding/json"

"github.com/Financial-Times/annotations-rw-neo4j/annotations"
"github.com/Financial-Times/kafka-client-go/kafka"
"github.com/Financial-Times/transactionid-utils-go"
log "github.com/Sirupsen/logrus"
"github.com/pkg/errors"
log "github.com/sirupsen/logrus"
)

type queueHandler struct {
Expand Down
172 changes: 103 additions & 69 deletions vendor/vendor.json
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,22 @@
"ignore": "test",
"package": [
{
"checksumSHA1": "fg1dZ/MIpnMKoW0vJE2y5HpHXXc=",
"path": "appengine",
"revision": ""
},
{
"path": "appengine/aetest",
"revision": ""
},
{
"path": "appengine/urlfetch",
"revision": ""
},
{
"checksumSHA1": "FfEWrE4sbtmtyeBTHCCF1q3QBxU=",
"path": "github.com/Financial-Times/base-ft-rw-app-go/baseftrwapp",
"revision": "01975d9da464dc2b864f1a5cf603827fdaa8e661",
"revisionTime": "2016-09-09T09:52:18Z"
"revision": "be466360f44ea91249e878204fc2f36f2fa9cf6c",
"revisionTime": "2017-08-30T11:11:50Z"
},
{
"checksumSHA1": "fNgRM8ZlaDzdvSpuhSdGxEOrWi4=",
Expand All @@ -15,16 +27,16 @@
"revisionTime": "2017-05-25T09:50:41Z"
},
{
"checksumSHA1": "zUpINnstJChGK0LAtkt7jBc3RY0=",
"checksumSHA1": "dqF1g4reeLPNN10qTXgDJj3fHm4=",
"path": "github.com/Financial-Times/http-handlers-go/httphandlers",
"revision": "bb69c454da9050fe1c4b92fe1345a01583ee70be",
"revisionTime": "2016-08-03T10:40:03Z"
"revision": "229ac16f1d9ec9bca485d2dafb9ec14dc7e9ba24",
"revisionTime": "2017-08-09T12:10:07Z"
},
{
"checksumSHA1": "efJSs//9AHdDmQklerOPAYoae40=",
"checksumSHA1": "4FoNa1c4xNwIuzokLe37dfC/hBQ=",
"path": "github.com/Financial-Times/kafka-client-go/kafka",
"revision": "9b51d3f2fa101211984b96ecf73f045afb38e29c",
"revisionTime": "2017-06-20T08:33:10Z"
"revision": "cc65f68255d42de893a6d72f31394ad031c54142",
"revisionTime": "2017-08-25T10:40:40Z"
},
{
"checksumSHA1": "ZmT6PPQSF7C4aHQ2HO8QsKtYStg=",
Expand All @@ -33,10 +45,10 @@
"revisionTime": "2017-04-05T08:23:10Z"
},
{
"checksumSHA1": "IDKJ/mqVeFl91y07EpjO6Kbnwnc=",
"checksumSHA1": "ibld3tkf8qmEKpF69JI4mrSN0T8=",
"path": "github.com/Financial-Times/neo-utils-go/neoutils",
"revision": "aed125896a5ac0b50296fde5faefed1ebfa7fae3",
"revisionTime": "2017-01-04T12:16:44Z"
"revision": "5cb1750096545b3c8f7384326247e3e30996a905",
"revisionTime": "2017-08-22T15:20:35Z"
},
{
"checksumSHA1": "fqpohN7Qp2qj7TLMbUxh/cK4oH0=",
Expand All @@ -63,22 +75,16 @@
"revisionTime": "2017-03-28T16:39:54Z"
},
{
"checksumSHA1": "TC6pkBrqs0MYZEbikQcrloZw4Ec=",
"checksumSHA1": "diw1KueSVzsMHPCNDvj+xQiXSTE=",
"path": "github.com/Financial-Times/up-rw-app-api-go/rwapi",
"revision": "c7976a0b575e3cad95ec10ebca53798567b39845",
"revisionTime": "2016-08-24T12:50:00Z"
"revision": "d9d93a1f689538313d12fee6f5f10715cfe280e0",
"revisionTime": "2017-07-10T12:58:28Z"
},
{
"checksumSHA1": "jRUvScAXltFxTRaj1RpBZKyqnEs=",
"checksumSHA1": "EddXnllITE2MqGjj8Xw9hHFjuE8=",
"path": "github.com/Shopify/sarama",
"revision": "f7e3024a61603647461f4b40bd8f3db88871bf9d",
"revisionTime": "2017-06-15T15:11:31Z"
},
{
"checksumSHA1": "DYv6Q1+VfnUVxMwvk5IshAClLvw=",
"path": "github.com/Sirupsen/logrus",
"revision": "5e5dc898656f695e2a086b8e12559febbfc01562",
"revisionTime": "2017-05-15T10:45:16Z"
"revision": "15174039fd207656a0f97f52bc78ec7793deeada",
"revisionTime": "2017-08-25T18:38:27Z"
},
{
"checksumSHA1": "/6H1rhQmbq8mEP29pnmLmdwBKUE=",
Expand All @@ -87,10 +93,10 @@
"revisionTime": "2016-12-19T23:08:53Z"
},
{
"checksumSHA1": "dvabztWVQX8f6oMLRyv4dLH+TGY=",
"checksumSHA1": "mrz/kicZiUaHxkyfvC/DyQcr8Do=",
"path": "github.com/davecgh/go-spew/spew",
"revision": "346938d642f2ec3594ed81d874461961cd0faa76",
"revisionTime": "2016-10-29T20:57:26Z"
"revision": "a476722483882dd40b8111f0eb64e1d7f43f56e4",
"revisionTime": "2017-08-29T19:49:58Z"
},
{
"checksumSHA1": "y2Kh4iPlgCPXSGTCcFpzePYdzzg=",
Expand All @@ -117,10 +123,16 @@
"revisionTime": "2017-02-15T23:32:05Z"
},
{
"checksumSHA1": "6PQFibmHgsXFHoRQPmkw2V+59Lk=",
"checksumSHA1": "g/V4qrXjUGG9B+e3hB+4NAYJ5Gs=",
"path": "github.com/gorilla/context",
"revision": "08b5f424b9271eedf6f9f0ce86cb9396ed337a42",
"revisionTime": "2016-08-17T18:46:32Z"
},
{
"checksumSHA1": "xDg0jE3TXG3TXgzUUy/+r+v9Hro=",
"path": "github.com/gorilla/mux",
"revision": "18fca31550181693b3a834a15b74b564b3605876",
"revisionTime": "2017-05-30T19:55:47Z"
"revision": "a659b61323b075cb38ad03aa43749e52eb4948e0",
"revisionTime": "2017-08-30T05:39:17Z"
},
{
"checksumSHA1": "tUGxc7rfX0cmhOOUDhMuAZ9rWsA=",
Expand All @@ -129,16 +141,16 @@
"revisionTime": "2017-02-02T08:07:59Z"
},
{
"checksumSHA1": "NK3DaezXmT5QyDImKH+qqI2Xa7c=",
"checksumSHA1": "I7AAXZqD3Dy5KjQ9N+2/iHzlKzc=",
"path": "github.com/jawher/mow.cli",
"revision": "8327d12beb75e6471b7f045588acc318d1147146",
"revisionTime": "2017-04-30T13:52:12Z"
"revision": "a459d5906bb7a9c5eda7c4d02eec7c541120226e",
"revisionTime": "2017-08-20T16:57:35Z"
},
{
"checksumSHA1": "ahHC2yTxvXEDiuqoe8TiMRpo9aM=",
"checksumSHA1": "nMm7xgpbpYYWy/zdKttNSoo1HAE=",
"path": "github.com/jmcvetta/neoism",
"revision": "2ffb5c69feb355227c6ee8679768d7289e6d7193",
"revisionTime": "2017-03-06T11:01:38Z"
"revision": "4674154f870d19b356581843f481dccd6792dcc0",
"revisionTime": "2017-03-06T10:41:37Z"
},
{
"checksumSHA1": "khL6oKjx81rAZKW+36050b7f5As=",
Expand All @@ -161,14 +173,14 @@
{
"checksumSHA1": "FGg99nQ56Fo3radSCuU1AeEUJug=",
"path": "github.com/pierrec/lz4",
"revision": "5a3d2245f97fc249850e7802e3c01fad02a1c316",
"revisionTime": "2017-05-19T17:06:25Z"
"revision": "08c27939df1bd95e881e2c2367a749964ad1fceb",
"revisionTime": "2017-08-28T19:29:35Z"
},
{
"checksumSHA1": "IT4sX58d+e8osXHV5U6YCSdB/uE=",
"checksumSHA1": "zPWRjzsPeXCoqmidIcJtHbvrvRs=",
"path": "github.com/pierrec/xxHash/xxHash32",
"revision": "5a004441f897722c627870a981d02b29924215fa",
"revisionTime": "2016-01-12T16:53:51Z"
"revision": "a0006b13c722f7f12368c00a3d3c2ae8a999a0c6",
"revisionTime": "2017-07-14T08:24:55Z"
},
{
"checksumSHA1": "rJab1YdNhQooDiBWNnt7TLWPyBU=",
Expand All @@ -177,11 +189,10 @@
"revisionTime": "2017-05-05T04:36:39Z"
},
{
"checksumSHA1": "zKKp5SZ3d3ycKe4EKMNT0BqAWBw=",
"origin": "github.com/stretchr/testify/vendor/github.com/pmezard/go-difflib/difflib",
"checksumSHA1": "LuFv4/jlrmFNnDb/5SCSEPAM9vU=",
"path": "github.com/pmezard/go-difflib/difflib",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "792786c7400a136282c1664665ae0a8db921c6c2",
"revisionTime": "2016-01-10T10:55:54Z"
},
{
"checksumSHA1": "KAzbLjI9MzW2tjfcAsK75lVRp6I=",
Expand All @@ -190,41 +201,46 @@
"revisionTime": "2016-11-28T21:05:44Z"
},
{
"checksumSHA1": "5SYLEhADhdBVZAGPVHWggQl7H8k=",
"checksumSHA1": "Vo8anQz2gbx3FnURv/wpv57zWP4=",
"path": "github.com/samuel/go-zookeeper/zk",
"revision": "1d7be4effb13d2d908342d349d71a284a7542693",
"revisionTime": "2016-10-28T23:23:40Z"
"revision": "e6b59f6144beb8570562539c1898a0b1fea34b41",
"revisionTime": "2017-08-15T20:11:39Z"
},
{
"checksumSHA1": "BYvROBsiyAXK4sq6yhDe8RgT4LM=",
"path": "github.com/sirupsen/logrus",
"revision": "89742aefa4b206dcf400792f3bd35b542998eb3b",
"revisionTime": "2017-08-22T13:27:46Z"
},
{
"checksumSHA1": "EO+jcRet/AJ6IY3lBO8l8BLsZWg=",
"origin": "github.com/stretchr/testify/vendor/github.com/stretchr/objx",
"checksumSHA1": "K0crHygPTP42i1nLKWphSlvOQJw=",
"path": "github.com/stretchr/objx",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "1a9d0bb9f541897e62256577b352fdbc1fb4fd94",
"revisionTime": "2015-09-28T12:21:52Z"
},
{
"checksumSHA1": "JXUVA1jky8ZX8w09p2t5KLs97Nc=",
"checksumSHA1": "mGbTYZ8dHVTiPTTJu3ktp+84pPI=",
"path": "github.com/stretchr/testify/assert",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "890a5c3458b43e6104ff5da8dfa139d013d77544",
"revisionTime": "2017-07-05T02:17:15Z"
},
{
"checksumSHA1": "WGwMB6WljaeGKzuNCX5M4E8LADE=",
"checksumSHA1": "o+jsS/rxceTym4M3reSPfrPxaio=",
"path": "github.com/stretchr/testify/mock",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "890a5c3458b43e6104ff5da8dfa139d013d77544",
"revisionTime": "2017-07-05T02:17:15Z"
},
{
"checksumSHA1": "2PpOCNkWnshDrXeCVH2kp3VHhIM=",
"checksumSHA1": "7vs6dSc1PPGBKyzb/SCIyeMJPLQ=",
"path": "github.com/stretchr/testify/require",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "890a5c3458b43e6104ff5da8dfa139d013d77544",
"revisionTime": "2017-07-05T02:17:15Z"
},
{
"checksumSHA1": "Dp8TnT65nINpRF/PrxrgmnYLsyA=",
"checksumSHA1": "uefllr2OtKBGo/kQSAPbW3w6p0A=",
"path": "github.com/stretchr/testify/suite",
"revision": "4d4bfba8f1d1027c4fdbe371823030df51419987",
"revisionTime": "2017-01-30T11:31:45Z"
"revision": "890a5c3458b43e6104ff5da8dfa139d013d77544",
"revisionTime": "2017-07-05T02:17:15Z"
},
{
"checksumSHA1": "ClyNDKGVhQH1K/IXbLZ1qMv0ddA=",
Expand All @@ -247,14 +263,32 @@
{
"checksumSHA1": "dBmk68coq8umF51FL23vNXOOS7o=",
"path": "go4.org/osutil",
"revision": "16ace784e4b16df1d51c3435223b1d602cd43bfa",
"revisionTime": "2017-05-05T14:57:44Z"
"revision": "034d17a462f7b2dcd1a4a73553ec5357ff6e6c6e",
"revisionTime": "2017-05-24T23:16:39Z"
},
{
"checksumSHA1": "nqWNlnMmVpt628zzvyo6Yv2CX5Q=",
"path": "golang.org/x/crypto/ssh/terminal",
"revision": "81e90905daefcd6fd217b62423c0908922eadb30",
"revisionTime": "2017-08-25T20:24:07Z"
},
{
"checksumSHA1": "Y+HGqEkYM15ir+J93MEaHdyFy0c=",
"checksumSHA1": "dr5+PfIRzXeN+l1VG+s0lea9qz8=",
"path": "golang.org/x/net/context",
"revision": "5b58a9c3e1690d33a592e5b791638e25eb9b3f70",
"revisionTime": "2017-05-24T09:28:03Z"
"revision": "66aacef3dd8a676686c7ae3716979581e8b03c47",
"revisionTime": "2016-09-14T00:11:54Z"
},
{
"checksumSHA1": "0pTcHZ43GApI5Lp33cN9RoWzdNk=",
"path": "golang.org/x/sys/unix",
"revision": "ab9e364efd8b52800ff7ee48a9ffba4e0ed78dfb",
"revisionTime": "2017-08-29T14:47:16Z"
},
{
"checksumSHA1": "gVfCD++7aVcdKF2spv6XkEM/wYw=",
"path": "golang.org/x/sys/windows",
"revision": "ab9e364efd8b52800ff7ee48a9ffba4e0ed78dfb",
"revisionTime": "2017-08-29T14:47:16Z"
},
{
"checksumSHA1": "k3L1Q7anlDsX2njPAE5Dd2SWVlw=",
Expand Down

0 comments on commit 9de16b7

Please sign in to comment.