internal

package
v0.0.0-...-8ccf8f9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 3, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var IsNetworkingIngressAvailable bool

IsNetworkingIngressAvailable indicates if package "k8s.io/api/networking/v1beta1" is available or not

Functions

func NetworkingIngressAvailable

func NetworkingIngressAvailable(client clientset.Interface) bool

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 ErrMsg

type ErrMsg map[string]EventMsg

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL