Class: Karafka::Persistence::Client

Inherits:

Object

• Object
• Karafka::Persistence::Client

Defined in:

lib/karafka/persistence/client.rb

Overview

Persistence layer to store current thread messages consumer client for further use

Class Method Summary

• .read ⇒ Karafka::Connection::Client

  Persisted messages consumer client.

• .write(client) ⇒ Karafka::Connection::Client

  Persisted messages consumer client.

Class Method Details

.read ⇒ Karafka::Connection::Client

Returns persisted messages consumer client.

Returns:

• (Karafka::Connection::Client) —

  persisted messages consumer client

Raises:

• (Karafka::Errors::MissingClientError) —

  raised when no thread messages consumer client but we try to use it anyway

# File 'lib/karafka/persistence/client.rb', line 23

def read
  Thread.current[PERSISTENCE_SCOPE] || raise(Errors::MissingClientError)
end

.write(client) ⇒ Karafka::Connection::Client

Returns persisted messages consumer client.

Parameters:

• client (Karafka::Connection::Client) —

  messages consumer client of a current thread

Returns:

• (Karafka::Connection::Client) —

  persisted messages consumer client

# File 'lib/karafka/persistence/client.rb', line 16

def write(client)
  Thread.current[PERSISTENCE_SCOPE] = client
end