idempotency

Documentation

Index

• Variables
• func Key(key string) string
• type Config
  • func (conf *Config) Validate() error
• type Idempotency
  • func New(conf *Config, logger logging.Logger) (Idempotency, error)
  • func NewRedis(conf *Config, logger logging.Logger) (Idempotency, error)

Variables

var (
	ErrNotConnected     = errors.New("INFRASTRUCTURE.IDEMPOTENCY.NOT_CONNECTED.ERROR")
	ErrAlreadyConnected = errors.New("INFRASTRUCTURE.IDEMPOTENCY.ALREADY_CONNECTED.ERROR")
)

Functions

func Key

func Key(key string) string

Types

type Config

type Config struct {
	Uri        string `json:"uri" yaml:"uri" mapstructure:"uri"`
	TimeToLive uint64 `json:"time_to_live" yaml:"timeToLive" mapstructure:"time_to_live"`
}

func (*Config) Validate

func (conf *Config) Validate() error

type Idempotency

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

func New

func New(conf *Config, logger logging.Logger) (Idempotency, error)

func NewRedis

func NewRedis(conf *Config, logger logging.Logger) (Idempotency, error)