barriers

Documentation

Index

• func BarrierBuilder(options ...configs.Option) barriers.BarrierBuilder
• func New(config configs.Config, ttl time.Duration, options ...configs.Option) (v barriers.Barrier, err error)
• func NewWithClient(client rueidis.Client, ttl time.Duration) (v barriers.Barrier, err error)
• type Barrier
  • func (b *Barrier) Do(ctx context.Context, key []byte, fn func() (result any, err error)) (result barriers.Result, err error)
• type Result
  • func (r Result) Value() (p []byte, err error)

Functions

func BarrierBuilder

func BarrierBuilder(options ...configs.Option) barriers.BarrierBuilder

func New

func New(config configs.Config, ttl time.Duration, options ...configs.Option) (v barriers.Barrier, err error)

func NewWithClient

func NewWithClient(client rueidis.Client, ttl time.Duration) (v barriers.Barrier, err error)

Types

type Barrier

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

func (*Barrier) Do

func (b *Barrier) Do(ctx context.Context, key []byte, fn func() (result any, err error)) (result barriers.Result, err error)

type Result

type Result []byte

func (Result) Value

func (r Result) Value() (p []byte, err error)