fluent / fluent-plugin-opensearch

93%

main: 93%

LAST BUILD ON BRANCH fix-flush

branch: fix-flush

CHANGE BRANCH

x

Reset

• fix-flush
• add-constraint-for-faraday-middleware
• add-ism-documentation-in-troubleshooting-doc
• add-testcases-for-hosts-parameter
• add-to-project
• adjust-github-workflows
• align-lowercases
• allow_duplicate_key
• ci-add-ruby-3.2
• ci-grouping-pr
• ci-sha
• configurable-unrecoverable-record-types
• dependabot.yml
• dependabot/github_actions/actions/add-to-project-2.0.0
• dependabot/github_actions/actions/checkout-6.0.3
• dependabot/github_actions/actions/create-github-app-token-3.1.1
• dependabot/github_actions/actions/create-github-app-token-3.2.0
• dependabot/github_actions/coverallsapp/github-action-2.3.6
• dependabot/github_actions/monthly-updates-a7c1315158
• dependabot/github_actions/monthly-updates-b381ee1f94
• dependabot/github_actions/roots/issue-closer-action-1.2
• dependabot/github_actions/ruby/setup-ruby-1.299.0
• dependabot/github_actions/ruby/setup-ruby-1.306.0
• dependabot/github_actions/ruby/setup-ruby-1.310.0
• docs
• fix-badge
• fix-customize-template
• fix-host
• fix-memory-usage
• fix-secret
• fix/data-stream-bulk-error-logging
• fix_duplicate_keys_in_test_fixtures
• fix_expired_sigv4_token
• handle-exceptions-on-credentials-retriving
• handle-opensearch-serverless
• handle-suppress_type_name-correctly
• implement-aws-opensearch-sign-request-mechanism
• issue-template
• load-faraday-v2
• main
• obtain-aws-credentials-on-every-requests-if-available
• pass-credentials-duration
• permit-to-handle-hosts-parameter
• prevent_refresh_from_stopping_on_exception
• refresh_credentials_interval
• refs/tags/v1.0.0
• refs/tags/v1.0.1
• refs/tags/v1.0.10
• refs/tags/v1.0.2
• refs/tags/v1.0.3
• refs/tags/v1.0.4
• refs/tags/v1.0.5
• refs/tags/v1.0.6
• refs/tags/v1.0.7
• refs/tags/v1.0.8
• refs/tags/v1.0.9
• refs/tags/v1.1.0
• refs/tags/v1.1.1
• refs/tags/v1.1.2
• refs/tags/v1.1.3
• refs/tags/v1.1.4
• refs/tags/v1.1.5
• release-1.2.0
• release-v1.0.0
• revert-duration
• ruby_versions.yml
• specify-host-argument-if-needed
• suppress-emit-error-label-events
• suppress_type_name
• tmp
• update-ci
• upload-coverage-into-coveralls
• use-faraday-1
• use-faraday-2
• use-if-clause-to-detect-requirements-for-emitting-error-label-events
• v1.1.6
• v1.1.7
• webrick
• yajl-to-json

Build # 35311016559

Build Type

Pull #195

github

Committed by kenhys

Commit Message

out_opensearch: guard the cached client with one mutex

Before:
the credential refresh timer used its own mutex and the flush
thread error path used none, so both could clear @_os while another
thread was building a client under @client_mutex. A failed credential
refresh also threw away the cached client for nothing.

After:
both paths take @client_mutex, and the timer keeps the old
credentials when it cannot get new ones.

Co-Authored-By: Claude <noreply@anthropic.com>
Signed-off-by: Kentaro Hayashi <hayashi@clear-code.com>

Pull Request Pull Request #195: out_opensearch: lock the client cache against flush threads

Coverage Stats

12 of 12 new or added lines in 1 file covered. (100.0%)

1199 of 1291 relevant lines covered (92.87%)

314.97 hits per line