Corrects wording of godoc comments.
This commit is contained in:

committed by
Yuki Sonoda (Yugui)

parent
1bd7276aca
commit
2861955025
@@ -109,7 +109,7 @@ func (m *Master) Run(myAddress, apiPrefix string) error {
|
|||||||
return s.ListenAndServe()
|
return s.ListenAndServe()
|
||||||
}
|
}
|
||||||
|
|
||||||
// ConstructHandler returns an http.Handler which serves Kubernetes API.
|
// ConstructHandler returns an http.Handler which serves the Kubernetes API.
|
||||||
// Instead of calling Run, you can call this function to get a handler for your own server.
|
// Instead of calling Run, you can call this function to get a handler for your own server.
|
||||||
// It is intended for testing. Only call once.
|
// It is intended for testing. Only call once.
|
||||||
func (m *Master) ConstructHandler(apiPrefix string) http.Handler {
|
func (m *Master) ConstructHandler(apiPrefix string) http.Handler {
|
||||||
|
@@ -54,14 +54,14 @@ type EndpointsUpdate struct {
|
|||||||
Op Operation
|
Op Operation
|
||||||
}
|
}
|
||||||
|
|
||||||
// ServiceConfigHandler is an abstract interface of objects which receive update notifications of the set of services.
|
// ServiceConfigHandler is an abstract interface of objects which receive update notifications for the set of services.
|
||||||
type ServiceConfigHandler interface {
|
type ServiceConfigHandler interface {
|
||||||
// OnUpdate gets called when a configuration has been changed by one of the sources.
|
// OnUpdate gets called when a configuration has been changed by one of the sources.
|
||||||
// This is the union of all the configuration sources.
|
// This is the union of all the configuration sources.
|
||||||
OnUpdate(services []api.Service)
|
OnUpdate(services []api.Service)
|
||||||
}
|
}
|
||||||
|
|
||||||
// EndpointsConfigHandler is an abstract interface of objects which receive update notifications of the set of endpoints.
|
// EndpointsConfigHandler is an abstract interface of objects which receive update notifications for the set of endpoints.
|
||||||
type EndpointsConfigHandler interface {
|
type EndpointsConfigHandler interface {
|
||||||
// OnUpdate gets called when endpoints configuration is changed for a given
|
// OnUpdate gets called when endpoints configuration is changed for a given
|
||||||
// service on any of the configuration sources. An example is when a new
|
// service on any of the configuration sources. An example is when a new
|
||||||
|
@@ -41,7 +41,7 @@ func NewLoadBalancerRR() *LoadBalancerRR {
|
|||||||
return &LoadBalancerRR{endpointsMap: make(map[string][]string), rrIndex: make(map[string]int)}
|
return &LoadBalancerRR{endpointsMap: make(map[string][]string), rrIndex: make(map[string]int)}
|
||||||
}
|
}
|
||||||
|
|
||||||
// LoadBalance select an endpoint of the service by round-robin algorithm.
|
// LoadBalance selects an endpoint of the service by round-robin algorithm.
|
||||||
func (impl LoadBalancerRR) LoadBalance(service string, srcAddr net.Addr) (string, error) {
|
func (impl LoadBalancerRR) LoadBalance(service string, srcAddr net.Addr) (string, error) {
|
||||||
impl.lock.RLock()
|
impl.lock.RLock()
|
||||||
endpoints, exists := impl.endpointsMap[service]
|
endpoints, exists := impl.endpointsMap[service]
|
||||||
|
Reference in New Issue
Block a user