Documentation ¶
Index ¶
- Variables
- func NetworkingIngressAvailable(client clientset.Interface) bool
- type CloudEventRecorder
- type ErrMsg
- type EventError
- type EventMsg
- type IngressResource
- type ResourceManager
- func (rm *ResourceManager) GenerateKubeEvent(errs EventError) error
- func (rm *ResourceManager) NewCloudEventRecorder(namespace string) *CloudEventRecorder
- func (rm *ResourceManager) RemoveStatusAddress(ing *networking.Ingress)
- func (rm *ResourceManager) ResetIngressStatus()
- func (rm *ResourceManager) UpdateIngressStatus(ing *networking.Ingress)
Constants ¶
This section is empty.
Variables ¶
var IsNetworkingIngressAvailable bool
IsNetworkingIngressAvailable indicates if package "k8s.io/api/networking/v1beta1" is available or not
Functions ¶
func NetworkingIngressAvailable ¶
NetworkingIngressAvailable checks if the package "k8s.io/api/networking/v1beta1" is available or not
Types ¶
type CloudEventRecorder ¶
type CloudEventRecorder struct { Name string Recorder record.EventRecorder }
CloudEventRecorder is the cloud event recorder data
func NewCloudEventRecorderV1 ¶
func NewCloudEventRecorderV1(eventInterface v1core.EventInterface) *CloudEventRecorder
NewCloudEventRecorderV1 returns a cloud event recorder for v1 client
type EventError ¶
type EventError struct { Ing *networking.Ingress MsgCode string OverwriteMsg string }
EventError ...
type EventMsg ¶
type EventMsg struct { Code string `json:"code" binding:"required"` Msg string `json:"message" binding:"required"` Reason string `json:"reason"` Type string `json:"type"` }
EventMsg ...
type IngressResource ¶
type IngressResource struct { Name string Namespace string NotFirstSecretError bool NotFirstSSLSecretError bool NotFirstMASecretError bool }
IngressResource ...
type ResourceManager ¶
type ResourceManager struct { Client kubernetes.Interface ListOfResources []IngressResource }
ResourceManager ...
func (*ResourceManager) GenerateKubeEvent ¶
func (rm *ResourceManager) GenerateKubeEvent(errs EventError) error
GenerateKubeEvent generates a normal or warning kubernetes event specific to an ingress
func (*ResourceManager) NewCloudEventRecorder ¶
func (rm *ResourceManager) NewCloudEventRecorder(namespace string) *CloudEventRecorder
NewCloudEventRecorder returns a cloud event recorder.
func (*ResourceManager) RemoveStatusAddress ¶
func (rm *ResourceManager) RemoveStatusAddress(ing *networking.Ingress)
func (*ResourceManager) ResetIngressStatus ¶
func (rm *ResourceManager) ResetIngressStatus()
ResetIngressStatus resets the ingress status in resource to an empty list This will trigger the other albs to resync the ingress resource thereby reflecting the correct IP constantly.
func (*ResourceManager) UpdateIngressStatus ¶
func (rm *ResourceManager) UpdateIngressStatus(ing *networking.Ingress)
UpdateIngressStatus updates the ingress address section