psc

Documentation

Overview

Copyright 2021 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• Variables
• func SvcAttachmentKeyFunc(namespace, name string) string
• type Controller
  • func NewController(ctx *context.ControllerContext) *Controller
  • func (c *Controller) Run(stopChan <-chan struct{})

Constants

const (

	// SvcAttachmentGCError is the service attachment GC error event reason
	SvcAttachmentGCError = "ServiceAttachmentGCError"
	// ServiceAttachmentFinalizer used by the psc controller to ensure Service Attachment CRs
	// are deleted after the corresponding Service Attachments are deleted
	ServiceAttachmentFinalizerKey = "networking.gke.io/service-attachment-finalizer"

	// ServiceAttachmentGCPeriod is the interval at which Service Attachment GC will run
	ServiceAttachmentGCPeriod = 2 * time.Minute
)

Variables

var (
	ServiceNotFoundError = errors.New("service not in store")
	MismatchedILBIPError = errors.New("Mismatched ILB IP")
)

Functions

func SvcAttachmentKeyFunc

func SvcAttachmentKeyFunc(namespace, name string) string

SvcAttachmentKeyFunc provides the service attachment key used by the svcAttachmentLister

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller is a private service connect (psc) controller It watches ServiceAttachment resources and creates, deletes, and manages corresponding GCE Service Attachment resources

func NewController

func NewController(ctx *context.ControllerContext) *Controller

func (*Controller) Run

func (c *Controller) Run(stopChan <-chan struct{})

Run waits for the initial sync and will process keys in the queue and run GC until signaled