globalregistry

README

全局资源缓存器

主要用来当成一个缓存数据库用。

Documentation

Index

• type ConcurrentMap
  • func NewConcurrentMap() *ConcurrentMap
  • func (m *ConcurrentMap) Delete(key string)
  • func (m *ConcurrentMap) Get(key string) (interface{}, bool)
  • func (m *ConcurrentMap) Keys() []string
  • func (m *ConcurrentMap) Set(key string, value interface{})
• type GlobalRegistry
  • func NewGlobalRegistry() *GlobalRegistry
• type RingBuffer
  • func NewRingBuffer(size int) *RingBuffer
  • func (rb *RingBuffer) Read() (byte, error)
  • func (rb *RingBuffer) Write(data []byte) (int, error)
• type TimerWheel
  • func NewTimerWheel(interval time.Duration, size int) *TimerWheel
  • func (tw *TimerWheel) AddTimer(d time.Duration, f func())
  • func (tw *TimerWheel) Run()
  • func (tw *TimerWheel) Stop()

Types

type ConcurrentMap

type ConcurrentMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConcurrentMap

func NewConcurrentMap() *ConcurrentMap

func (*ConcurrentMap) Delete

func (m *ConcurrentMap) Delete(key string)

func (*ConcurrentMap) Get

func (m *ConcurrentMap) Get(key string) (interface{}, bool)

func (*ConcurrentMap) Keys

func (m *ConcurrentMap) Keys() []string

func (*ConcurrentMap) Set

func (m *ConcurrentMap) Set(key string, value interface{})

type GlobalRegistry

type GlobalRegistry struct {
	Registry   *ConcurrentMap
	RingBuffer *RingBuffer
	TimerWheel *TimerWheel
}

func NewGlobalRegistry

func NewGlobalRegistry() *GlobalRegistry

type RingBuffer

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

RingBuffer 是环形缓冲区结构体

func NewRingBuffer

func NewRingBuffer(size int) *RingBuffer

NewRingBuffer 创建一个新的环形缓冲区

func (*RingBuffer) Read

func (rb *RingBuffer) Read() (byte, error)

Read 从环形缓冲区读取数据

func (*RingBuffer) Write

func (rb *RingBuffer) Write(data []byte) (int, error)

Write 向环形缓冲区写入数据

type TimerWheel

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

func NewTimerWheel

func NewTimerWheel(interval time.Duration, size int) *TimerWheel

func (*TimerWheel) AddTimer

func (tw *TimerWheel) AddTimer(d time.Duration, f func())

func (*TimerWheel) Run

func (tw *TimerWheel) Run()

func (*TimerWheel) Stop

func (tw *TimerWheel) Stop()