idempotence

README

idempotence service

保证API的幂等性

Documentation

Index

• func GetTimestamp() int64
• func NewLogger() *zap.SugaredLogger
• type Idempotence
  • func NewIdempotence(storage IdempotenceStorage) Idempotence
  • func (ide Idempotence) Remove(key, group string) error
  • func (ide Idempotence) SaveIfAbsent(key, group string) error
• type IdempotenceStorage
• type Logger
• type RedisIdempotenceStorage
  • func NewRedisIdempotenceStorage(config RedisIdempotenceStorageConfig) (RedisIdempotenceStorage, error)
  • func (storage RedisIdempotenceStorage) Remove(key, group string) error
  • func (storage RedisIdempotenceStorage) SaveIfAbsent(key, group string) error
• type RedisIdempotenceStorageConfig

Functions

func GetTimestamp

func GetTimestamp() int64

func NewLogger

func NewLogger() *zap.SugaredLogger

Types

type Idempotence

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

func NewIdempotence

func NewIdempotence(storage IdempotenceStorage) Idempotence

func (Idempotence) Remove

func (ide Idempotence) Remove(key, group string) error

func (Idempotence) SaveIfAbsent

func (ide Idempotence) SaveIfAbsent(key, group string) error

type IdempotenceStorage

type IdempotenceStorage interface {
	SaveIfAbsent(key, group string) error
	Remove(key, group string) error
}

type Logger

type Logger interface {
	Debugw(msg string, keysAndValues ...interface{})
	Infow(msg string, keysAndValues ...interface{})
	Errorw(msg string, keysAndValues ...interface{})
}

type RedisIdempotenceStorage

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

func NewRedisIdempotenceStorage

func NewRedisIdempotenceStorage(config RedisIdempotenceStorageConfig) (RedisIdempotenceStorage, error)

func (RedisIdempotenceStorage) Remove

func (storage RedisIdempotenceStorage) Remove(key, group string) error

func (RedisIdempotenceStorage) SaveIfAbsent

func (storage RedisIdempotenceStorage) SaveIfAbsent(key, group string) error

type RedisIdempotenceStorageConfig

type RedisIdempotenceStorageConfig struct {
	IP       string
	Port     string
	DBNumber int
}