infomanifest

Documentation

Index

• Constants
• func NewGlobalInfoManifest(latestInfoManifest *manifestv1alpha1.Manifest) *manifestv1alpha1.Manifest
• type Controller
  • func (c *Controller) EnsureGlobalInfoManifestBeingLatest(latestInfoManifest *manifestv1alpha1.Manifest) (*manifestv1alpha1.Manifest, error)
  • func (c *Controller) FetchGlobalInfoManifest() (*manifestv1alpha1.Manifest, error)
  • func (c *Controller) FetchLatestInfoManifest() (*manifestv1alpha1.Manifest, error)
  • func (c *Controller) FetchLocalServiceCM(namespace string) (*corev1.ConfigMap, error)
  • func (c *Controller) ParseConfigMapToLocalService(localServiceConfigMap *corev1.ConfigMap) (*manifestv1alpha1.LocalService, error)
  • func (c *Controller) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *Controller) SetupWithManager(mgr controllerruntime.Manager) error
  • func (c *Controller) Start(ctx context.Context) error
  • func (c *Controller) UpdateGlobalLocalService()
  • func (c *Controller) UpdateLocalAvailableImage()

Constants

const LocalServiceConfigMap = "kubean-localservice"

const Loop = time.Second * 30

const OriginLabel = "origin"

Functions

func NewGlobalInfoManifest

func NewGlobalInfoManifest(latestInfoManifest *manifestv1alpha1.Manifest) *manifestv1alpha1.Manifest

Types

type Controller

type Controller struct {
	client.Client
	InfoManifestClientSet manifestClientSet.Interface
	ClientSet             kubernetes.Interface
}

func (*Controller) EnsureGlobalInfoManifestBeingLatest

func (c *Controller) EnsureGlobalInfoManifestBeingLatest(latestInfoManifest *manifestv1alpha1.Manifest) (*manifestv1alpha1.Manifest, error)

func (*Controller) FetchGlobalInfoManifest

func (c *Controller) FetchGlobalInfoManifest() (*manifestv1alpha1.Manifest, error)

func (*Controller) FetchLatestInfoManifest

func (c *Controller) FetchLatestInfoManifest() (*manifestv1alpha1.Manifest, error)

FetchLatestInfoManifest , get infomanifest exclude the global-infomanifest.

func (*Controller) FetchLocalServiceCM

func (c *Controller) FetchLocalServiceCM(namespace string) (*corev1.ConfigMap, error)

func (*Controller) ParseConfigMapToLocalService

func (c *Controller) ParseConfigMapToLocalService(localServiceConfigMap *corev1.ConfigMap) (*manifestv1alpha1.LocalService, error)

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)

func (*Controller) SetupWithManager

func (c *Controller) SetupWithManager(mgr controllerruntime.Manager) error

func (*Controller) Start

func (c *Controller) Start(ctx context.Context) error

func (*Controller) UpdateGlobalLocalService

func (c *Controller) UpdateGlobalLocalService()

func (*Controller) UpdateLocalAvailableImage

func (c *Controller) UpdateLocalAvailableImage()