class Curator::Forwards::Forward

• Curator::Forwards::Forward
• Reference
• Object

Overview

Responsible for maintaining the websocket connection And sending the event data through to the forward server. Has 2 long running Fibers.

1. To maintain the forward websocket connection. Polls the connection every second.
2. To flush the buffer if there is an available connection and data in buffer. Polls the buffer 5000 per second.

Defined in:

forwards/forward.cr

Constructors

• .new(url : URI, api_key : String)

Instance Method Summary

• #api_key : String
• #buffer : Curator::Utils::RingBuffer
• #buffer=(buffer : Curator::Utils::RingBuffer)
• #push(event : Curator::Event)

  Accepts the event data in a buffer

• #socket : HTTP::WebSocket | Nil
• #socket=(socket : HTTP::WebSocket | Nil)
• #url : URI

Constructor Detail

Instance Method Detail