controller

Documentation

Overview

© 2020 Red Hat, Inc. and others

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.

© 2020 Red Hat, Inc. and others

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.

© 2020 Red Hat, Inc. and others

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.

© 2020 Red Hat, Inc. and others

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

• Variables
• type AgentConfig
• type AgentSpecification
• type Controller
  • func New(spec *AgentSpecification, syncerConf broker.SyncerConfig, ...) (*Controller, error)
  • func (a *Controller) Start(stopCh <-chan struct{}) error
• type EndpointController
• type ServiceImportController

Variables

var MaxExportStatusConditions = 10

Types

type AgentConfig

type AgentConfig struct {
	ServiceImportCounterName string
	ServiceExportCounterName string
}

type AgentSpecification

type AgentSpecification struct {
	ClusterID        string
	Namespace        string
	GlobalnetEnabled bool `split_words:"true"`
}

type Controller

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

func New

func New(spec *AgentSpecification, syncerConf broker.SyncerConfig, kubeClientSet kubernetes.Interface,
	syncerMetricNames AgentConfig) (*Controller, error)

func (*Controller) Start

func (a *Controller) Start(stopCh <-chan struct{}) error

type EndpointController

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

Each EndpointController listens for the endpoints that backs a service and have a ServiceImport It will create an endpoint slice corresponding to an endpoint object and set the owner references to ServiceImport. The app label from the endpoint will be added to endpoint slice as well.

type ServiceImportController

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

The ServiceImportController listens for ServiceImport resources created in the target namespace and creates an EndpointController in response. The EndpointController will use the app label as filter to listen only for the endpoints event related to ServiceImport created