idempotence

Documentation

Index

• Constants
• Variables
• func WithSuccessfulTTL(successfulTTL time.Duration) func(opts *IdempotenceImplOptions)
• func WithTimeout(timeout time.Duration) func(opts *IdempotenceImplOptions)
• type Idempotence
  • func New(redisClient *redis.Client, opts ...func(opts *IdempotenceImplOptions)) Idempotence
• type IdempotenceImpl
  • func (i *IdempotenceImpl) Exec(ctx context.Context, key string, exec func(context.Context) error) error
• type IdempotenceImplOptions

Constants

const (
	DefaultTimeout       = 5 * time.Second // 5 seconds
	DefaultSuccessfulTTL = 24 * time.Hour  // 24 hours
	StatusProcessing     = "processing"
	StatusProcessed      = "processed"
)

Variables

var ErrConflict = errors.New("conflict")

Functions

func WithSuccessfulTTL

func WithSuccessfulTTL(successfulTTL time.Duration) func(opts *IdempotenceImplOptions)

func WithTimeout

func WithTimeout(timeout time.Duration) func(opts *IdempotenceImplOptions)

Types

type Idempotence

type Idempotence interface {
	Exec(ctx context.Context, key string, exec func(context.Context) error) error
}

func New

func New(redisClient *redis.Client, opts ...func(opts *IdempotenceImplOptions)) Idempotence

type IdempotenceImpl

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

func (*IdempotenceImpl) Exec

func (i *IdempotenceImpl) Exec(ctx context.Context, key string, exec func(context.Context) error) error

type IdempotenceImplOptions

type IdempotenceImplOptions struct {
	Timeout       time.Duration
	SuccessfulTTL time.Duration
}