Redis
- BusyGroup
- Client
- Cluster
  - Ask
  - CrossSlot
  - Error
  - Moved
- Commands
  - EmptyEnumerable
  - Hash
  - List
    - Side
  - ScriptFlushMode
  - Set
  - SortedSet
  - Stream
    - XGroup
- Connection
- Error
- FullText
  - Filter
  - GeoFilter
  - GeoUnit
  - Highlight
  - SortBy
  - SortDirection
  - Summarize
- Future
  - NotResolved
- Graph
  - Cache
  - Client
  - Constraints
    - Constraint
    - EntityType
    - Status
    - Type
  - ConstraintViolation
  - Error
  - Field
  - Indices
    - IndexAlreadyExists
  - List
  - Map
  - Node
  - Relationship
  - ResultSet
    - Row
  - Serializable
    - Node
      - Metadata
      - PropertyMissing
    - Property
  - UnexpectedValue
  - Value
  - ValueType
- JSON
- NoGroup
- Parser
- Pipeline
- ReplicationClient
  - Info
    - Replica
      - State
    - Replication
      - Role
- Streaming
  - Message
  - XAutoClaimResponse
  - XPendingBaseResponse
    - Data
  - XPendingExtendedResponse
    - MessageData
  - XReadGroupResponse
    - Result
- Subscription
  - InvalidMessage
- TimeSeries
  - Aggregation
  - AggregationType
  - Alignment
  - BucketTimestamp
  - Datapoint
  - Datapoints
  - DuplicatePolicy
  - Encoding
  - Labels
  - MRangeResponse
    - DatapointMap
  - Range
  - RangeOptions
    - Aggregation
- Transaction
- Value
- Writer

struct Redis::Streaming::Message

Redis::Streaming::Message
Struct
Value
Object

Defined in:

streaming.cr

Constructors

.new(message : Array)

Instance Method Summary

#id : String
#values : Hash(String, String)

Constructor Detail

def self.new(message : Array) #

[View source]

Instance Method Detail

def id : String #

[View source]

def values : Hash(String, String) #

[View source]