generic

Documentation

Index

• type Deployer
  • func NewDeployer(syncMode clusterapi.ClusterSyncMode, appPusherEnabled bool, ...) (*Deployer, error)
  • func (deployer *Deployer) AddController(gvk schema.GroupVersionKind, controller *resourcecontroller.Controller) bool
  • func (deployer *Deployer) ControllerHasStarted(gvk schema.GroupVersionKind) bool
  • func (deployer *Deployer) ResourceCallbackHandler(resource *unstructured.Unstructured) error
  • func (deployer *Deployer) Run(workers int, ctx context.Context)
  • func (deployer *Deployer) SyncDescriptionStatus(dynamicClient dynamic.Interface, restMapper meta.RESTMapper, ...) error

Types

type Deployer

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

func NewDeployer

func NewDeployer(syncMode clusterapi.ClusterSyncMode, appPusherEnabled bool,
	appDeployerConfig *rest.Config, clusternetClient *clusternetclientset.Clientset,
	clusternetInformerFactory clusternetinformers.SharedInformerFactory,
	recorder record.EventRecorder) (*Deployer, error)

func (*Deployer) AddController

func (deployer *Deployer) AddController(gvk schema.GroupVersionKind, controller *resourcecontroller.Controller) bool

func (*Deployer) ControllerHasStarted

func (deployer *Deployer) ControllerHasStarted(gvk schema.GroupVersionKind) bool

func (*Deployer) ResourceCallbackHandler

func (deployer *Deployer) ResourceCallbackHandler(resource *unstructured.Unstructured) error

func (*Deployer) Run

func (deployer *Deployer) Run(workers int, ctx context.Context)

func (*Deployer) SyncDescriptionStatus

func (deployer *Deployer) SyncDescriptionStatus(
	dynamicClient dynamic.Interface,
	restMapper meta.RESTMapper,
	desc *appsapi.Description,
) error