idempotency

Documentation

Index

• type Redis
  • func NewRedis[T any](redisUrl string) (*Redis[T], error)
  • func (r *Redis[T]) Start(ctx context.Context, idempotencyKey string) (T, bool, error)
  • func (r *Redis[T]) Store(ctx context.Context, idempotencyKey string, value T) error

Types

type Redis

type Redis[T any] struct {
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis[T any](redisUrl string) (*Redis[T], error)

func (*Redis[T]) Start

func (r *Redis[T]) Start(ctx context.Context, idempotencyKey string) (T, bool, error)

Start returns the executed result and true if the idempotency key is already executed. Otherwise, returns empty T and false

func (*Redis[T]) Store

func (r *Redis[T]) Store(ctx context.Context, idempotencyKey string, value T) error