This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
from 4389991a8b chore(plc4go): code sync
new 09147a8d95 refactor(plc4go/spi): move transaction manager to own
package
new c4bf3ebd62 refactor(plc4go/spi): move WorkerPool to own package
new b330c7ce33 feat(plc4go/spi): Introduce new WithCustomLogger option
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
plc4go/internal/bacnetip/Connection.go | 5 +-
plc4go/internal/bacnetip/Driver.go | 6 +-
plc4go/internal/bacnetip/Reader.go | 7 +-
plc4go/internal/cbus/Browser.go | 73 +-
plc4go/internal/cbus/Browser_test.go | 351 +++++-----
plc4go/internal/cbus/CBusMessageMapper.go | 8 +-
plc4go/internal/cbus/CBusMessageMapper_test.go | 589 +++++++++++-----
plc4go/internal/cbus/Configuration.go | 10 +-
plc4go/internal/cbus/Configuration_test.go | 5 +-
plc4go/internal/cbus/Connection.go | 101 +--
plc4go/internal/cbus/Connection_test.go | 742 +++++++++++++--------
plc4go/internal/cbus/Discoverer.go | 43 +-
plc4go/internal/cbus/Discoverer_test.go | 53 +-
plc4go/internal/cbus/Driver.go | 39 +-
plc4go/internal/cbus/Driver_test.go | 8 +-
plc4go/internal/cbus/MessageCodec.go | 66 +-
plc4go/internal/cbus/Reader.go | 40 +-
plc4go/internal/cbus/Reader_test.go | 35 +-
plc4go/internal/cbus/Subscriber.go | 35 +-
plc4go/internal/cbus/Writer.go | 22 +-
plc4go/internal/cbus/Writer_test.go | 6 +-
.../internal/cbus/mock_RequestTransaction_test.go | 12 +-
plc4go/internal/cbus/mock_requirements.go | 6 +-
.../cbus/noGlobalLog_test.go} | 7 +-
plc4go/internal/eip/Connection.go | 5 +-
plc4go/internal/eip/EipDriver.go | 6 +-
plc4go/internal/eip/Reader.go | 7 +-
plc4go/internal/eip/Writer.go | 9 +-
plc4go/internal/knxnetip/Discoverer.go | 14 +-
plc4go/internal/s7/Connection.go | 5 +-
plc4go/internal/s7/Driver.go | 6 +-
plc4go/internal/s7/Reader.go | 7 +-
plc4go/internal/s7/Writer.go | 7 +-
plc4go/pkg/api/driver.go | 2 +-
plc4go/pkg/api/mock_PlcDriver_test.go | 16 +-
plc4go/pkg/api/mock_Transport_test.go | 51 +-
.../protocols/cbus/readwrite/model/StaticHelper.go | 7 +-
plc4go/spi/default/DefaultCodec.go | 55 +-
plc4go/spi/default/DefaultConnection.go | 31 +-
plc4go/spi/default/DefaultDriver.go | 2 +-
.../default/mock_DefaultDriverRequirements_test.go | 16 +-
plc4go/spi/default/mock_DefaultDriver_test.go | 16 +-
plc4go/spi/mock_requirements.go | 4 +-
plc4go/spi/options/Option.go | 35 +
plc4go/spi/{utils => pool}/WorkerPool.go | 82 ++-
plc4go/spi/{utils => pool}/WorkerPool_test.go | 55 +-
.../spi/{ => pool}/mock_CompletionFuture_test.go | 2 +-
plc4go/spi/{utils => pool}/mock_Executor_test.go | 43 +-
plc4go/spi/{utils => pool}/mock_Runnable_test.go | 2 +-
plc4go/spi/testutils/TestUtils.go | 34 +
.../RequestTransactionManager.go | 97 ++-
.../RequestTransactionManager_test.go | 49 +-
.../mock_CompletionFuture_test.go | 2 +-
.../mock_RequestTransactionManagerOption_test.go | 2 +-
.../mock_RequestTransactionManager_test.go | 91 ++-
.../mock_RequestTransactionRunnable_test.go | 16 +-
.../mock_RequestTransaction_test.go | 2 +-
plc4go/spi/{ => transactions}/mock_requirements.go | 6 +-
plc4go/spi/transports/Transport.go | 7 +-
plc4go/spi/transports/mock_Transport_test.go | 50 +-
plc4go/spi/transports/pcap/Transport.go | 36 +-
plc4go/spi/transports/serial/Transport.go | 35 +-
plc4go/spi/transports/tcp/Transport.go | 14 +-
plc4go/spi/transports/test/Transport.go | 48 +-
plc4go/spi/transports/udp/Transport.go | 23 +-
plc4go/spi/utils/mock_ExecutorOption_test.go | 85 ---
66 files changed, 2079 insertions(+), 1272 deletions(-)
copy plc4go/{pkg/api/model/plc_request.go =>
internal/cbus/noGlobalLog_test.go} (88%)
rename plc4go/spi/{utils => pool}/WorkerPool.go (80%)
rename plc4go/spi/{utils => pool}/WorkerPool_test.go (93%)
copy plc4go/spi/{ => pool}/mock_CompletionFuture_test.go (99%)
rename plc4go/spi/{utils => pool}/mock_Executor_test.go (85%)
copy plc4go/spi/{utils => pool}/mock_Runnable_test.go (99%)
rename plc4go/spi/{ => transactions}/RequestTransactionManager.go (77%)
rename plc4go/spi/{ => transactions}/RequestTransactionManager_test.go (94%)
copy plc4go/spi/{ => transactions}/mock_CompletionFuture_test.go (99%)
rename plc4go/spi/{ =>
transactions}/mock_RequestTransactionManagerOption_test.go (99%)
rename plc4go/spi/{ => transactions}/mock_RequestTransactionManager_test.go
(64%)
rename plc4go/spi/{ => transactions}/mock_RequestTransactionRunnable_test.go
(85%)
rename plc4go/spi/{ => transactions}/mock_RequestTransaction_test.go (99%)
copy plc4go/spi/{ => transactions}/mock_requirements.go (91%)
delete mode 100644 plc4go/spi/utils/mock_ExecutorOption_test.go
