traffic

Documentation

Index

• Constants
• type Controller
  • func NewController(shipperclientset shipperclient.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{})
• type PatchOperation
• type TargetClusterMathError
  • func NewTargetClusterMathError(releaseName string, idlePodCount int, missingCount int) TargetClusterMathError
• type TargetClusterPodListingError
  • func NewTargetClusterPodListingError(clusterName string, namespace string, err error) TargetClusterPodListingError
  • func NewTargetClusterReleasePodListingError(releaseName string, clusterName string, namespace string, err error) TargetClusterPodListingError
• type TargetClusterServiceError
  • func NewTargetClusterFetchServiceFailedError(clusterName string, selector string, namespace string, err error) TargetClusterServiceError
  • func NewTargetClusterServiceMissesSelectorError(clusterName string, namespace string, serviceName string) TargetClusterServiceError
  • func NewTargetClusterWrongServiceCountError(clusterName string, selector string, namespace string, serviceCount int) TargetClusterServiceError
• type TargetClusterTrafficError
  • func NewTargetClusterTrafficModifyingLabelError(clusterName string, namespace string, podName string, err error) TargetClusterTrafficError

Constants

const AgentName = "traffic-controller"

Types

type Controller

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

Controller is the controller implementation for TrafficTarget resources.

func NewController

func NewController(
	shipperclientset shipperclient.Interface,
	shipperInformerFactory informers.SharedInformerFactory,
	store *clusterclientstore.Store,
	recorder record.EventRecorder,
) *Controller

NewController returns a new TrafficTarget controller.

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{})

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

type PatchOperation

type PatchOperation struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value string `json:"value"`
}

PatchOperation represents a JSON PatchOperation in a very specific way. Using jsonpatch's types could be a possiblity, but there's no need to be generic in here.

type TargetClusterMathError

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

func NewTargetClusterMathError

func NewTargetClusterMathError(
	releaseName string,
	idlePodCount int,
	missingCount int,
) TargetClusterMathError

type TargetClusterPodListingError

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

func NewTargetClusterPodListingError

func NewTargetClusterPodListingError(
	clusterName string,
	namespace string,
	err error,
) TargetClusterPodListingError

func NewTargetClusterReleasePodListingError

func NewTargetClusterReleasePodListingError(
	releaseName string,
	clusterName string,
	namespace string,
	err error,
) TargetClusterPodListingError

type TargetClusterServiceError

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

func NewTargetClusterFetchServiceFailedError

func NewTargetClusterFetchServiceFailedError(
	clusterName string,
	selector string,
	namespace string,
	err error,
) TargetClusterServiceError

func NewTargetClusterServiceMissesSelectorError

func NewTargetClusterServiceMissesSelectorError(
	clusterName string,
	namespace string,
	serviceName string,
) TargetClusterServiceError

func NewTargetClusterWrongServiceCountError

func NewTargetClusterWrongServiceCountError(
	clusterName string,
	selector string,
	namespace string,
	serviceCount int,
) TargetClusterServiceError

type TargetClusterTrafficError

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

func NewTargetClusterTrafficModifyingLabelError

func NewTargetClusterTrafficModifyingLabelError(
	clusterName string,
	namespace string,
	podName string,
	err error,
) TargetClusterTrafficError