Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redis

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 23, 2026

Changes in this version

+ var ErrStreamsClosed = errors.New("redis streams service is closed")

+ var ErrStreamsDeliveryLost = errors.New("redis stream delivery ownership was lost")

+ var ErrStreamsWorkerCapacity = errors.New("redis streams worker capacity is exhausted")

+ var Streams = Feature

+ var StreamsConfigToken = gioc.NewToken("StreamsConfig")

+ var StreamsServiceInjections = []gioc.Token

+ var StreamsServiceToken = gioc.NewToken("StreamsService")

+ func ForFeature(features ...Feature) *gioc.Module

+ func ProvideConfig(config *Config) gioc.IProvider

+ func ProvideStreamsConfig(config *StreamsConfig) gioc.IProvider

+ type Feature struct

+ func (feature Feature) Name() string

+ type IStreamsService interface

+ Ack func(ctx context.Context, message StreamsMessage) error

+ Consume func(ctx context.Context, group string, stream string, ...) (<-chan StreamsMessage, error)

+ Publish func(ctx context.Context, stream string, key string, value any) error

type Service

+ func (service *Service) Client() goredis.UniversalClient

+ type StreamsConfig struct

+ BlockTimeout time.Duration

+ ChannelSize int

+ DeadLetterSuffix string

+ DefaultBatchSize int64

+ DefaultConsumerCount int

+ MaximumDeliveries int64

+ MaximumMessageBytes int

+ MaximumStreamLength int64

+ ReclaimAfter time.Duration

+ ReclaimInterval time.Duration

+ RetryMaximumDelay time.Duration

+ RetryMinimumDelay time.Duration

+ WorkerCount int

+ func DefaultStreamsConfig() StreamsConfig

+ type StreamsConsumerConfig struct

+ BatchSize int64

+ ConsumerCount int

+ StartFrom StreamsStart

+ type StreamsMessage struct

+ Attempts int64

+ Group string

+ ID string

+ Key string

+ Payload json.RawMessage

+ Stream string

+ func (message StreamsMessage) Decode(target any) error

+ type StreamsService struct

+ ApplicationService *react.ApplicationService

+ Logger react.ILogger

+ func NewStreamsService(injections gioc.Injections) (*StreamsService, error)

+ func (service *StreamsService) Ack(ctx context.Context, message StreamsMessage) error

+ func (service *StreamsService) Consume(ctx context.Context, group string, stream string, ...) (<-chan StreamsMessage, error)

+ func (service *StreamsService) Publish(ctx context.Context, stream string, key string, value any) error

+ type StreamsStart string

+ const StreamsStartBeginning

+ const StreamsStartLatest

v0.1.0

Aug 10, 2026

Changes in this version

+ var ConfigToken = gioc.NewToken("RedisConfig")

+ var Module = ...(...)

+ var ServiceInjections = react.InjectFromBase(ConfigToken)

+ var ServiceToken = gioc.NewToken("RedisService")

+ type Config struct

+ URL string

+ type Service struct

+ func NewService(injections gioc.Injections) (*Service, error)

+ func (service *Service) Add(key string, members ...any) (int64, error)

+ func (service *Service) Delete(keys ...string) error

+ func (service *Service) Drop(key string, members ...any) (int64, error)

+ func (service *Service) Get(key string) (string, bool, error)

+ func (service *Service) GetBool(key string) (bool, bool, error)

+ func (service *Service) IncludesMany(key string, members ...string) ([]bool, error)

+ func (service *Service) IncludesOne(key string, member any) (bool, error)

+ func (service *Service) Keys(template string) ([]string, error)

+ func (service *Service) Scan(template string, count int64) ([]string, error)

+ func (service *Service) Set(key string, value any, ttl time.Duration) error

+ func (service *Service) SetIfNotExists(key string, value any, ttl time.Duration) (bool, error)

+ func (service *Service) Size(key string) (int64, error)