Golang cache.NewThreadSafeStore函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中k8s/io/kubernetes/pkg/client/cache.NewThreadSafeStore函数的典型用法代码示例。如果您正苦于以下问题：Golang NewThreadSafeStore函数的具体用法？Golang NewThreadSafeStore怎么用？Golang NewThreadSafeStore使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了NewThreadSafeStore函数的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: proxyHealthCheckFactory

// proxyHealthCheckRequest - Factory method to instantiate the health check handler
func proxyHealthCheckFactory() *proxyHC {
	glog.V(2).Infof("Initializing kube-proxy health checker")
	phc := &proxyHC{
		serviceEndpointsMap:    cache.NewThreadSafeStore(cache.Indexers{}, cache.Indices{}),
		serviceResponderMap:    make(map[types.NamespacedName]serviceResponder),
		mutationRequestChannel: make(chan *proxyMutationRequest, 1024),
		listenerRequestChannel: make(chan *proxyListenerRequest, 1024),
	}
	return phc
}

开发者ID:humblec，项目名称:kubernetes，代码行数:11，代码来源:healthcheck.go

示例2: newPodTracker

func newPodTracker() *podTracker {
	return &podTracker{cache.NewThreadSafeStore(
		cache.Indexers{}, cache.Indices{})}
}

开发者ID:ethernetdan，项目名称:kubernetes，代码行数:4，代码来源:daemon_restart.go

示例3: NewInMemoryPool

// NewInMemoryPool creates an InMemoryPool.
func NewInMemoryPool() *InMemoryPool {
	return &InMemoryPool{
		cache.NewThreadSafeStore(cache.Indexers{}, cache.Indices{})}
}

开发者ID:raggi，项目名称:contrib，代码行数:5，代码来源:pools.go

示例4: newPoolStore

func newPoolStore() *poolStore {
	return &poolStore{
		cache.NewThreadSafeStore(cache.Indexers{}, cache.Indices{})}
}

开发者ID:resouer，项目名称:contrib，代码行数:4，代码来源:utils.go

示例5: newSSLCertTracker

func newSSLCertTracker() *sslCertTracker {
	return &sslCertTracker{
		cache.NewThreadSafeStore(cache.Indexers{}, cache.Indices{}),
	}
}

开发者ID:aledbf，项目名称:Ingress，代码行数:5，代码来源:backend_ssl.go

注：本文中的k8s/io/kubernetes/pkg/client/cache.NewThreadSafeStore函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。