什么是genericStore

genericStore是对ETCD Helper的封装，定义了Kubernetes类型的通用操作。

genericStore

genericStore中主要包含NewFunc, NewListFunc, KeyRootFunc, KeyFunc, TTLFunc, PredicateFunc, DestroyFunc这些函数及其他相关字段。

genericStore的方法有Create(), Delete(), Get(), List(), New(), Watch(), Update()等。其中Update()实现了resourceVersion的比较。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
type Store struct {
	// Called to make a new object, should return e.g., &api.Pod{}
	NewFunc func() runtime.Object
	// Called to make a new listing object, should return e.g., &api.PodList{}
	NewListFunc func() runtime.Object
	// Used for error reporting
	QualifiedResource unversioned.GroupResource
	// Used for listing/watching; should not include trailing "/"
	KeyRootFunc func(ctx api.Context) string
	// Called for Create/Update/Get/Delete. Note that 'namespace' can be
	// gotten from ctx.
	KeyFunc func(ctx api.Context, name string) (string, error)
	// Called to get the name of an object
	ObjectNameFunc func(obj runtime.Object) (string, error)
	// Return the TTL objects should be persisted with. Update is true if this
	// is an operation against an existing object. Existing is the current TTL
	// or the default for this operation.
	TTLFunc func(obj runtime.Object, existing uint64, update bool) (uint64, error)
	// Returns a matcher corresponding to the provided labels and fields.
	PredicateFunc func(label labels.Selector, field fields.Selector) storage.SelectionPredicate
	// Called to cleanup storage clients.
	DestroyFunc func()
	// EnableGarbageCollection affects the handling of Update and Delete requests. It
	// must be synced with the corresponding flag in kube-controller-manager.
	EnableGarbageCollection bool
	// DeleteCollectionWorkers is the maximum number of workers in a single
	// DeleteCollection call.
	DeleteCollectionWorkers int
	// Decorator is called as exit hook on object returned from the underlying storage.
	// The returned object could be individual object (e.g. Pod) or the list type (e.g. PodList).
	// Decorator is intended for integrations that are above storage and
	// should only be used for specific cases where storage of the value is
	// not appropriate, since they cannot be watched.
	Decorator rest.ObjectFunc
	// Allows extended behavior during creation, required
	CreateStrategy rest.RESTCreateStrategy
	// On create of an object, attempt to run a further operation.
	AfterCreate rest.ObjectFunc
	// Allows extended behavior during updates, required
	UpdateStrategy rest.RESTUpdateStrategy
	// On update of an object, attempt to run a further operation.
	AfterUpdate rest.ObjectFunc
	// Allows extended behavior during updates, optional
	DeleteStrategy rest.RESTDeleteStrategy
	// On deletion of an object, attempt to run a further operation.
	AfterDelete rest.ObjectFunc
	// If true, return the object that was deleted. Otherwise, return a generic
	// success status response.
	ReturnDeletedObject bool
	// Allows extended behavior during export, optional
	ExportStrategy rest.RESTExportStrategy
	// Used for all storage access functions
	Storage storage.Interface
}

关于genericStore的具体分析略，流程很清晰。