Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

k8s

package

Go to main page

Versions in this module

v1

v1.0.2

Aug 8, 2023

v1.0.1

Aug 8, 2023

v1.0.0

Aug 7, 2023

Changes in this version

+ const IngressEventReasonConflictingIngressClass

+ const IngressEventReasonFailedAddFinalizer

+ const IngressEventReasonFailedBuildModel

+ const IngressEventReasonFailedDeployModel

+ const IngressEventReasonFailedLoadGroupID

+ const IngressEventReasonFailedRemoveFinalizer

+ const IngressEventReasonFailedUpdateStatus

+ const IngressEventReasonSuccessfullyReconciled

+ const ServiceEventReasonFailedAddFinalizer

+ const ServiceEventReasonFailedBuildModel

+ const ServiceEventReasonFailedCleanupStatus

+ const ServiceEventReasonFailedDeployModel

+ const ServiceEventReasonFailedRemoveFinalizer

+ const ServiceEventReasonFailedUpdateStatus

+ const ServiceEventReasonSuccessfullyReconciled

+ const TargetGroupBindingEventReasonBackendNotFound

+ const TargetGroupBindingEventReasonFailedAddFinalizer

+ const TargetGroupBindingEventReasonFailedCleanup

+ const TargetGroupBindingEventReasonFailedRemoveFinalizer

+ const TargetGroupBindingEventReasonFailedUpdateStatus

+ const TargetGroupBindingEventReasonSuccessfullyReconciled

+ func ExtractNodeInstanceID(node *corev1.Node) (string, error)

+ func GetNodeCondition(node *corev1.Node, conditionType corev1.NodeConditionType) *corev1.NodeCondition

+ func GetPodCondition(pod *corev1.Pod, conditionType corev1.PodConditionType) *corev1.PodCondition

+ func HasFinalizer(obj metav1.Object, finalizer string) bool

+ func IsPodContainersReady(pod *corev1.Pod) bool

+ func IsPodHasReadinessGate(pod *corev1.Pod, conditionType corev1.PodConditionType) bool

+ func LookupContainerPort(pod *corev1.Pod, port intstr.IntOrString) (int64, error)

+ func LookupServicePort(svc *corev1.Service, port intstr.IntOrString) (corev1.ServicePort, error)

+ func NamespacedName(obj metav1.Object) types.NamespacedName

+ func NewDefaultPodInfoRepo(getter cache.Getter, watchNamespace string, logger logr.Logger) *defaultPodInfoRepo

+ func NewSecretsManager(clientSet kubernetes.Interface, secretsEventChan chan<- event.GenericEvent, ...) *defaultSecretsManager

+ func ToSliceOfNamespacedNames(s []T) []types.NamespacedName

+ func UpdatePodCondition(pod *corev1.Pod, condition corev1.PodCondition)

+ type ConversionFunc func(obj interface{}) (interface{}, error)

+ type ConversionStore struct

+ func NewConversionStore(conversionFunc ConversionFunc, keyFunc cache.KeyFunc) *ConversionStore

+ func (s *ConversionStore) Add(obj interface{}) error

+ func (s *ConversionStore) Delete(obj interface{}) error

+ func (s *ConversionStore) Get(obj interface{}) (item interface{}, exists bool, err error)

+ func (s *ConversionStore) GetByKey(key string) (item interface{}, exists bool, err error)

+ func (s *ConversionStore) List() []interface{}

+ func (s *ConversionStore) ListKeys() []string

+ func (s *ConversionStore) Replace(list []interface{}, resourceVersion string) error

+ func (s *ConversionStore) Resync() error

+ func (s *ConversionStore) Update(obj interface{}) error

+ type FinalizerManager interface

+ AddFinalizers func(ctx context.Context, object client.Object, finalizers ...string) error

+ RemoveFinalizers func(ctx context.Context, object client.Object, finalizers ...string) error

+ func NewDefaultFinalizerManager(k8sClient client.Client, log logr.Logger) FinalizerManager

+ type MockFinalizerManager struct

+ func NewMockFinalizerManager(ctrl *gomock.Controller) *MockFinalizerManager

+ func (m *MockFinalizerManager) AddFinalizers(arg0 context.Context, arg1 client.Object, arg2 ...string) error

+ func (m *MockFinalizerManager) EXPECT() *MockFinalizerManagerMockRecorder

+ func (m *MockFinalizerManager) RemoveFinalizers(arg0 context.Context, arg1 client.Object, arg2 ...string) error

+ type MockFinalizerManagerMockRecorder struct

+ func (mr *MockFinalizerManagerMockRecorder) AddFinalizers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockFinalizerManagerMockRecorder) RemoveFinalizers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockPodInfoRepo struct

+ func NewMockPodInfoRepo(ctrl *gomock.Controller) *MockPodInfoRepo

+ func (m *MockPodInfoRepo) EXPECT() *MockPodInfoRepoMockRecorder

+ func (m *MockPodInfoRepo) Get(arg0 context.Context, arg1 types.NamespacedName) (PodInfo, bool, error)

+ func (m *MockPodInfoRepo) ListKeys(arg0 context.Context) []types.NamespacedName

+ type MockPodInfoRepoMockRecorder struct

+ func (mr *MockPodInfoRepoMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPodInfoRepoMockRecorder) ListKeys(arg0 interface{}) *gomock.Call

+ type PodENIInfo struct

+ ENIID string

+ PrivateIP string

+ type PodInfo struct

+ Conditions []corev1.PodCondition

+ ContainerPorts []corev1.ContainerPort

+ ENIInfos []PodENIInfo

+ Key types.NamespacedName

+ NodeName string

+ PodIP string

+ ReadinessGates []corev1.PodReadinessGate

+ UID types.UID

+ func (i *PodInfo) GetPodCondition(conditionType corev1.PodConditionType) (corev1.PodCondition, bool)

+ func (i *PodInfo) HasAnyOfReadinessGates(conditionTypes []corev1.PodConditionType) bool

+ func (i *PodInfo) IsContainersReady() bool

+ func (i *PodInfo) LookupContainerPort(port intstr.IntOrString) (int64, error)

+ type PodInfoRepo interface

+ Get func(ctx context.Context, key types.NamespacedName) (PodInfo, bool, error)

+ ListKeys func(ctx context.Context) []types.NamespacedName

+ type SecretsManager interface

+ MonitorSecrets func(ingressGroupID string, secrets []types.NamespacedName)

+ type SecretsStore struct

+ func NewSecretsStore(secretsEventChan chan<- event.GenericEvent, keyFunc cache.KeyFunc, ...) *SecretsStore

+ func (s *SecretsStore) Add(obj interface{}) error

+ func (s *SecretsStore) Delete(obj interface{}) error

+ func (s *SecretsStore) Get(obj interface{}) (item interface{}, exists bool, err error)

+ func (s *SecretsStore) GetByKey(key string) (item interface{}, exists bool, err error)

+ func (s *SecretsStore) List() []interface{}

+ func (s *SecretsStore) ListKeys() []string

+ func (s *SecretsStore) Replace(list []interface{}, resourceVersion string) error

+ func (s *SecretsStore) Resync() error

+ func (s *SecretsStore) Update(obj interface{}) error

Other modules containing this package

github.com/sonal-chauhan/aws-load-balancer-controller/v2