kube

Documentation

Index

• Constants
• type Apply
• type ApplyClient
  • func NewApplyClient(ctx context.Context, kubeClient kubernetes.Interface, ...) (*ApplyClient, error)
  • func (c *ApplyClient) CreateApply(tpl *v1alpha1.Apply) (*v1alpha1.Apply, error)
  • func (c *ApplyClient) DeleteApply(ns, name string) error
  • func (c *ApplyClient) GetApply(ns, name string) (*v1alpha1.Apply, error)
  • func (c *ApplyClient) ListApplies(ns string, selector labels.Selector) ([]*v1alpha1.Apply, error)
  • func (c *ApplyClient) Run() error
  • func (c *ApplyClient) Start()
  • func (c *ApplyClient) UpdateApply(tpl *v1alpha1.Apply) (*v1alpha1.Apply, error)
• type Client
  • func NewController(ctx context.Context, path string) (Client, error)
• type Cluster
• type ClusterClient
  • func NewClusterClient(ctx context.Context, kubeClient kubernetes.Interface, ...) (*ClusterClient, error)
  • func (c *ClusterClient) CreateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)
  • func (c *ClusterClient) DeleteCluster(ns, name string) error
  • func (c *ClusterClient) GetCluster(ns, name string) (*v1alpha1.Cluster, error)
  • func (c *ClusterClient) ListClusters(ns string, selector labels.Selector) ([]*v1alpha1.Cluster, error)
  • func (c *ClusterClient) Run() error
  • func (c *ClusterClient) Start()
  • func (c *ClusterClient) UpdateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)
• type Config
• type Controller
• type Template
• type TemplateClient
  • func NewTemplateClient(ctx context.Context, kubeClient kubernetes.Interface, ...) (*TemplateClient, error)
  • func (c *TemplateClient) CreateTemplate(tpl *v1alpha1.Template) (*v1alpha1.Template, error)
  • func (c *TemplateClient) DeleteTemplate(ns, name string) error
  • func (c *TemplateClient) GetTemplate(ns, name string) (*v1alpha1.Template, error)
  • func (c *TemplateClient) ListTemplates(ns string, selector labels.Selector) ([]*v1alpha1.Template, error)
  • func (c *TemplateClient) Run() error
  • func (c *TemplateClient) Start()
  • func (c *TemplateClient) UpdateTemplate(tpl *v1alpha1.Template) (*v1alpha1.Template, error)

Constants

const (
	DefaultResyncApply       = time.Second * 30
	ControllerAgentNameApply = "apply-controller"
	ApplyKind                = "Apply"
	DefaultValuesKey         = "default"

	ApplySuccessSynced     = "ApplySynced"
	ErrApplyResourceExists = "ErrApplyResourceExists"
	MessageApplySynced     = "Apply synced successfully"
	MessageApplyExists     = "Resource %q already exists and is not managed by Apply"
)

const (
	DefaultResyncCluster       = time.Second * 30
	ControllerAgentNameCluster = "cluster-controller"
	ClusterKind                = "Cluster"

	ClusterSuccessSynced     = "ClusterSynced"
	ErrClusterResourceExists = "ErrClusterResourceExists"
	MessageClusterSynced     = "Cluster synced successfully"
	MessageClusterExists     = "Resource %q already exists and is not managed by Cluster"
)

const (
	DefaultResyncTemplate       = time.Second * 30
	ControllerAgentNameTemplate = "template-controller"
	TemplateKind                = "Template"

	TemplateSuccessSynced     = "TemplateSynced"
	ErrTemplateResourceExists = "ErrTemplateResourceExists"
	MessageTemplateSynced     = "Template synced successfully"
	MessageTemplateExists     = "Resource %q already exists and is not managed by Template"
)

const (
	DefaultThreadiness = 2
)

Types

type Apply

type Apply interface {
	CreateApply(clt *v1alpha1.Apply) (*v1alpha1.Apply, error)
	GetApply(ns, name string) (*v1alpha1.Apply, error)
	UpdateApply(clt *v1alpha1.Apply) (*v1alpha1.Apply, error)
	DeleteApply(ns, name string) error
	ListApplies(ns string, selector labels.Selector) ([]*v1alpha1.Apply, error)
}

type ApplyClient

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

func NewApplyClient

func NewApplyClient(ctx context.Context, kubeClient kubernetes.Interface, customClient clientSet.Interface, threadiness int, stopCh <-chan struct{}) (*ApplyClient, error)

