package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
No description provided by the author
NewInClusterRedisClient returns a new Redis Client, it assumes it's in a vertex pod, where those required environment variables are available.
NewRedisClient returns a new Redis Client.
No description provided by the author
WithBufferFullWritingStrategy sets the BufferFullWritingStrategy.
WithBufferUsageLimit sets the bufferUsageLimit.
WithCheckBacklog sets the checkBackLog option.
WithInfoRefreshInterval sets the refresh interval.
WithLagDuration sets the consumerLag duration.
WithMaxLength sets the maxLength.
WithoutPipelining turns on redis pipelining.
WithReadTimeOut sets the readTimeOut.
WithRefreshBufferWriteInfo sets the refreshBufferWriteInfo.

# Constants

No description provided by the author
No description provided by the author

# Variables

RedisContext is used to pass the context specifically for REDIS operations.

# Structs

No description provided by the author
Options for writing to redis.
RedisClient datatype to hold redis client attributes.
RedisStreamsRead is the read queue implementation powered by RedisClient.

# Interfaces

Option to apply different options.