[filebeat][streaming] - Added retry functionality to websocket connections

[ShourieG]

Type of change

Please label this PR with one of the following labels, depending on the scope of your change:

• Enhancement
• Docs

Proposed commit message

Added retry functionality to websocket connections under the streaming input. Docs & tests have been updated accordingly to support the new functionality.

Checklist

• My code follows the style guidelines of this project
• I have commented my code, particularly in hard-to-understand areas
• I have made corresponding changes to the documentation
  - [ ] I have made corresponding change to the default configuration files
• I have added tests that prove my fix is effective or that my feature works
• I have added an entry in CHANGELOG.next.asciidoc or CHANGELOG-developer.next.asciidoc.

Disruptive User Impact

None

Author's Checklist

How to test this PR locally

Related issues

• Closes [filebeat][websocket] - Add retry mechanism to socket connections #40271

Use cases

Screenshots

Logs

[mergify]

This pull request does not have a backport label.
If this is a bug or security fix, could you label this PR @ShourieG? 🙏.
For such, you'll need to label your PR with:

• The upcoming major version of the Elastic Stack
• The upcoming minor version of the Elastic Stack (if you're not pushing a breaking change)

To fixup this pull request, you need to add the backport labels for the needed
branches, such as:

• backport-v8./d.0 is the label to automatically backport to the 8./d branch. /d is the digit

[elasticmachine]

Pinging @elastic/security-service-integrations (Team:Security-Service Integrations)

[ShourieG]

@rdner, can I get a CODEOWNER review on this.

[pierrehilbert]

@mauri870 is part of the code owner so his approval would work.
I'm adding someone else as a reviewer as @rdner is off this week

[mauri870]

Thanks for the ping. I've reviewed the PR, and it looks good.

[elasticmachine]

Pinging @elastic/elastic-agent-data-plane (Team:Elastic-Agent-Data-Plane)

[ShourieG]

@belimawr, Addressed the PR comments.

[mauri870]

Is it possible to use https://pkg.go.dev/github.com/gorilla/websocket#IsCloseError here?

[ShourieG]

IsCloseError will require us to pass all the possible codes in the func param which can seem a bit messy when we are dealing with so many types of codes. It can be used but the signature is messy compared to the switch statement.