idempotency

Documentation

Index

• Variables
• func Key(k string) (string, error)
• type Idempotency
  • func New(conf *config.Config) (Idempotency, error)
  • func NewRedis(conf *config.Config) (Idempotency, error)

Variables

var (
	ErrAlreadyConnected = errors.New("IDEMPOTENCY.ALREADY_CONNECTED.ERROR")
	ErrNotConnected     = errors.New("IDEMPOTENCY.NOT_CONNECTED.ERROR")
	ErrConflict         = errors.New("IDEMPOTENCY.CONFLICT.ERROR")
	ErrKeyEmpty         = errors.New("IDEMPOTENCY.KEY.EMPTY.ERROR")
)

var CtxKey ctxkey = "idempotency.key"

Functions

func Key

func Key(k string) (string, error)

Types

type Idempotency

type Idempotency interface {
	patterns.Connectable
	Validate(ctx context.Context, key string) error
}

func New

func New(conf *config.Config) (Idempotency, error)

New creates a new idempotency instance based on the provided configuration. The idempotency instance is initialized based on the URI scheme. Supported schemes are: - memory:// - redis:// If the URI scheme is not supported, an error is returned.

func NewRedis

func NewRedis(conf *config.Config) (Idempotency, error)

NewRedis creates a new idempotency instance that uses Redis as the underlying storage.