class

Curator::Forwards::Forward

Inherits Reference < Object

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.

Constructors

new(url : URI, api_key : String)
Source

Instance methods

api_key
Source
buffer
Source
buffer=(buffer : Curator::Utils::RingBuffer)
Source
push(event : Curator::Event)

Accepts the event data in a buffer

Source
socket
Source
socket=(socket : HTTP::WebSocket | Nil)
Source