K8s源码分析(24)-ThreadSafeStore组件

TA码字

发布于 2022-10-30 13:25:17

2360

发布于 2022-10-30 13:25:17

文章被收录于专栏：TA码字TA码字

上一篇文章里，我们主要介绍了和资源索引相关的一系列对象，其中包括了 indexer 对象，index 对象，以及 indices 对象等等。在本篇文章里我们主要来介绍和对象存储相关的组件 ThreadSafeStore 接口以及其实现。

ThreadSafeStore 接口

ThreadSafeStore 是接口，图解和源码如下：

//k8s.io/client-go/tools/cache/thread_safe_store.go
type ThreadSafeStore interface {
  Add(key string, obj interface{})
  Update(key string, obj interface{})
  Delete(key string)
  Get(key string) (item interface{}, exists bool)
  List() []interface{}
  ListKeys() []string
  Replace(map[string]interface{}, string)
  Index(indexName string, obj interface{}) ([]interface{}, error)
  IndexKeys(indexName, indexKey string) ([]string, error)
  ListIndexFuncValues(name string) []string
  ByIndex(indexName, indexKey string) ([]interface{}, error)
  GetIndexers() Indexers

  // AddIndexers adds more indexers to this store.  If you call this after you already have data
  // in the store, the results are undefined.
  AddIndexers(newIndexers Indexers) error
  // Resync is a no-op and is deprecated
  Resync() error
}

‍

该接口定义了对于资源增删改查的方法，例如 Add/Update/Delete/Get/List 等操作。
该接口定义了对于资源进行索引相关的方法，例如 Index/IndexKeys/ByIndex 等系列操作。

threadSafeMap 结构体

threadSafeMap 是一个结构体，该结构体实现了上面介绍的接口 ThreadSafeStore，其相关的图解和源码如下：

//k8s.io/client-go/tools/cache/thread_safe_store.go
type threadSafeMap struct {
  lock  sync.RWMutex
  items map[string]interface{}

  // indexers maps a name to an IndexFunc
  indexers Indexers
  // indices maps a name to an Index
  indices Indices
}


func (c *threadSafeMap) Add(key string, obj interface{}) {
  c.Update(key, obj)
}

func (c *threadSafeMap) Update(key string, obj interface{}){...}
func (c *threadSafeMap) Delete(key string) {...}
func (c *threadSafeMap) Get(key string) (item interface{}, exists bool){...}
func (c *threadSafeMap) List() []interface{...}
func (c *threadSafeMap) ListKeys() []string  {...}
func (c *threadSafeMap) Replace(items map[string]interface{}, resourceVersion string) {...}
func (c *threadSafeMap) Index(indexName string, obj interface{}) ([]interface{}, error) {...} {...}
func (c *threadSafeMap) ByIndex(indexName, indexedValue string) ([]interface{}, error) {...}
func (c *threadSafeMap) IndexKeys(indexName, indexedValue string) ([]string, error) {...}
func (c *threadSafeMap) ListIndexFuncValues(indexName string) []string {...}
.......