store

Documentation

Index

• Constants
• type BlockStatus
• type BlockedValue
• type Int32Map
  • func NewInt32Map(maxTracked int64) *Int32Map
  • func (i *Int32Map) BlockedValues() []BlockedValue
  • func (i *Int32Map) CleanUp(clock int32)
  • func (i *Int32Map) Get(key interface{}) (*BlockStatus, *sync.Mutex)
  • func (i *Int32Map) Type() string
• type ShardMap
• type StringMap
  • func NewStringMap(maxTracked int64) *StringMap
  • func (s *StringMap) BlockedValues() []BlockedValue
  • func (s *StringMap) CleanUp(clock int32)
  • func (s *StringMap) Get(key interface{}) (*BlockStatus, *sync.Mutex)
  • func (s *StringMap) Type() string

Constants

const NumShards = 128

Types

type BlockStatus

type BlockStatus struct {
	IsBlocked bool
	FrontTile float64
	Since     float64
}

type BlockedValue

type BlockedValue struct {
	Since float64
	Value interface{}
}

type Int32Map

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

func NewInt32Map

func NewInt32Map(maxTracked int64) *Int32Map

func (*Int32Map) BlockedValues

func (i *Int32Map) BlockedValues() []BlockedValue

func (*Int32Map) CleanUp

func (i *Int32Map) CleanUp(clock int32)

func (*Int32Map) Get

func (i *Int32Map) Get(key interface{}) (*BlockStatus, *sync.Mutex)

func (*Int32Map) Type

func (i *Int32Map) Type() string

type ShardMap

type ShardMap interface {
	Get(key interface{}) (*BlockStatus, *sync.Mutex)
	CleanUp(clock int32)
	Type() string
	BlockedValues() []BlockedValue
}

type StringMap

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

func NewStringMap

func NewStringMap(maxTracked int64) *StringMap

func (*StringMap) BlockedValues

func (s *StringMap) BlockedValues() []BlockedValue

func (*StringMap) CleanUp

func (s *StringMap) CleanUp(clock int32)

func (*StringMap) Get

func (s *StringMap) Get(key interface{}) (*BlockStatus, *sync.Mutex)

func (*StringMap) Type

func (s *StringMap) Type() string