【K8s】kube-proxy 源码分析 01-02

pkg/proxy/config/config.go

type ServiceConfig struct {
	// Configuration sources and their lock.
	configSourceLock       sync.RWMutex
	serviceConfigSources   map[string]chan ServiceUpdate
	endpointsConfigSources map[string]chan EndpointsUpdate

	// Handlers for changes to services and endpoints and their lock.
	handlerLock      sync.RWMutex
	serviceHandlers  []ServiceConfigHandler
	endpointHandlers []EndpointsConfigHandler

	// Last known configuration for union of the sources and the locks. Map goes
	// from each source to array of services/endpoints that have been configured
	// through that channel.
	configLock     sync.RWMutex
	serviceConfig  map[string]map[string]api.Service
	endpointConfig map[string]map[string]api.Endpoints

	// Channel that service configuration source listeners use to signal of new
	// configurations.
	// Value written is the source of the change.
	serviceNotifyChannel chan string

	// Channel that endpoint configuration source listeners use to signal of new
	// configurations.
	// Value written is the source of the change.
	endpointsNotifyChannel chan string
}

func (impl *ServiceConfig) Run() {}

	for {
		select {
		case source := <-impl.serviceNotifyChannel:
			log.Printf("Got new service configuration from source %s", source)
			impl.NotifyServiceUpdate()
		case source := <-impl.endpointsNotifyChannel:
			log.Printf("Got new endpoint configuration from source %s", source)
			impl.NotifyEndpointsUpdate()
		case <-time.After(1 * time.Second):
		}
	}