Skip to content

Bridge master #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
saahn wants to merge 50 commits into
base: master
Choose a base branch
from
Open

Bridge master #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
50 commits
Select commit Hold shift + click to select a range
7d6708a
create network bridge to link consumer and producer go channels
saahn Aug 8, 2016
87822a5
modify mirrormaker with network bridge support
saahn Aug 8, 2016
cc7205f
do not start irrelevant processes if bridge is specified
saahn Aug 8, 2016
174df9f
initialize connections map
saahn Aug 8, 2016
f02fb76
start local consumer/producer in bridge mode; fix producer stop bug
saahn Aug 9, 2016
308550c
Dereference msg before sending over the net; sender should loop for i…
saahn Aug 11, 2016
fe91a08
add debug logs
saahn Aug 11, 2016
a3ab7c5
temporary SimpleMessage for debugging
saahn Aug 12, 2016
92f69c1
fix blocked libchan sender -> receiver channel
saahn Aug 16, 2016
8b70ca0
fix marshalling/unmarshalling of BridgeMessage
saahn Aug 16, 2016
bce8520
fix dockerfile and run-tests
saahn Aug 16, 2016
cc89fea
log clean up; working with send channel creation/close per message
saahn Aug 18, 2016
4df2949
fix gochannel indexing
saahn Aug 22, 2016
4995f56
make TopicPartitionHash public
saahn Aug 22, 2016
f84d88f
remove mirrormaker binary
saahn Sep 6, 2016
67f26b8
remove debug code
saahn Sep 6, 2016
0da660b
TLS support
saahn Sep 6, 2016
b6063ad
debug logs
saahn Sep 6, 2016
2055f5a
refactor chan bridge to be more robust and bidirectional
saahn Sep 14, 2016
0c6b7aa
debug logs
saahn Sep 14, 2016
9573c34
remove bridgeResponse cruft
saahn Sep 14, 2016
7528a6c
use go channel to signal connection state across send/receive go rout…
saahn Sep 15, 2016
57d44e7
minor bridge initialization change
saahn Sep 15, 2016
0cba631
recover failed to send messages
saahn Sep 15, 2016
17fd154
detect sigterm and sigkill for stopping mm
saahn Sep 16, 2016
540c15b
refactor tryConnect
saahn Sep 17, 2016
1c19a5a
minor logging fix
saahn Sep 20, 2016
32c9a2e
fix retry logic
saahn Sep 22, 2016
ed19b06
fix concurrenty bugs; fix resend logic for failed messages
saahn Sep 23, 2016
e1b2bc5
fix failedMessages slice resets
saahn Sep 23, 2016
47ec3ff
local health endpoint
saahn Nov 18, 2016
b34c53a
remove verbose logs
saahn Nov 18, 2016
20de278
fix memory leak
saahn Nov 28, 2016
dca1a43
remove logs
saahn Nov 29, 2016
2402f84
pprof
saahn Nov 29, 2016
2c813af
close remote receiver
saahn Nov 29, 2016
ef484f2
add debug logs
saahn Nov 30, 2016
a0de063
more debug
saahn Nov 30, 2016
e41b47e
more debug
saahn Nov 30, 2016
12ae122
refactor bridge send logic
saahn Dec 5, 2016
60644dd
capture debug
saahn Dec 6, 2016
38da88f
refactor save
saahn Dec 7, 2016
817ef5f
fix resend logic
saahn Dec 7, 2016
cf0ddd9
cleanup and stop logic fix
saahn Dec 7, 2016
5c09388
more fixes to resend logic
saahn Dec 8, 2016
d8257f8
clean up
saahn Dec 8, 2016
dcd97bd
fix disconnect logic
saahn Dec 8, 2016
69d1e59
clear consumer members; suppress logs
saahn Dec 8, 2016
73dedfb
suppress verbose logs
saahn Dec 9, 2016
fb08b08
remove logs
saahn Dec 9, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions Dockerfile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
Expand Down Expand Up @@ -40,7 +40,8 @@ ENV REGISTRY_URL http://packages.confluent.io/archive/$REGISTRY_VERSION/confluen
ENV REGISTRY_HOME /opt/confluent-$REGISTRY_VERSION

#Go settings
ENV GOLANG_VERSION 1.3.3
#ENV GOLANG_VERSION 1.3.3
ENV GOLANG_VERSION 1.6.3
ENV GOLANG_RELEASE go$GOLANG_VERSION
ENV GOLANG_URL https://storage.googleapis.com/golang/go$GOLANG_VERSION.linux-amd64.tar.gz
ENV GOROOT /usr/bin/go
Expand Down
Loading