storageredis

Documentation

Index

• type Storage
  • func New(rds redis.UniversalClient, streamName string, ...) Storage
  • func (s Storage) Drop(ctx context.Context, streamID uuid.UUID) error
  • func (s Storage) Load(ctx context.Context, streamID uuid.UUID) (*stream.Stream, error)
  • func (s Storage) NewStream() *stream.Stream
  • func (s Storage) Persist(ctx context.Context, ss *stream.Stream) (err error)
  • func (s Storage) StreamName() string

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

func New

func New(
	rds redis.UniversalClient,
	streamName string,
	blankStream func() *stream.Stream,
) Storage

func (Storage) Drop

func (s Storage) Drop(ctx context.Context, streamID uuid.UUID) error

func (Storage) Load

func (s Storage) Load(ctx context.Context, streamID uuid.UUID) (*stream.Stream, error)

func (Storage) NewStream

func (s Storage) NewStream() *stream.Stream

func (Storage) Persist

func (s Storage) Persist(ctx context.Context, ss *stream.Stream) (err error)

func (Storage) StreamName

func (s Storage) StreamName() string