func (*ApplyClient) CreateApply

func (c *ApplyClient) CreateApply(tpl *v1alpha1.Apply) (*v1alpha1.Apply, error)

func (*ApplyClient) DeleteApply

func (c *ApplyClient) DeleteApply(ns, name string) error

func (*ApplyClient) GetApply

func (c *ApplyClient) GetApply(ns, name string) (*v1alpha1.Apply, error)

func (*ApplyClient) ListApplies

func (c *ApplyClient) ListApplies(ns string, selector labels.Selector) ([]*v1alpha1.Apply, error)

func (*ApplyClient) Run

func (c *ApplyClient) Run() error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items. 启动controller

func (*ApplyClient) Start

func (c *ApplyClient) Start()

func (*ApplyClient) UpdateApply

func (c *ApplyClient) UpdateApply(tpl *v1alpha1.Apply) (*v1alpha1.Apply, error)

type Client

type Client interface {
	Run()
	Cluster
	Apply
	Template
	io.Closer
}

func NewController

func NewController(ctx context.Context, path string) (Client, error)

type Cluster

type Cluster interface {
	CreateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	GetCluster(ns, name string) (*v1alpha1.Cluster, error)
	UpdateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	DeleteCluster(ns, name string) error
	ListClusters(ns string, selector labels.Selector) ([]*v1alpha1.Cluster, error)
}

type ClusterClient

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

func NewClusterClient

func NewClusterClient(ctx context.Context, kubeClient kubernetes.Interface, customClient clientSet.Interface, threadiness int, stopCh <-chan struct{}) (*ClusterClient, error)

func (*ClusterClient) CreateCluster

func (c *ClusterClient) CreateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)

func (*ClusterClient) DeleteCluster

func (c *ClusterClient) DeleteCluster(ns, name string) error

func (*ClusterClient) GetCluster

func (c *ClusterClient) GetCluster(ns, name string) (*v1alpha1.Cluster, error)

func (*ClusterClient) ListClusters

func (c *ClusterClient) ListClusters(ns string, selector labels.Selector) ([]*v1alpha1.Cluster, error)

func (*ClusterClient) Run

func (c *ClusterClient) Run() error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items. 启动controller

func (*ClusterClient) Start

func (c *ClusterClient) Start()

func (*ClusterClient) UpdateCluster

func (c *ClusterClient) UpdateCluster(clt *v1alpha1.Cluster) (*v1alpha1.Cluster, error)

type Config

type Config struct {
	Kube struct {
		OutCluster bool   `yaml:"outCluster" json:"outCluster"`
		ConfigPath string `yaml:"configPath" json:"configPath" default:"kubeconfig.yaml"`
	} `yaml:"kube" json:"kube"`
}

type Controller

type Controller interface {
	Start()
	Run() error
}

type Template

type Template interface {
	CreateTemplate(clt *v1alpha1.Template) (*v1alpha1.Template, error)
	GetTemplate(ns, name string) (*v1alpha1.Template, error)
	UpdateTemplate(clt *v1alpha1.Template) (*v1alpha1.Template, error)
	DeleteTemplate(ns, name string) error
	ListTemplates(ns string, selector labels.Selector) ([]*v1alpha1.Template, error)
}

type TemplateClient

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

func NewTemplateClient

func NewTemplateClient(ctx context.Context, kubeClient kubernetes.Interface, customClient clientSet.Interface, threadiness int, stopCh <-chan struct{}) (*TemplateClient, error)

func (*TemplateClient) CreateTemplate

func (c *TemplateClient) CreateTemplate(tpl *v1alpha1.Template) (*v1alpha1.Template, error)

func (*TemplateClient) DeleteTemplate

func (c *TemplateClient) DeleteTemplate(ns, name string) error

func (*TemplateClient) GetTemplate

func (c *TemplateClient) GetTemplate(ns, name string) (*v1alpha1.Template, error)

func (*TemplateClient) ListTemplates

func (c *TemplateClient) ListTemplates(ns string, selector labels.Selector) ([]*v1alpha1.Template, error)

func (*TemplateClient) Run

func (c *TemplateClient) Run() error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items. 启动controller

func (*TemplateClient) Start

func (c *TemplateClient) Start()

func (*TemplateClient) UpdateTemplate

func (c *TemplateClient) UpdateTemplate(tpl *v1alpha1.Template) (*v1alpha1.Template, error)