From 09fd7492c886ec60cb2b43f72a7ff7b5bcdba38c Mon Sep 17 00:00:00 2001 From: Kelly Wilson Date: Thu, 28 Apr 2022 08:01:32 -0700 Subject: [PATCH] go.mod - revert module back to lirm for PR to upstream --- aeron/aeron.go | 12 +++++------ aeron/atomic/buffer.go | 2 +- aeron/broadcast/copyreceiver.go | 3 ++- aeron/broadcast/receiver.go | 6 +++--- aeron/clientconductor.go | 14 ++++++------- aeron/command/flyweights.go | 4 ++-- aeron/context.go | 4 ++-- aeron/counters/counters.go | 10 +++++----- aeron/counters/reader.go | 4 ++-- aeron/driver/flyweights.go | 4 ++-- aeron/driver/listeneradapter.go | 8 ++++---- aeron/driver/proxy.go | 6 +++--- aeron/flyweight/fields.go | 5 +++-- aeron/flyweight/flightweight_test.go | 3 ++- aeron/flyweight/flyweight.go | 2 +- aeron/fragmentassembler.go | 6 +++--- aeron/image.go | 8 ++++---- aeron/logbuffer/FrameDescriptor.go | 2 +- aeron/logbuffer/claim.go | 3 ++- aeron/logbuffer/descriptor.go | 7 ++++--- aeron/logbuffer/header.go | 4 ++-- aeron/logbuffer/logbuffers.go | 7 ++++--- aeron/logbuffer/logbuffers_test.go | 9 +++++---- aeron/logbuffer/term/appender.go | 8 ++++---- aeron/logbuffer/term/reader.go | 6 +++--- aeron/position.go | 4 ++-- aeron/publication.go | 10 +++++----- aeron/publication_test.go | 17 ++++++++-------- aeron/ringbuffer/manytoone.go | 5 +++-- aeron/ringbuffer/recorddesc.go | 3 ++- aeron/stat/aeron_stat.go | 5 +++-- aeron/subscription.go | 4 ++-- aeron/util/memmap/memmap.go | 2 +- aeron/util/memmap/memmap_test.go | 3 ++- archive/archive.go | 11 +++++----- archive/archive_test.go | 9 +++++---- archive/benchmarks_test.go | 5 +++-- archive/config_test.go | 3 ++- archive/control.go | 11 +++++----- .../basic_recording_publisher.go | 13 ++++++------ .../basic_replayed_subscriber.go | 15 +++++++------- archive/examples/examplesconfig.go | 3 ++- archive/options.go | 5 +++-- archive/proxy.go | 9 +++++---- archive/recordingevents.go | 9 +++++---- cluster/bounded_log_adapter.go | 8 ++++---- cluster/client_session.go | 6 +++--- cluster/cluster.go | 2 +- cluster/clustered_service.go | 8 ++++---- cluster/clustered_service_agent.go | 20 +++++++++---------- cluster/consensus_module_proxy.go | 8 ++++---- cluster/mark_file.go | 7 ++++--- cluster/mark_file_header_flyweight.go | 4 ++-- cluster/options.go | 4 ++-- cluster/service_adapter.go | 8 ++++---- cluster/snapshot_loader.go | 8 ++++---- cluster/snapshot_taker.go | 6 +++--- examples/basic_publisher/basic_publisher.go | 9 +++++---- .../basic_publisher_claim.go | 9 +++++---- examples/basic_subscriber/basic_subscriber.go | 12 +++++------ examples/cluster/echo_service.go | 12 +++++------ examples/common.go | 3 ++- examples/ping/ping.go | 13 ++++++------ examples/pong/pong.go | 13 ++++++------ go.mod | 2 +- systests/systest.go | 8 ++++---- 66 files changed, 246 insertions(+), 217 deletions(-) diff --git a/aeron/aeron.go b/aeron/aeron.go index ed6e8fa7..4b2970b0 100644 --- a/aeron/aeron.go +++ b/aeron/aeron.go @@ -17,12 +17,12 @@ package aeron import ( "time" - "github.com/corymonroe-coinbase/aeron-go/aeron/broadcast" - "github.com/corymonroe-coinbase/aeron-go/aeron/counters" - "github.com/corymonroe-coinbase/aeron-go/aeron/driver" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - rb "github.com/corymonroe-coinbase/aeron-go/aeron/ringbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" + "github.com/lirm/aeron-go/aeron/broadcast" + "github.com/lirm/aeron-go/aeron/counters" + "github.com/lirm/aeron-go/aeron/driver" + "github.com/lirm/aeron-go/aeron/logging" + rb "github.com/lirm/aeron-go/aeron/ringbuffer" + "github.com/lirm/aeron-go/aeron/util/memmap" ) // NewPublicationHandler is the handler type for new publication notification from the media driver diff --git a/aeron/atomic/buffer.go b/aeron/atomic/buffer.go index 24b661e6..71030e48 100644 --- a/aeron/atomic/buffer.go +++ b/aeron/atomic/buffer.go @@ -24,7 +24,7 @@ import ( "sync/atomic" "unsafe" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/util" ) // Buffer is the equivalent of AtomicBuffer used by Aeron Java and C++ implementations. It provides diff --git a/aeron/broadcast/copyreceiver.go b/aeron/broadcast/copyreceiver.go index c844f8cc..e72a25d5 100644 --- a/aeron/broadcast/copyreceiver.go +++ b/aeron/broadcast/copyreceiver.go @@ -18,7 +18,8 @@ package broadcast import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" + + "github.com/lirm/aeron-go/aeron/atomic" ) type Handler func(int32, *atomic.Buffer, int32, int32) diff --git a/aeron/broadcast/receiver.go b/aeron/broadcast/receiver.go index b5a71ca6..ca20268b 100644 --- a/aeron/broadcast/receiver.go +++ b/aeron/broadcast/receiver.go @@ -19,9 +19,9 @@ package broadcast import ( "log" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - rb "github.com/corymonroe-coinbase/aeron-go/aeron/ringbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + rb "github.com/lirm/aeron-go/aeron/ringbuffer" + "github.com/lirm/aeron-go/aeron/util" ) var BufferDescriptor = struct { diff --git a/aeron/clientconductor.go b/aeron/clientconductor.go index b572694d..a7f46b21 100644 --- a/aeron/clientconductor.go +++ b/aeron/clientconductor.go @@ -25,13 +25,13 @@ import ( "sync" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/broadcast" - ctr "github.com/corymonroe-coinbase/aeron-go/aeron/counters" - "github.com/corymonroe-coinbase/aeron-go/aeron/driver" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/broadcast" + ctr "github.com/lirm/aeron-go/aeron/counters" + "github.com/lirm/aeron-go/aeron/driver" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" ) var RegistrationStatus = struct { diff --git a/aeron/command/flyweights.go b/aeron/command/flyweights.go index 9ca93015..5dbcbee5 100644 --- a/aeron/command/flyweights.go +++ b/aeron/command/flyweights.go @@ -17,8 +17,8 @@ limitations under the License. package command import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" ) type CorrelatedMessage struct { diff --git a/aeron/context.go b/aeron/context.go index afd98f94..d1c12919 100644 --- a/aeron/context.go +++ b/aeron/context.go @@ -19,8 +19,8 @@ package aeron import ( "time" - "github.com/corymonroe-coinbase/aeron-go/aeron/counters" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/counters" + "github.com/lirm/aeron-go/aeron/idlestrategy" ) // Context configuration options are located here https://github.com/real-logic/Aeron/wiki/Configuration-Options#aeron-client-options diff --git a/aeron/counters/counters.go b/aeron/counters/counters.go index 098af884..af2d86a2 100644 --- a/aeron/counters/counters.go +++ b/aeron/counters/counters.go @@ -20,12 +20,12 @@ import ( "errors" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/util/memmap" ) var logger = logging.MustGetLogger("counters") diff --git a/aeron/counters/reader.go b/aeron/counters/reader.go index f53d9bac..58369b50 100644 --- a/aeron/counters/reader.go +++ b/aeron/counters/reader.go @@ -20,8 +20,8 @@ import ( "fmt" "unsafe" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" ) const COUNTER_LENGTH = util.CacheLineLength * 2 diff --git a/aeron/driver/flyweights.go b/aeron/driver/flyweights.go index 8df7e967..b0de0603 100644 --- a/aeron/driver/flyweights.go +++ b/aeron/driver/flyweights.go @@ -17,8 +17,8 @@ limitations under the License. package driver import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" ) /** diff --git a/aeron/driver/listeneradapter.go b/aeron/driver/listeneradapter.go index d3300382..a884e77e 100644 --- a/aeron/driver/listeneradapter.go +++ b/aeron/driver/listeneradapter.go @@ -17,11 +17,11 @@ limitations under the License. package driver import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/broadcast" - "github.com/corymonroe-coinbase/aeron-go/aeron/command" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/broadcast" + "github.com/lirm/aeron-go/aeron/command" ) var logger = logging.MustGetLogger("driver") diff --git a/aeron/driver/proxy.go b/aeron/driver/proxy.go index 43d1eae2..c28d3b1e 100644 --- a/aeron/driver/proxy.go +++ b/aeron/driver/proxy.go @@ -17,9 +17,9 @@ limitations under the License. package driver import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/command" - rb "github.com/corymonroe-coinbase/aeron-go/aeron/ringbuffer" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/command" + rb "github.com/lirm/aeron-go/aeron/ringbuffer" ) // Proxy is a media driver proxy class that is used to send commands diff --git a/aeron/flyweight/fields.go b/aeron/flyweight/fields.go index 2272efb6..1be2dac1 100644 --- a/aeron/flyweight/fields.go +++ b/aeron/flyweight/fields.go @@ -17,10 +17,11 @@ limitations under the License. package flyweight import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" syncatomic "sync/atomic" "unsafe" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" ) // Field is the interface for a field in a flyweight wrapper. It expects a preallocated buffer and offset into it, as diff --git a/aeron/flyweight/flightweight_test.go b/aeron/flyweight/flightweight_test.go index f694d33a..1d319969 100644 --- a/aeron/flyweight/flightweight_test.go +++ b/aeron/flyweight/flightweight_test.go @@ -17,8 +17,9 @@ limitations under the License. package flyweight import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" "testing" + + "github.com/lirm/aeron-go/aeron/atomic" ) type StringFly struct { diff --git a/aeron/flyweight/flyweight.go b/aeron/flyweight/flyweight.go index 17fa0dbd..91de36ef 100644 --- a/aeron/flyweight/flyweight.go +++ b/aeron/flyweight/flyweight.go @@ -16,7 +16,7 @@ limitations under the License. package flyweight -import "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" +import "github.com/lirm/aeron-go/aeron/atomic" type Flyweight interface { Wrap(*atomic.Buffer, int) Flyweight diff --git a/aeron/fragmentassembler.go b/aeron/fragmentassembler.go index 2ac61751..bb36f819 100644 --- a/aeron/fragmentassembler.go +++ b/aeron/fragmentassembler.go @@ -19,9 +19,9 @@ package aeron import ( "bytes" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logbuffer/term" ) const ( diff --git a/aeron/image.go b/aeron/image.go index f7a51706..b51fcdfc 100644 --- a/aeron/image.go +++ b/aeron/image.go @@ -17,10 +17,10 @@ limitations under the License. package aeron import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron/util" ) type ControlledPollFragmentHandler func(buffer *atomic.Buffer, offset int32, length int32, header *logbuffer.Header) diff --git a/aeron/logbuffer/FrameDescriptor.go b/aeron/logbuffer/FrameDescriptor.go index 5fdaec05..9f1292ad 100644 --- a/aeron/logbuffer/FrameDescriptor.go +++ b/aeron/logbuffer/FrameDescriptor.go @@ -17,7 +17,7 @@ limitations under the License. package logbuffer import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/atomic" ) const ( diff --git a/aeron/logbuffer/claim.go b/aeron/logbuffer/claim.go index 75520c8a..2e0d3c7b 100644 --- a/aeron/logbuffer/claim.go +++ b/aeron/logbuffer/claim.go @@ -17,8 +17,9 @@ limitations under the License. package logbuffer import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" "unsafe" + + "github.com/lirm/aeron-go/aeron/atomic" ) type Claim struct { diff --git a/aeron/logbuffer/descriptor.go b/aeron/logbuffer/descriptor.go index cba4c91a..1e690c4d 100644 --- a/aeron/logbuffer/descriptor.go +++ b/aeron/logbuffer/descriptor.go @@ -18,9 +18,10 @@ package logbuffer import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/util" ) const ( diff --git a/aeron/logbuffer/header.go b/aeron/logbuffer/header.go index b68e5f05..b4d3a257 100644 --- a/aeron/logbuffer/header.go +++ b/aeron/logbuffer/header.go @@ -19,8 +19,8 @@ package logbuffer import ( "unsafe" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" ) type Header struct { diff --git a/aeron/logbuffer/logbuffers.go b/aeron/logbuffer/logbuffers.go index 5549da48..6bf66a62 100644 --- a/aeron/logbuffer/logbuffers.go +++ b/aeron/logbuffer/logbuffers.go @@ -17,10 +17,11 @@ limitations under the License. package logbuffer import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" "unsafe" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/util/memmap" ) var logger = logging.MustGetLogger("logbuffers") diff --git a/aeron/logbuffer/logbuffers_test.go b/aeron/logbuffer/logbuffers_test.go index 9eac7f53..93b98219 100644 --- a/aeron/logbuffer/logbuffers_test.go +++ b/aeron/logbuffer/logbuffers_test.go @@ -18,12 +18,13 @@ package logbuffer import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" "testing" "unsafe" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/util/memmap" ) func prepareFile(t *testing.T) *LogBuffers { diff --git a/aeron/logbuffer/term/appender.go b/aeron/logbuffer/term/appender.go index 26f90ac6..e22cd059 100644 --- a/aeron/logbuffer/term/appender.go +++ b/aeron/logbuffer/term/appender.go @@ -17,10 +17,10 @@ limitations under the License. package term import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/util" ) const ( diff --git a/aeron/logbuffer/term/reader.go b/aeron/logbuffer/term/reader.go index 233fc1dc..8762c54e 100644 --- a/aeron/logbuffer/term/reader.go +++ b/aeron/logbuffer/term/reader.go @@ -17,9 +17,9 @@ limitations under the License. package term import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/util" ) // FragmentHandler is the main callback interface for received data diff --git a/aeron/position.go b/aeron/position.go index c3a874f0..6467d4de 100644 --- a/aeron/position.go +++ b/aeron/position.go @@ -17,8 +17,8 @@ limitations under the License. package aeron import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" ) // Position is a wrapper for a buffer location of a position counter diff --git a/aeron/publication.go b/aeron/publication.go index c7c711d9..15a4fd65 100644 --- a/aeron/publication.go +++ b/aeron/publication.go @@ -19,11 +19,11 @@ package aeron import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/util" ) const ( diff --git a/aeron/publication_test.go b/aeron/publication_test.go index d9ce7c0c..58fbdbd8 100644 --- a/aeron/publication_test.go +++ b/aeron/publication_test.go @@ -17,18 +17,19 @@ limitations under the License. package aeron import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/counters" - "github.com/corymonroe-coinbase/aeron-go/aeron/driver" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/ringbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" "os" "testing" "time" "unsafe" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/counters" + "github.com/lirm/aeron-go/aeron/driver" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/ringbuffer" + "github.com/lirm/aeron-go/aeron/util" + "github.com/lirm/aeron-go/aeron/util/memmap" ) func prepareFile(t *testing.T) (string, *logbuffer.LogBuffers) { diff --git a/aeron/ringbuffer/manytoone.go b/aeron/ringbuffer/manytoone.go index dff7332a..d02ad92d 100644 --- a/aeron/ringbuffer/manytoone.go +++ b/aeron/ringbuffer/manytoone.go @@ -18,8 +18,9 @@ package rb import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" ) const insufficientCapacity int32 = -2 diff --git a/aeron/ringbuffer/recorddesc.go b/aeron/ringbuffer/recorddesc.go index c276e26e..b30c7cbf 100644 --- a/aeron/ringbuffer/recorddesc.go +++ b/aeron/ringbuffer/recorddesc.go @@ -18,7 +18,8 @@ package rb import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" + + "github.com/lirm/aeron-go/aeron/util" ) var RecordDescriptor = struct { diff --git a/aeron/stat/aeron_stat.go b/aeron/stat/aeron_stat.go index f48c8408..097186a2 100644 --- a/aeron/stat/aeron_stat.go +++ b/aeron/stat/aeron_stat.go @@ -18,9 +18,10 @@ package main import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/counters" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/counters" ) var ansiCls = "\u001b[2J" diff --git a/aeron/subscription.go b/aeron/subscription.go index 6a5d2660..760639f8 100644 --- a/aeron/subscription.go +++ b/aeron/subscription.go @@ -17,8 +17,8 @@ limitations under the License. package aeron import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer/term" ) // Subscription is the object responsible for receiving messages from media driver. It is specific to a channel and diff --git a/aeron/util/memmap/memmap.go b/aeron/util/memmap/memmap.go index 8293e9c1..0d1e9a7d 100644 --- a/aeron/util/memmap/memmap.go +++ b/aeron/util/memmap/memmap.go @@ -23,8 +23,8 @@ import ( "syscall" "unsafe" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" mapper "github.com/edsrzf/mmap-go" + "github.com/lirm/aeron-go/aeron/logging" ) // File is the wrapper around memory mapped file diff --git a/aeron/util/memmap/memmap_test.go b/aeron/util/memmap/memmap_test.go index 6cb255a6..d44f6305 100644 --- a/aeron/util/memmap/memmap_test.go +++ b/aeron/util/memmap/memmap_test.go @@ -16,8 +16,9 @@ package memmap import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" "testing" + + "github.com/lirm/aeron-go/aeron/atomic" ) const ( diff --git a/archive/archive.go b/archive/archive.go index d606f08b..e7625d41 100644 --- a/archive/archive.go +++ b/archive/archive.go @@ -19,13 +19,14 @@ package archive import ( "errors" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" "sync" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/archive/codecs" ) // Archive is the primary interface to the media driver for managing archiving diff --git a/archive/archive_test.go b/archive/archive_test.go index dc06a002..d08f3540 100644 --- a/archive/archive_test.go +++ b/archive/archive_test.go @@ -16,16 +16,17 @@ package archive import ( "flag" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" "log" "math/rand" "os" "sync" "testing" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/archive/codecs" ) // Rather than mock or spawn an archive-media-driver we're just seeing diff --git a/archive/benchmarks_test.go b/archive/benchmarks_test.go index 507fded4..867ee4ff 100644 --- a/archive/benchmarks_test.go +++ b/archive/benchmarks_test.go @@ -16,9 +16,10 @@ package archive import ( "bytes" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" "testing" + + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/archive/codecs" ) // check to see if this is worth avoiding in the fragment handlers diff --git a/archive/config_test.go b/archive/config_test.go index d14fec88..5df3e72e 100644 --- a/archive/config_test.go +++ b/archive/config_test.go @@ -16,7 +16,8 @@ package archive import ( "flag" - "github.com/corymonroe-coinbase/aeron-go/aeron" + + "github.com/lirm/aeron-go/aeron" ) // TestConfig defaults diff --git a/archive/control.go b/archive/control.go index ee569cd8..b9414a19 100644 --- a/archive/control.go +++ b/archive/control.go @@ -17,12 +17,13 @@ package archive import ( "bytes" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/archive/codecs" ) // Control contains everything required for the archive subscription/response side diff --git a/archive/examples/basic_recording_publisher/basic_recording_publisher.go b/archive/examples/basic_recording_publisher/basic_recording_publisher.go index 55ef84a8..bd9764b8 100644 --- a/archive/examples/basic_recording_publisher/basic_recording_publisher.go +++ b/archive/examples/basic_recording_publisher/basic_recording_publisher.go @@ -18,14 +18,15 @@ package main import ( "flag" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/archive" - "github.com/corymonroe-coinbase/aeron-go/archive/examples" "os" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/archive" + "github.com/lirm/aeron-go/archive/examples" ) var logID = "basic_recording_publisher" diff --git a/archive/examples/basic_replayed_subscriber/basic_replayed_subscriber.go b/archive/examples/basic_replayed_subscriber/basic_replayed_subscriber.go index c24493d8..310ec10e 100644 --- a/archive/examples/basic_replayed_subscriber/basic_replayed_subscriber.go +++ b/archive/examples/basic_replayed_subscriber/basic_replayed_subscriber.go @@ -18,15 +18,16 @@ package main import ( "flag" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/archive" - "github.com/corymonroe-coinbase/aeron-go/archive/examples" "math" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/archive" + "github.com/lirm/aeron-go/archive/examples" ) var logID = "basic_recording_subscriber" diff --git a/archive/examples/examplesconfig.go b/archive/examples/examplesconfig.go index af1fedef..87a6efa5 100644 --- a/archive/examples/examplesconfig.go +++ b/archive/examples/examplesconfig.go @@ -16,7 +16,8 @@ package examples import ( "flag" - "github.com/corymonroe-coinbase/aeron-go/aeron" + + "github.com/lirm/aeron-go/aeron" ) // Config defaults diff --git a/archive/options.go b/archive/options.go index eee959b6..7db57be2 100644 --- a/archive/options.go +++ b/archive/options.go @@ -15,9 +15,10 @@ package archive import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "go.uber.org/zap/zapcore" "time" + + "github.com/lirm/aeron-go/aeron/idlestrategy" + "go.uber.org/zap/zapcore" ) // Options are set by NewArchive() with the default options specified below diff --git a/archive/proxy.go b/archive/proxy.go index 641672db..70c03c3d 100644 --- a/archive/proxy.go +++ b/archive/proxy.go @@ -16,11 +16,12 @@ package archive import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/archive/codecs" ) // Proxy class for encapsulating encoding and sending of control protocol messages to an archive diff --git a/archive/recordingevents.go b/archive/recordingevents.go index c98df469..7ec16375 100644 --- a/archive/recordingevents.go +++ b/archive/recordingevents.go @@ -17,10 +17,11 @@ package archive import ( "bytes" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/archive/codecs" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/archive/codecs" ) // RecordingEventsAdapter is used to poll for recording events on a subscription. diff --git a/cluster/bounded_log_adapter.go b/cluster/bounded_log_adapter.go index 19c58397..4fcd0b07 100644 --- a/cluster/bounded_log_adapter.go +++ b/cluster/bounded_log_adapter.go @@ -3,10 +3,10 @@ package cluster import ( "bytes" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/cluster/codecs" ) const ( diff --git a/cluster/client_session.go b/cluster/client_session.go index 41959992..1c1b4a47 100644 --- a/cluster/client_session.go +++ b/cluster/client_session.go @@ -1,9 +1,9 @@ package cluster import ( - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer/term" ) const ( diff --git a/cluster/cluster.go b/cluster/cluster.go index de0dd923..97e9bc01 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -1,6 +1,6 @@ package cluster -import "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" +import "github.com/lirm/aeron-go/aeron/idlestrategy" type Cluster interface { LogPosition() int64 diff --git a/cluster/clustered_service.go b/cluster/clustered_service.go index 9acdc20b..9704bb69 100644 --- a/cluster/clustered_service.go +++ b/cluster/clustered_service.go @@ -1,10 +1,10 @@ package cluster import ( - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/cluster/codecs" ) type ClusteredService interface { diff --git a/cluster/clustered_service_agent.go b/cluster/clustered_service_agent.go index aa2675e9..249b93cd 100644 --- a/cluster/clustered_service_agent.go +++ b/cluster/clustered_service_agent.go @@ -5,16 +5,16 @@ import ( "strings" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/counters" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer/term" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/aeron/util" - "github.com/corymonroe-coinbase/aeron-go/archive" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/counters" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logbuffer/term" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron/util" + "github.com/lirm/aeron-go/archive" + "github.com/lirm/aeron-go/cluster/codecs" ) const NullValue = -1 diff --git a/cluster/consensus_module_proxy.go b/cluster/consensus_module_proxy.go index 28f39192..ba7d96ba 100644 --- a/cluster/consensus_module_proxy.go +++ b/cluster/consensus_module_proxy.go @@ -3,10 +3,10 @@ package cluster import ( "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/cluster/codecs" ) const ( diff --git a/cluster/mark_file.go b/cluster/mark_file.go index 465c459a..a4dbcf5f 100644 --- a/cluster/mark_file.go +++ b/cluster/mark_file.go @@ -1,13 +1,14 @@ package cluster import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/util" "os" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/util" + + "github.com/lirm/aeron-go/aeron/atomic" // "github.com/lirm/aeron-go/aeron/util" - "github.com/corymonroe-coinbase/aeron-go/aeron/util/memmap" + "github.com/lirm/aeron-go/aeron/util/memmap" ) const ( diff --git a/cluster/mark_file_header_flyweight.go b/cluster/mark_file_header_flyweight.go index e26c18f5..b4cc9755 100644 --- a/cluster/mark_file_header_flyweight.go +++ b/cluster/mark_file_header_flyweight.go @@ -1,8 +1,8 @@ package cluster import ( - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/flyweight" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/flyweight" ) type MarkFileHeaderFlyweight struct { diff --git a/cluster/options.go b/cluster/options.go index 9ffffa9a..b4cef0d3 100644 --- a/cluster/options.go +++ b/cluster/options.go @@ -3,8 +3,8 @@ package cluster import ( "time" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/archive" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/archive" "go.uber.org/zap/zapcore" ) diff --git a/cluster/service_adapter.go b/cluster/service_adapter.go index c64d7808..8be8dabf 100644 --- a/cluster/service_adapter.go +++ b/cluster/service_adapter.go @@ -3,10 +3,10 @@ package cluster import ( "bytes" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/cluster/codecs" ) type serviceAdapter struct { diff --git a/cluster/snapshot_loader.go b/cluster/snapshot_loader.go index 27f79121..be83bc3e 100644 --- a/cluster/snapshot_loader.go +++ b/cluster/snapshot_loader.go @@ -4,10 +4,10 @@ import ( "bytes" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/cluster/codecs" ) type snapshotLoader struct { diff --git a/cluster/snapshot_taker.go b/cluster/snapshot_taker.go index 5dcee36f..e7cf7d58 100644 --- a/cluster/snapshot_taker.go +++ b/cluster/snapshot_taker.go @@ -4,9 +4,9 @@ import ( "fmt" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/cluster/codecs" ) const snapshotTypeId = 2 diff --git a/examples/basic_publisher/basic_publisher.go b/examples/basic_publisher/basic_publisher.go index e98e524e..75d447fc 100644 --- a/examples/basic_publisher/basic_publisher.go +++ b/examples/basic_publisher/basic_publisher.go @@ -19,12 +19,13 @@ package main import ( "flag" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/examples" "log" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/examples" ) var logger = logging.MustGetLogger("basic_publisher") diff --git a/examples/basic_publisher_claim/basic_publisher_claim.go b/examples/basic_publisher_claim/basic_publisher_claim.go index 40e46ac1..0243b429 100644 --- a/examples/basic_publisher_claim/basic_publisher_claim.go +++ b/examples/basic_publisher_claim/basic_publisher_claim.go @@ -19,12 +19,13 @@ package main import ( "flag" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/examples" "log" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/examples" ) var logger = logging.MustGetLogger("basic_publisher_claim") diff --git a/examples/basic_subscriber/basic_subscriber.go b/examples/basic_subscriber/basic_subscriber.go index a6c0550b..5e77713a 100644 --- a/examples/basic_subscriber/basic_subscriber.go +++ b/examples/basic_subscriber/basic_subscriber.go @@ -23,12 +23,12 @@ import ( "log" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/examples" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/examples" ) var logger = logging.MustGetLogger("basic_subscriber") diff --git a/examples/cluster/echo_service.go b/examples/cluster/echo_service.go index 7a895f33..c9ba44bc 100644 --- a/examples/cluster/echo_service.go +++ b/examples/cluster/echo_service.go @@ -4,12 +4,12 @@ import ( "fmt" "os" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/cluster" - "github.com/corymonroe-coinbase/aeron-go/cluster/codecs" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/cluster" + "github.com/lirm/aeron-go/cluster/codecs" ) type EchoService struct { diff --git a/examples/common.go b/examples/common.go index 11d6f8b6..0ce4e339 100644 --- a/examples/common.go +++ b/examples/common.go @@ -18,7 +18,8 @@ package examples import ( "flag" - "github.com/corymonroe-coinbase/aeron-go/aeron" + + "github.com/lirm/aeron-go/aeron" ) var ExamplesConfig = struct { diff --git a/examples/ping/ping.go b/examples/ping/ping.go index 6635867a..5a5335a4 100644 --- a/examples/ping/ping.go +++ b/examples/ping/ping.go @@ -19,16 +19,17 @@ package main import ( "flag" "fmt" - "github.com/HdrHistogram/hdrhistogram-go" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/examples" "io" "os" "runtime/pprof" "time" + + "github.com/HdrHistogram/hdrhistogram-go" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/examples" ) var logger = logging.MustGetLogger("examples") diff --git a/examples/pong/pong.go b/examples/pong/pong.go index 7b674ce2..21b34436 100644 --- a/examples/pong/pong.go +++ b/examples/pong/pong.go @@ -19,17 +19,18 @@ package main import ( "flag" "fmt" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/idlestrategy" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" - "github.com/corymonroe-coinbase/aeron-go/examples" "os" "os/signal" "runtime/pprof" "syscall" "time" + + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/idlestrategy" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/examples" ) var logger = logging.MustGetLogger("examples") diff --git a/go.mod b/go.mod index b35cde2b..6267ba59 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/corymonroe-coinbase/aeron-go +module github.com/lirm/aeron-go go 1.12 diff --git a/systests/systest.go b/systests/systest.go index 43c8d45b..0ed68182 100644 --- a/systests/systest.go +++ b/systests/systest.go @@ -21,10 +21,10 @@ import ( "fmt" "time" - "github.com/corymonroe-coinbase/aeron-go/aeron" - "github.com/corymonroe-coinbase/aeron-go/aeron/atomic" - "github.com/corymonroe-coinbase/aeron-go/aeron/logbuffer" - "github.com/corymonroe-coinbase/aeron-go/aeron/logging" + "github.com/lirm/aeron-go/aeron" + "github.com/lirm/aeron-go/aeron/atomic" + "github.com/lirm/aeron-go/aeron/logbuffer" + "github.com/lirm/aeron-go/aeron/logging" ) var ExamplesConfig = struct {