Class: RedisStream::Client

Inherits:

Object

• Object
• RedisStream::Client

Defined in:

lib/redis_stream/client.rb

Instance Method Summary

• #group(key:, name:) ⇒ Object
• #initialize(redis) ⇒ Client constructor

  A new instance of Client.

• #stream(key) ⇒ Object

Constructor Details

#initialize(redis) ⇒ Client

Returns a new instance of Client.

# File 'lib/redis_stream/client.rb', line 3

def initialize(redis)
  @redis = redis
end

Instance Method Details

#group(key:, name:) ⇒ Object

# File 'lib/redis_stream/client.rb', line 11

def group(key:, name:)
  new_group = Group.new(redis: @redis, key: key, name: name)
  new_group.create
end

#stream(key) ⇒ Object

# File 'lib/redis_stream/client.rb', line 7

def stream(key)
  Stream.new(redis: @redis, key: key)
end