cron

Documentation

Overview

Copyright 2019, Oath Inc.

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

• type AthenzContactTimeConfigMap
• type Cron
  • func NewCron(k8sClient kubernetes.Interface, checkInterval time.Duration, ...) *Cron
  • func (c *Cron) AddAdminSystemDomains()
  • func (c *Cron) FullResync(stopCh <-chan struct{})
  • func (c *Cron) SetEtag(timestamp string)
  • func (c *Cron) UpdateAthenzContactTime(etag string)
  • func (c *Cron) UpdateCron(stopCh <-chan struct{})
  • func (c *Cron) ValidateDomain(domain string) bool

Types

type AthenzContactTimeConfigMap

type AthenzContactTimeConfigMap struct {
	Namespace,
	Name,
	Key string
}

AthenzContactTimeConfigMap for recording the latesttime that the Update Cron contacted Athenz

type Cron

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

Cron type for cron updates

func NewCron

func NewCron(k8sClient kubernetes.Interface, checkInterval time.Duration, syncInterval time.Duration, etag string, zmsClient *zms.ZMSClient, informer cache.SharedIndexInformer, queue workqueue.RateLimitingInterface, util *util.Util, cr *cr.CRUtil, cm *AthenzContactTimeConfigMap) *Cron

NewCron - creates new cron object

func (*Cron) AddAdminSystemDomains

func (c *Cron) AddAdminSystemDomains()

AddAdminSystemDomains - add admin domain and all the system domains to the queue

func (*Cron) FullResync

func (c *Cron) FullResync(stopCh <-chan struct{})

FullResync - add all namespaces to the queue for full resync

func (*Cron) SetEtag

func (c *Cron) SetEtag(timestamp string)

SetEtag - set initial etag in cron field

func (*Cron) UpdateAthenzContactTime

func (c *Cron) UpdateAthenzContactTime(etag string)

UpdateAthenzContactTime - update the latest athenz contact timestamp in config map

func (*Cron) UpdateCron

func (c *Cron) UpdateCron(stopCh <-chan struct{})

UpdateCron - Run starts the main controller loop running sync at every poll interval

func (*Cron) ValidateDomain

func (c *Cron) ValidateDomain(domain string) bool

ValidateDomain - validate if the domain is whether a namespace, admin domain, system domain or trust domain