This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from fb8eff2f0 fix(triple): case-insensitive method routing without
metadata polluti… (#3277)
add c356735e9 feat: graceful shutdown #1977 (#3235)
No new revisions were added by this update.
Summary of changes:
cluster/directory/directory.go | 6 +
common/constant/key.go | 3 +
common/extension/graceful_shutdown.go | 80 ++++-
common/extension/graceful_shutdown_test.go | 62 ++++
common/extension/otel_trace.go | 2 +-
compat.go | 2 +
config/graceful_shutdown_config.go | 25 +-
config/root_config.go | 4 +-
filter/graceful_shutdown/compat.go | 1 +
filter/graceful_shutdown/consumer_filter.go | 165 ++++++++++-
filter/graceful_shutdown/consumer_filter_test.go | 155 ++++++++++
filter/graceful_shutdown/provider_filter.go | 53 +++-
filter/graceful_shutdown/provider_filter_test.go | 33 +++
global/shutdown_config.go | 18 +-
graceful_shutdown/closing_ack.go | 98 ++++++
.../{common.go => closing_handler.go} | 37 +--
graceful_shutdown/closing_registry.go | 153 ++++++++++
graceful_shutdown/closing_registry_test.go | 128 ++++++++
graceful_shutdown/options.go | 6 +
graceful_shutdown/options_test.go | 10 +-
graceful_shutdown/shutdown.go | 190 +++++++++++-
graceful_shutdown/shutdown_test.go | 329 +++++++++++++++++++++
internal/internal.go | 3 +
protocol/base/base_invoker.go | 10 +
protocol/base/base_protocol.go | 7 +
protocol/grpc/active_notify_test.go | 139 +++++++++
protocol/grpc/grpc_invoker.go | 63 +++-
protocol/grpc/grpc_protocol.go | 54 +++-
protocol/grpc/grpc_protocol_test.go | 58 ++++
protocol/grpc/server.go | 38 ++-
protocol/triple/active_notify_test.go | 154 ++++++++++
protocol/triple/client.go | 29 +-
protocol/triple/health/healthServer.go | 1 +
protocol/triple/triple.go | 45 ++-
protocol/triple/triple_invoker.go | 64 +++-
protocol/triple/triple_test.go | 78 +++++
registry/directory/directory.go | 129 +++++++-
registry/directory/directory_test.go | 104 +++++++
registry/protocol/protocol.go | 13 +
39 files changed, 2460 insertions(+), 89 deletions(-)
create mode 100644 common/extension/graceful_shutdown_test.go
create mode 100644 graceful_shutdown/closing_ack.go
copy graceful_shutdown/{common.go => closing_handler.go} (52%)
create mode 100644 graceful_shutdown/closing_registry.go
create mode 100644 graceful_shutdown/closing_registry_test.go
create mode 100644 protocol/grpc/active_notify_test.go
create mode 100644 protocol/triple/active_notify_test.go
