Documentation
¶
Index ¶
- Constants
- type AppServiceHandler
- type ClbIngressStatus
- type CloudListenerStatus
- type HandlerProcessor
- type IngressHandler
- type ListenerHandler
- type NodeHandler
- type Option
- type Processor
- func (p *Processor) Collect(ch chan<- prometheus.Metric)
- func (p *Processor) Describe(ch chan<- *prometheus.Desc)
- func (p *Processor) GetStatusFunction() restful.RouteFunction
- func (p *Processor) Handle()
- func (p *Processor) Init() error
- func (p *Processor) Run()
- func (p *Processor) SetUpdated()
- func (p *Processor) Stop()
- type RemoteListenerStatus
- type Status
- type StatusResponse
- type Updater
Constants ¶
View Source
const ( StatusCodeSuccess = 0 StatusCodeError = 1 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppServiceHandler ¶
type AppServiceHandler struct {
// contains filtered or unexported fields
}
func NewAppServiceHandler ¶
func NewAppServiceHandler() *AppServiceHandler
func (*AppServiceHandler) OnAdd ¶
func (handler *AppServiceHandler) OnAdd(obj interface{})
func (*AppServiceHandler) OnDelete ¶
func (handler *AppServiceHandler) OnDelete(obj interface{})
func (*AppServiceHandler) OnUpdate ¶
func (handler *AppServiceHandler) OnUpdate(objOld, objNew interface{})
func (*AppServiceHandler) RegisterProcessor ¶
func (handler *AppServiceHandler) RegisterProcessor(p HandlerProcessor)
type ClbIngressStatus ¶
type ClbIngressStatus struct {
Name string
Namespace string
clbingressType.ClbIngressSpec
clbingressType.ClbIngressStatus
AppSvcs map[string]*serviceclient.AppService
}
ClbIngressStatus clb ingress status
type CloudListenerStatus ¶
type CloudListenerStatus struct {
Name string
Namespace string
cloudListenerType.CloudListenerSpec
}
CloudListenerStatus cloud listener status
type HandlerProcessor ¶
type HandlerProcessor interface {
SetUpdated()
}
type IngressHandler ¶
type IngressHandler struct {
// contains filtered or unexported fields
}
func NewIngressHandler ¶
func NewIngressHandler() *IngressHandler
func (*IngressHandler) OnAdd ¶
func (handler *IngressHandler) OnAdd(obj interface{})
func (*IngressHandler) OnDelete ¶
func (handler *IngressHandler) OnDelete(obj interface{})
func (*IngressHandler) OnUpdate ¶
func (handler *IngressHandler) OnUpdate(objOld, objNew interface{})
func (*IngressHandler) RegisterProcessor ¶
func (handler *IngressHandler) RegisterProcessor(p HandlerProcessor)
type ListenerHandler ¶
type ListenerHandler struct{}
func NewListenerHandler ¶
func NewListenerHandler() *ListenerHandler
func (*ListenerHandler) OnAdd ¶
func (handler *ListenerHandler) OnAdd(obj interface{})
func (*ListenerHandler) OnDelete ¶
func (handler *ListenerHandler) OnDelete(obj interface{})
func (*ListenerHandler) OnUpdate ¶
func (handler *ListenerHandler) OnUpdate(objOld, objNew interface{})
type NodeHandler ¶
type NodeHandler struct {
// contains filtered or unexported fields
}
func NewNodeHandler ¶
func NewNodeHandler() *NodeHandler
func (*NodeHandler) OnAdd ¶
func (handler *NodeHandler) OnAdd(obj interface{})
func (*NodeHandler) OnDelete ¶
func (handler *NodeHandler) OnDelete(obj interface{})
func (*NodeHandler) OnUpdate ¶
func (handler *NodeHandler) OnUpdate(objOld, objNew interface{})
func (*NodeHandler) RegisterProcessor ¶
func (handler *NodeHandler) RegisterProcessor(p HandlerProcessor)
type Option ¶
type Option struct {
Port int
ServiceRegistry string
ClbName string
NetType string
BackendIPType string
Namespace string
Cluster string
Kubeconfig string
UpdatePeriod int
NodeSyncPeriod int
SyncPeriod int
}
Option processor options
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor processor for ingresses and services
func NewProcessor ¶
NewProcessor create processor for clb controller
func (*Processor) Collect ¶
func (p *Processor) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus exporter Collect interface
func (*Processor) Describe ¶
func (p *Processor) Describe(ch chan<- *prometheus.Desc)
Describe implements promethues exporter Describe interface
func (*Processor) GetStatusFunction ¶
func (p *Processor) GetStatusFunction() restful.RouteFunction
GetStatusFunction get status function
func (*Processor) SetUpdated ¶
func (p *Processor) SetUpdated()
type RemoteListenerStatus ¶
type RemoteListenerStatus struct {
Name string
cloudListenerType.CloudListenerSpec
cloudListenerType.CloudListenerStatus
}
RemoteListenerStatus remote listener status
type Status ¶
type Status struct {
Ingresses []*ClbIngressStatus `json:"ingresses"`
CloudListeners []*CloudListenerStatus `json:"cloudListeners"`
RemoteListeners []*RemoteListenerStatus `json:"remoteListeners"`
}
Status status
type StatusResponse ¶
type StatusResponse struct {
Code int `json:"code"`
Message string `json:"message"`
Data *Status `json:"data,omitempty"`
}
StatusResponse status response
type Updater ¶
type Updater struct {
// contains filtered or unexported fields
}
Updater generate listeners from ingress and service discovery
func NewUpdater ¶
func NewUpdater(opt *Option, svcClient svcclient.Client, ingressRegistry clbingress.Registry, listenerClient listenerclient.Interface) (*Updater, error)
NewUpdater create updater
func (*Updater) EnsureLoadBalancer ¶
EnsureLoadBalancer create new loadbalance cloud lb instance or take over existed cloud lb instance
func (*Updater) ListRemoteListener ¶
func (updater *Updater) ListRemoteListener() ([]*cloudListenerType.CloudListener, error)
ListRemoteListener list remote listener currently it calls cloud api directly TODO: cloud lb interface should has events informer this function should get remote listeners from local cache
Source Files
Click to show internal directories.
Click to hide internal directories.