duplikat dari https://git.mills.io/prologic/msgbus.git
Migrate to Drone CI (cloud), CodeCov and Go11Modules
This commit is contained in:
James Mills
orang tua
848540a51d
melakukan
8d19831a86
44
.drone.yml
44
.drone.yml
|
|
@ -1,38 +1,22 @@
|
|||
workspace:
|
||||
base: /go
|
||||
path: src/github.com/prologic/msgbus
|
||||
kind: pipeline
|
||||
name: default
|
||||
|
||||
pipeline:
|
||||
build:
|
||||
steps:
|
||||
- name: build
|
||||
image: golang:latest
|
||||
commands:
|
||||
- make test
|
||||
|
||||
docker:
|
||||
image: plugins/docker
|
||||
repo: r.mills.io/prologic/msgbus
|
||||
registry: r.mills.io
|
||||
secrets: [ docker_username, docker_password ]
|
||||
- name: coverage
|
||||
image: plugins/codecov
|
||||
settings:
|
||||
token:
|
||||
from_secret: codecov-token
|
||||
|
||||
notify:
|
||||
image: drillster/drone-email
|
||||
host: mail.mills.io
|
||||
from: drone@mills.io
|
||||
skip_verify: true
|
||||
secrets: [ email_username, email_password ]
|
||||
when:
|
||||
status: [ success, changed, failure ]
|
||||
|
||||
webhook:
|
||||
- name: notify
|
||||
image: plugins/webhook
|
||||
urls: https://msgbus.mills.io/ci.mills.io
|
||||
|
||||
secrets:
|
||||
email_username:
|
||||
external: true
|
||||
email_password:
|
||||
external: true
|
||||
registry_username:
|
||||
external: true
|
||||
registry_password:
|
||||
external: true
|
||||
when:
|
||||
status:
|
||||
- success
|
||||
- failure
|
||||
|
|
|
|||
|
|
@ -3,5 +3,5 @@ dist
|
|||
*.bak
|
||||
*.prof
|
||||
coverage.txt
|
||||
cmd/msgbus/msgbus
|
||||
cmd/msgbusd/msgbusd
|
||||
./cmd/msgbus/msgbus
|
||||
./cmd/msgbusd/msgbusd
|
||||
|
|
|
|||
|
|
@ -1,7 +0,0 @@
|
|||
language: go
|
||||
sudo: false
|
||||
go: "1.10.x"
|
||||
script:
|
||||
- make test
|
||||
after_success:
|
||||
- bash <(curl -s https://codecov.io/bash)
|
||||
|
|
@ -1,10 +1,10 @@
|
|||
# msgbus
|
||||
|
||||
[](https://travis-ci.org/prologic/msgbus)
|
||||
[](https://cloud.drone.io/prologic/msgbus)
|
||||
[](https://codecov.io/gh/prologic/msgbus)
|
||||
[](https://goreportcard.com/report/prologic/msgbus)
|
||||
[](https://godoc.org/github.com/prologic/msgbus)
|
||||
[](https://microbadger.com/images/prologic/msgbus "Get your own image badge on microbadger.com")
|
||||
[](https://sourcegraph.com/github.com/prologic/msgbus?badge)
|
||||
|
||||
A real-time message bus server and library written in Go.
|
||||
|
||||
|
|
|
|||
|
|
@ -191,7 +191,7 @@ func NewSubscriber(client *Client, topic string, handler msgbus.HandlerFunc) *Su
|
|||
|
||||
u, err := url.Parse(client.url)
|
||||
if err != nil {
|
||||
log.Fatal("invalid url: %s", client.url)
|
||||
log.Fatalf("invalid url: %s", client.url)
|
||||
}
|
||||
|
||||
if strings.HasPrefix(client.url, "https") {
|
||||
|
|
|
|||
Binary file not shown.
Binary file not shown.
|
|
@ -0,0 +1,13 @@
|
|||
module github.com/prologic/msgbus
|
||||
|
||||
require (
|
||||
github.com/gorilla/websocket v1.4.0
|
||||
github.com/jpillora/backoff v0.0.0-20180909062703-3050d21c67d7
|
||||
github.com/mitchellh/go-homedir v1.0.0
|
||||
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3
|
||||
github.com/prometheus/client_golang v0.9.2
|
||||
github.com/sirupsen/logrus v1.2.0
|
||||
github.com/spf13/cobra v0.0.3
|
||||
github.com/spf13/viper v1.3.1
|
||||
github.com/stretchr/testify v1.2.2
|
||||
)
|
||||
|
|
@ -0,0 +1,75 @@
|
|||
github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
|
||||
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973 h1:xJ4a3vCFaGF/jqvzLMYoU8P317H5OQ+Via4RmuPwCS0=
|
||||
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
|
||||
github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
|
||||
github.com/coreos/go-etcd v2.0.0+incompatible/go.mod h1:Jez6KQU2B/sWsbdaef3ED8NzMklzPG4d5KIOhIy30Tk=
|
||||
github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
|
||||
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
|
||||
github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM=
|
||||
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/gorilla/websocket v1.4.0 h1:WDFjx/TMzVgy9VdMMQi2K2Emtwi2QcUQsztZ/zLaH/Q=
|
||||
github.com/gorilla/websocket v1.4.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
|
||||
github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
|
||||
github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
|
||||
github.com/jpillora/backoff v0.0.0-20180909062703-3050d21c67d7 h1:K//n/AqR5HjG3qxbrBCL4vJPW0MVFSs9CPK1OOJdRME=
|
||||
github.com/jpillora/backoff v0.0.0-20180909062703-3050d21c67d7/go.mod h1:2iMrUgbbvHEiQClaW2NsSzMyGHqN+rDFqY705q49KG0=
|
||||
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
|
||||
github.com/magiconair/properties v1.8.0 h1:LLgXmsheXeRoUOBOjtwPQCWIYqM/LU1ayDtDePerRcY=
|
||||
github.com/magiconair/properties v1.8.0/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.1 h1:4hp9jkHxhMHkqkrB3Ix0jegS5sx/RkqARlsWZ6pIwiU=
|
||||
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
|
||||
github.com/mitchellh/go-homedir v1.0.0 h1:vKb8ShqSby24Yrqr/yDYkuFz8d0WUjys40rvnGC8aR0=
|
||||
github.com/mitchellh/go-homedir v1.0.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
|
||||
github.com/mitchellh/mapstructure v1.1.2 h1:fmNYVwqnSfB9mZU6OS2O6GsXM+wcskZDuKQzvN1EDeE=
|
||||
github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
|
||||
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3 h1:2YMbJ6WbdQI9K73chxh9OWMDsZ2PNjAIRGTonp3T0l0=
|
||||
github.com/mmcloughlin/professor v0.0.0-20170922221822-6b97112ab8b3/go.mod h1:LQkXsHRSPIEklPCq8OMQAzYNS2NGtYStdNE/ej1oJU8=
|
||||
github.com/pelletier/go-toml v1.2.0 h1:T5zMGML61Wp+FlcbWjRDT7yAxhJNAiPPLOFECq181zc=
|
||||
github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/prometheus/client_golang v0.9.2 h1:awm861/B8OKDd2I/6o1dy3ra4BamzKhYOiGItCeZ740=
|
||||
github.com/prometheus/client_golang v0.9.2/go.mod h1:OsXs2jCmiKlQ1lTBmv21f2mNfw4xf/QclQDMrYNZzcM=
|
||||
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910 h1:idejC8f05m9MGOsuEi1ATq9shN03HrxNkD/luQvxCv8=
|
||||
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
|
||||
github.com/prometheus/common v0.0.0-20181126121408-4724e9255275 h1:PnBWHBf+6L0jOqq0gIVUe6Yk0/QMZ640k6NvkxcBf+8=
|
||||
github.com/prometheus/common v0.0.0-20181126121408-4724e9255275/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro=
|
||||
github.com/prometheus/procfs v0.0.0-20181204211112-1dc9a6cbc91a h1:9a8MnZMP0X2nLJdBg+pBmGgkJlSaKC2KaQmTCk1XDtE=
|
||||
github.com/prometheus/procfs v0.0.0-20181204211112-1dc9a6cbc91a/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
|
||||
github.com/sirupsen/logrus v1.2.0 h1:juTguoYk5qI21pwyTXY3B3Y5cOTH3ZUyZCg1v/mihuo=
|
||||
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
|
||||
github.com/spf13/afero v1.1.2 h1:m8/z1t7/fwjysjQRYbP0RD+bUIF/8tJwPdEZsI83ACI=
|
||||
github.com/spf13/afero v1.1.2/go.mod h1:j4pytiNVoe2o6bmDsKpLACNPDBIoEAkihy7loJ1B0CQ=
|
||||
github.com/spf13/cast v1.3.0 h1:oget//CVOEoFewqQxwr0Ej5yjygnqGkvggSE/gB35Q8=
|
||||
github.com/spf13/cast v1.3.0/go.mod h1:Qx5cxh0v+4UWYiBimWS+eyWzqEqokIECu5etghLkUJE=
|
||||
github.com/spf13/cobra v0.0.3 h1:ZlrZ4XsMRm04Fr5pSFxBgfND2EBVa1nLpiy1stUsX/8=
|
||||
github.com/spf13/cobra v0.0.3/go.mod h1:1l0Ry5zgKvJasoi3XT1TypsSe7PqH0Sj9dhYf7v3XqQ=
|
||||
github.com/spf13/jwalterweatherman v1.0.0 h1:XHEdyB+EcvlqZamSM4ZOMGlc93t6AcsBEu9Gc1vn7yk=
|
||||
github.com/spf13/jwalterweatherman v1.0.0/go.mod h1:cQK4TGJAtQXfYWX+Ddv3mKDzgVb68N+wFjFa4jdeBTo=
|
||||
github.com/spf13/pflag v1.0.3 h1:zPAT6CGy6wXeQ7NtTnaTerfKOsV6V6F8agHXFiazDkg=
|
||||
github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
|
||||
github.com/spf13/viper v1.3.1 h1:5+8j8FTpnFV4nEImW/ofkzEt8VoOiLXxdYIDsB73T38=
|
||||
github.com/spf13/viper v1.3.1/go.mod h1:ZiWeW+zYFKm7srdB9IoDzzZXaJaI5eL9QjNiN/DMA2s=
|
||||
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/testify v1.2.2 h1:bSDNvY7ZPG5RlJ8otE/7V6gMiyenm9RtJ7IUVIAoJ1w=
|
||||
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
|
||||
github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8/go.mod h1:VFNgLljTbGfSG7qAOspJ7OScBnGdDN/yBr0sguwnwf0=
|
||||
github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793 h1:u+LnwYTOOW7Ukr/fppxEb1Nwz0AtPflrblfvUudpo+I=
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
|
||||
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9 h1:mKdxBk7AujPs8kU4m80U72y/zjbZ3UcXC7dClwKbUI0=
|
||||
golang.org/x/crypto v0.0.0-20181203042331-505ab145d0a9/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
|
||||
golang.org/x/net v0.0.0-20181201002055-351d144fa1fc/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33 h1:I6FyU15t786LL7oL/hn43zqTuEGr4PN7F4XJ1p4E3Y8=
|
||||
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20181205085412-a5c9d58dba9a h1:1n5lsVfiQW3yfsRGu98756EH1YthsFqr/5mxHduZW2A=
|
||||
golang.org/x/sys v0.0.0-20181205085412-a5c9d58dba9a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
|
||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
|
||||
gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
|
||||
|
|
@ -54,6 +54,10 @@ type Topic struct {
|
|||
Created time.Time `json:"created"`
|
||||
}
|
||||
|
||||
func (t *Topic) String() string {
|
||||
return t.Name
|
||||
}
|
||||
|
||||
// Message ...
|
||||
type Message struct {
|
||||
ID uint64 `json:"id"`
|
||||
|
|
|
|||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 3a771d992973f24aa725d07868b467d1ddfceafb
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit c2828203cd70a50dcccfb2761f8b1f8ceef9a8e9
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 70c277a8a150a8e069492e6600926300405c2884
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 21ab95fa12b9bdd8fecf5fa3586aad941cc98785
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit ef8a98b0bbce4a65b5aa4c368430a80ddc533168
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 8eab2debe79d12b7bd3d10653910df25fa9552ba
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit c2353362d570a7bfa228149c62842019201cfb71
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit c12348ce28de40eed0136aa2b644d0ee0650e56c
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit b8bc1bf767474819792c23f32d8286a45736f1c6
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit bb74f1db0675b241733089d5a1faa5dd8b0ef57b
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 6b97112ab8b362d27f7976815eb0d35da5249099
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 66540cf1fcd2c3aee6f6787dfa32a6ae9a870f12
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit c51dc758d4bb30acacbef9eaa2b774969a135086
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 99fa1f4be8e564e8a6b613da7fa6f46c9edafc6c
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 7600349dcfe1abd18d72d3a1770870d9800a7801
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 8b1c2da0d56deffdbb9e48d4414b4e674bd8083e
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 0dad3b6953e73d351ec8ebfd8a8c6b088d320381
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 63644898a8da0bc22138abf860edaf5277b6102e
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 8965335b8c7107321228e3e3702cab9832751bac
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit ef82de70bb3f60c65fb8eebacbb2d122ef517385
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 7c0cea34c8ece3fbeb2b27ab9b59511d360fb394
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 583c0c0531f06d5278b7d917446061adc344b5cd
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 15738813a09db5c8e5b60a19d67d3f9bd38da3a4
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit c679ae2cc0cb27ec3293fea7e254e47386f05d69
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 1a580b3eff7814fc9b40602fd35256c63b50f491
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 7c87d13f8e835d2fb3a70a2912c811ed0c1d241b
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 5c1cf69b5978e5a34c5f9ba09a83e56acc4b7877
|
||||
|
|
@ -1 +0,0 @@
|
|||
Subproject commit 5420a8b6744d3b0345ab293f6fcba19c978f1183
|
||||
Memuat…
Reference in New Issue