hostresources

Documentation

Index

• Variables
• type Options
• type ResourcesAccessor
• type ResourcesManager
  • func NewHostResourcesManager(opts *Options) ResourcesManager

Variables

var GetHostClient = func(token, masterURL string) (*kubeconfig.KubeClients, error) {
	return kubeconfig.CreateClientSetsFromToken(token, masterURL)
}

GetHostClient returns kubeClient and kusciaClient of host cluster.

Types

type Options

type Options struct {
	MemberKusciaClient          kusciaclientset.Interface
	MemberDomainLister          kuscialistersv1alpha1.DomainLister
	MemberDeploymentLister      kuscialistersv1alpha1.KusciaDeploymentLister
	MemberJobLister             kuscialistersv1alpha1.KusciaJobLister
	MemberTaskLister            kuscialistersv1alpha1.KusciaTaskLister
	MemberTaskResourceLister    kuscialistersv1alpha1.TaskResourceLister
	MemberDomainDataLister      kuscialistersv1alpha1.DomainDataLister
	MemberDomainDataGrantLister kuscialistersv1alpha1.DomainDataGrantLister
}

Options defines some options for host resources manager.

type ResourcesAccessor

type ResourcesAccessor interface {
	HasSynced() bool
	HostKusciaClient() kusciaclientset.Interface
	HostJobLister() kuscialistersv1alpha1.KusciaJobLister
	HostJobSummaryLister() kuscialistersv1alpha1.KusciaJobSummaryLister
	HostTaskSummaryLister() kuscialistersv1alpha1.KusciaTaskSummaryLister
	HostDeploymentLister() kuscialistersv1alpha1.KusciaDeploymentLister
	HostDeploymentSummaryLister() kuscialistersv1alpha1.KusciaDeploymentSummaryLister
	HostDomainDataLister() kuscialistersv1alpha1.DomainDataLister
	HostDomainDataGrantLister() kuscialistersv1alpha1.DomainDataGrantLister
	EnqueueDeployment(string)
}

ResourcesAccessor is an interface to get host resources controller related information.

type ResourcesManager

type ResourcesManager interface {
	Register(host, member string) error
	Deregister(host, member string)
	SetWorkers(worker int)
	GetHostResourceAccessor(host, member string) ResourcesAccessor
	Stop()
	HasSynced() bool
}

ResourcesManager is an interface to manage host resources.

func NewHostResourcesManager

func NewHostResourcesManager(opts *Options) ResourcesManager