idempotent

Documentation

Index

• Variables
• func DoIdempotent(ctx context.Context, store *redis.Redis, key string, v any, ...) (bool, error)
• type Idempotent
  • func NewIdempotent(store *redis.Redis, key string) *Idempotent
  • func (i *Idempotent) Lock(ctx context.Context, seconds int) (bool, error)
  • func (i *Idempotent) SetCacheValue(ctx context.Context, v any, expired int) error
  • func (i *Idempotent) TryGetCacheValue(ctx context.Context, v any) (cached bool, err error)
  • func (i *Idempotent) Unlock(ctx context.Context) error

Variables

var (
	ErrorDoEmpty    = fmt.Errorf("do empty")
	ErrorCacheEmpty = fmt.Errorf("cache empty")
)

Functions

func DoIdempotent

func DoIdempotent(ctx context.Context, store *redis.Redis, key string, v any, seconds, expired int, fn func(ctx context.Context, v any) error) (bool, error)

Types

type Idempotent

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

func NewIdempotent

func NewIdempotent(store *redis.Redis, key string) *Idempotent

func (*Idempotent) Lock

func (i *Idempotent) Lock(ctx context.Context, seconds int) (bool, error)

Lock Lock

func (*Idempotent) SetCacheValue

func (i *Idempotent) SetCacheValue(ctx context.Context, v any, expired int) error

func (*Idempotent) TryGetCacheValue

func (i *Idempotent) TryGetCacheValue(ctx context.Context, v any) (cached bool, err error)

func (*Idempotent) Unlock

func (i *Idempotent) Unlock(ctx context.Context) error

Unlock Unlock