adaptors

Documentation

Index

• func NewMd5Hash() ports.ConsistentHash
• func NewSimpleCache() ports.Storage
• type LamportClock
  • func NewLamportClock() *LamportClock
  • func (l *LamportClock) Tick() uint64
  • func (l *LamportClock) Time() uint64
  • func (l *LamportClock) Witness(t uint64) bool
• type SimpleCache
  • func (c *SimpleCache) Del(key string) error
  • func (c *SimpleCache) Get(key string) (string, error)
  • func (c *SimpleCache) Put(key, value string) error

Functions

func NewMd5Hash

func NewMd5Hash() ports.ConsistentHash

func NewSimpleCache

func NewSimpleCache() ports.Storage

Types

type LamportClock

type LamportClock struct {
	sync.Mutex
	// contains filtered or unexported fields
}

LamportClock is a partial-order clock implementing ports.ILamportClock

func NewLamportClock

func NewLamportClock() *LamportClock

func (*LamportClock) Tick

func (l *LamportClock) Tick() uint64

func (*LamportClock) Time

func (l *LamportClock) Time() uint64

func (*LamportClock) Witness

func (l *LamportClock) Witness(t uint64) bool

type SimpleCache

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

SimpleCache implements ports.Storage

func (*SimpleCache) Del

func (c *SimpleCache) Del(key string) error

func (*SimpleCache) Get

func (c *SimpleCache) Get(key string) (string, error)

func (*SimpleCache) Put

func (c *SimpleCache) Put(key, value string) error