redis

Documentation

Index

• type Duplicator
  • func NewDuplicator(c *redis.Client, prefix string) *Duplicator
  • func (d *Duplicator) Ensure(ctx context.Context, c stream.Event) error
  • func (d *Duplicator) Has(ctx context.Context, c stream.Event) bool

Types

type Duplicator

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

func NewDuplicator

func NewDuplicator(c *redis.Client, prefix string) *Duplicator

func (*Duplicator) Ensure

func (d *Duplicator) Ensure(ctx context.Context, c stream.Event) error

func (*Duplicator) Has

func (d *Duplicator) Has(ctx context.Context, c stream.Event) bool