Module: RedisStream

Defined in:
lib/redis_stream.rb,
lib/redis_stream/group.rb,
lib/redis_stream/client.rb,
lib/redis_stream/stream.rb,
lib/redis_stream/version.rb,
lib/redis_stream/consumer.rb

Defined Under Namespace

Classes: Client, Consumer, Error, Group, Stream

Constant Summary collapse

VERSION = 
"0.3.0"

Class Method Summary collapse

Class Method Details

.group(name:, stream:) ⇒ RedisStream::Group

Parameters:

  • name (String) —

    Name of a group

  • stream (RedisStream::Stream) —

    Stream that group should consume

Returns:



20
21
22
 
# File 'lib/redis_stream.rb', line 20

def self.group(name:, stream:)
  Group.new(name: name, stream: stream)
end

.stream(name:) ⇒ RedisStream::Stream

Parameters:

  • name (String) —

    Name of a stream

Returns:



13
14
15
 
# File 'lib/redis_stream.rb', line 13

def self.stream(name:)
  Stream.new(name: name)
end