stream

Documentation

Index

• type Stream
  • func NewRedis(redisClient *redis.Client) Stream

Types

type Stream

type Stream interface {
	Add(key string, event protocol.Event) (addedEvent protocol.Event, err error)
	Get(key string, id string) (event protocol.Event, err error)
	Delete(key string) error
}

Stream is the interface for accessing the distributed stream

func NewRedis

func NewRedis(redisClient *redis.Client) Stream

NewRedis returns the Redis implementation of Stream