controller

Documentation

Overview

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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.

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You 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
• func SyncSecretSSL(key string, ssl *v1.Ssl, operator string)
• type Api6Controller
  • func (api6 *Api6Controller) ApisixTLS(controller *Controller)
• type ApisixTLSController
  • func BuildApisixTlsController(kubeclientset kubernetes.Interface, apisixTLSClientset clientset.Interface, ...) *ApisixTLSController
  • func (c *ApisixTLSController) Run(stop <-chan struct{}) error
• type Controller
  • func NewController(cfg *config.Config) (*Controller, error)
  • func (c *Controller) Eventf(_ runtime.Object, eventType string, reason string, message string, ...)
  • func (c *Controller) Run(stop chan struct{}) error
• type TlsQueueObj

Constants

const (
	ADD           = "ADD"
	UPDATE        = "UPDATE"
	DELETE        = "DELETE"
	WatchFromKind = "watch"
)

Functions

func SyncSecretSSL

func SyncSecretSSL(key string, ssl *v1.Ssl, operator string)

SyncSecretSSL sync the secretSSLMap the struct of secretSSLMap is a map[secretKey string]map[sslKey string]bool the xxxKey is format as namespace + "_" + name

Types

type Api6Controller

type Api6Controller struct {
	KubeClientSet             kubernetes.Interface
	Api6ClientSet             clientset.Interface
	SharedInformerFactory     externalversions.SharedInformerFactory
	CoreSharedInformerFactory informers.SharedInformerFactory
	Stop                      <-chan struct{}
}

func (*Api6Controller) ApisixTLS

func (api6 *Api6Controller) ApisixTLS(controller *Controller)

type ApisixTLSController

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

func BuildApisixTlsController

func BuildApisixTlsController(
	kubeclientset kubernetes.Interface,
	apisixTLSClientset clientset.Interface,
	apisixTLSInformer informersv1.ApisixTlsInformer,
	root *Controller) *ApisixTLSController

func (*ApisixTLSController) Run

func (c *ApisixTLSController) Run(stop <-chan struct{}) error

type Controller

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

Controller is the ingress apisix controller object.

func NewController

func NewController(cfg *config.Config) (*Controller, error)

NewController creates an ingress apisix controller object.

func (*Controller) Eventf

func (c *Controller) Eventf(_ runtime.Object, eventType string, reason string, message string, _ ...interface{})

Eventf implements the resourcelock.EventRecorder interface.

func (*Controller) Run

func (c *Controller) Run(stop chan struct{}) error

Run launches the controller.

type TlsQueueObj

type TlsQueueObj struct {
	Key    string              `json:"key"`
	OldObj *configv1.ApisixTls `json:"old_obj"`
	Ope    string              `json:"ope"` // add / update / delete
}