infomanifest

Documentation

Index

• Constants
• type Controller
  • func (c *Controller) FetchLocalServiceCM(namespace string) (*corev1.ConfigMap, error)
  • func (c *Controller) IsOnlineENV() bool
  • 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) UpdateLocalAvailableImage(manifests []manifestv1alpha1.Manifest)
  • func (c *Controller) UpdateLocalService(manifests []manifestv1alpha1.Manifest) bool
• type VersionedManifest
  • func GetVersionedManifest() *VersionedManifest
  • func (m *VersionedManifest) Op(op string, m1, m2 *manifestv1alpha1.Manifest)

Constants

const LocalServiceConfigMap = "kubean-localservice"

const Loop = time.Second * 30

Types

type Controller

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

func (*Controller) FetchLocalServiceCM

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

func (*Controller) IsOnlineENV

func (c *Controller) IsOnlineENV() bool

IsOnlineENV indicates what the running env is onLine or air-gap.

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) UpdateLocalAvailableImage

func (c *Controller) UpdateLocalAvailableImage(manifests []manifestv1alpha1.Manifest)

UpdateLocalAvailableImage update image infos into status.

func (*Controller) UpdateLocalService

func (c *Controller) UpdateLocalService(manifests []manifestv1alpha1.Manifest) bool

UpdateLocalService sync the content of local-service configmap into spec.

type VersionedManifest

type VersionedManifest struct {
	Manifests map[string][]*manifestv1alpha1.Manifest
	// contains filtered or unexported fields
}

func GetVersionedManifest

func GetVersionedManifest() *VersionedManifest

func (*VersionedManifest) Op

func (m *VersionedManifest) Op(op string, m1, m2 *manifestv1alpha1.Manifest)