kubernetes

package
v0.10.20 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 18, 2019 License: Apache-2.0 Imports: 16 Imported by: 22

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ConfigMapGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "ConfigMap",
	}
)
View Source 
var (
	CustomResourceDefinitionGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "CustomResourceDefinition",
	}
)
View Source 
var (
	DeploymentGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "Deployment",
	}
)
View Source 
var (
	KubeNamespaceGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "KubeNamespace",
	}
)
View Source 
var (
	PodGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "Pod",
	}
)
View Source 
var (
	ServiceGVK = schema.GroupVersionKind{
		Version: "kubernetes",
		Group:   "kubernetes.solo.io",
		Kind:    "Service",
	}
)

Functions

This section is empty.

Types

type CloneableConfigMap 

type CloneableConfigMap interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_configmap.ConfigMap
}

type CloneableCustomResourceDefinition 

type CloneableCustomResourceDefinition interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_customresourcedefinition.CustomResourceDefinition
}

type CloneableDeployment 

type CloneableDeployment interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_deployment.Deployment
}

type CloneableKubeNamespace 

type CloneableKubeNamespace interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_namespace.KubeNamespace
}

type CloneablePod 

type CloneablePod interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_pod.Pod
}

type CloneableService 

type CloneableService interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_external_kubernetes_service.Service
}

type ConfigMap 

type ConfigMap struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_configmap.ConfigMap
}

func NewConfigMap 

func NewConfigMap(namespace, name string) *ConfigMap

func (*ConfigMap) Clone 

func (r *ConfigMap) Clone() resources.Resource

func (*ConfigMap) GroupVersionKind added in v0.10.4 

func (r *ConfigMap) GroupVersionKind() schema.GroupVersionKind

func (*ConfigMap) Hash 

func (r *ConfigMap) Hash() uint64

type ConfigMapClient 

type ConfigMapClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*ConfigMap, error)
	Write(resource *ConfigMap, opts clients.WriteOpts) (*ConfigMap, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (ConfigMapList, error)
	ConfigMapWatcher
}

func NewConfigMapClient 

func NewConfigMapClient(rcFactory factory.ResourceClientFactory) (ConfigMapClient, error)

func NewConfigMapClientWithBase 

func NewConfigMapClientWithBase(rc clients.ResourceClient) ConfigMapClient

func NewConfigMapClientWithToken 

func NewConfigMapClientWithToken(rcFactory factory.ResourceClientFactory, token string) (ConfigMapClient, error)

type ConfigMapList 

type ConfigMapList []*ConfigMap

func (ConfigMapList) AsInterfaces 

func (list ConfigMapList) AsInterfaces() []interface{}

func (ConfigMapList) AsResources 

func (list ConfigMapList) AsResources() resources.ResourceList

func (ConfigMapList) Clone 

func (list ConfigMapList) Clone() ConfigMapList

func (ConfigMapList) Each 

func (list ConfigMapList) Each(f func(element *ConfigMap))

func (ConfigMapList) EachResource 

func (list ConfigMapList) EachResource(f func(element resources.Resource))

func (ConfigMapList) Find 

func (list ConfigMapList) Find(namespace, name string) (*ConfigMap, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (ConfigMapList) Names 

func (list ConfigMapList) Names() []string

func (ConfigMapList) NamespacesDotNames 

func (list ConfigMapList) NamespacesDotNames() []string

func (ConfigMapList) Sort 

func (list ConfigMapList) Sort() ConfigMapList

type ConfigMapReconciler 

type ConfigMapReconciler interface {
	Reconcile(namespace string, desiredResources ConfigMapList, transition TransitionConfigMapFunc, opts clients.ListOpts) error
}

func NewConfigMapReconciler 

func NewConfigMapReconciler(client ConfigMapClient) ConfigMapReconciler

type ConfigMapWatcher 

type ConfigMapWatcher interface {
	// watch namespace-scoped configmaps
	Watch(namespace string, opts clients.WatchOpts) (<-chan ConfigMapList, <-chan error, error)
}

type CustomResourceDefinition 

type CustomResourceDefinition struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_customresourcedefinition.CustomResourceDefinition
}

func NewCustomResourceDefinition 

func NewCustomResourceDefinition(namespace, name string) *CustomResourceDefinition

func (*CustomResourceDefinition) Clone 

func (r *CustomResourceDefinition) Clone() resources.Resource

func (*CustomResourceDefinition) GroupVersionKind added in v0.10.4 

func (r *CustomResourceDefinition) GroupVersionKind() schema.GroupVersionKind

func (*CustomResourceDefinition) Hash 

func (r *CustomResourceDefinition) Hash() uint64

type CustomResourceDefinitionClient 

type CustomResourceDefinitionClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*CustomResourceDefinition, error)
	Write(resource *CustomResourceDefinition, opts clients.WriteOpts) (*CustomResourceDefinition, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (CustomResourceDefinitionList, error)
	CustomResourceDefinitionWatcher
}

func NewCustomResourceDefinitionClient 

func NewCustomResourceDefinitionClient(rcFactory factory.ResourceClientFactory) (CustomResourceDefinitionClient, error)

func NewCustomResourceDefinitionClientWithBase 

func NewCustomResourceDefinitionClientWithBase(rc clients.ResourceClient) CustomResourceDefinitionClient

func NewCustomResourceDefinitionClientWithToken 

func NewCustomResourceDefinitionClientWithToken(rcFactory factory.ResourceClientFactory, token string) (CustomResourceDefinitionClient, error)

type CustomResourceDefinitionList 

type CustomResourceDefinitionList []*CustomResourceDefinition

func (CustomResourceDefinitionList) AsInterfaces 

func (list CustomResourceDefinitionList) AsInterfaces() []interface{}

func (CustomResourceDefinitionList) AsResources 

func (list CustomResourceDefinitionList) AsResources() resources.ResourceList

func (CustomResourceDefinitionList) Clone 

func (list CustomResourceDefinitionList) Clone() CustomResourceDefinitionList

func (CustomResourceDefinitionList) Each 

func (list CustomResourceDefinitionList) Each(f func(element *CustomResourceDefinition))

func (CustomResourceDefinitionList) EachResource 

func (list CustomResourceDefinitionList) EachResource(f func(element resources.Resource))

func (CustomResourceDefinitionList) Find 

func (list CustomResourceDefinitionList) Find(namespace, name string) (*CustomResourceDefinition, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (CustomResourceDefinitionList) Names 

func (list CustomResourceDefinitionList) Names() []string

func (CustomResourceDefinitionList) NamespacesDotNames 

func (list CustomResourceDefinitionList) NamespacesDotNames() []string

func (CustomResourceDefinitionList) Sort 

func (list CustomResourceDefinitionList) Sort() CustomResourceDefinitionList

type CustomResourceDefinitionReconciler 

type CustomResourceDefinitionReconciler interface {
	Reconcile(namespace string, desiredResources CustomResourceDefinitionList, transition TransitionCustomResourceDefinitionFunc, opts clients.ListOpts) error
}

func NewCustomResourceDefinitionReconciler 

func NewCustomResourceDefinitionReconciler(client CustomResourceDefinitionClient) CustomResourceDefinitionReconciler

type CustomResourceDefinitionWatcher 

type CustomResourceDefinitionWatcher interface {
	// watch namespace-scoped customresourcedefinition
	Watch(namespace string, opts clients.WatchOpts) (<-chan CustomResourceDefinitionList, <-chan error, error)
}

type Deployment 

type Deployment struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_deployment.Deployment
}

func NewDeployment 

func NewDeployment(namespace, name string) *Deployment

func (*Deployment) Clone 

func (r *Deployment) Clone() resources.Resource

func (*Deployment) GroupVersionKind added in v0.10.4 

func (r *Deployment) GroupVersionKind() schema.GroupVersionKind

func (*Deployment) Hash 

func (r *Deployment) Hash() uint64

type DeploymentClient 

type DeploymentClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*Deployment, error)
	Write(resource *Deployment, opts clients.WriteOpts) (*Deployment, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (DeploymentList, error)
	DeploymentWatcher
}

func NewDeploymentClient 

func NewDeploymentClient(rcFactory factory.ResourceClientFactory) (DeploymentClient, error)

func NewDeploymentClientWithBase 

func NewDeploymentClientWithBase(rc clients.ResourceClient) DeploymentClient

func NewDeploymentClientWithToken 

func NewDeploymentClientWithToken(rcFactory factory.ResourceClientFactory, token string) (DeploymentClient, error)

type DeploymentList 

type DeploymentList []*Deployment

func (DeploymentList) AsInterfaces 

func (list DeploymentList) AsInterfaces() []interface{}

func (DeploymentList) AsResources 

func (list DeploymentList) AsResources() resources.ResourceList

func (DeploymentList) Clone 

func (list DeploymentList) Clone() DeploymentList

func (DeploymentList) Each 

func (list DeploymentList) Each(f func(element *Deployment))

func (DeploymentList) EachResource 

func (list DeploymentList) EachResource(f func(element resources.Resource))

func (DeploymentList) Find 

func (list DeploymentList) Find(namespace, name string) (*Deployment, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (DeploymentList) Names 

func (list DeploymentList) Names() []string

func (DeploymentList) NamespacesDotNames 

func (list DeploymentList) NamespacesDotNames() []string

func (DeploymentList) Sort 

func (list DeploymentList) Sort() DeploymentList

type DeploymentReconciler 

type DeploymentReconciler interface {
	Reconcile(namespace string, desiredResources DeploymentList, transition TransitionDeploymentFunc, opts clients.ListOpts) error
}

func NewDeploymentReconciler 

func NewDeploymentReconciler(client DeploymentClient) DeploymentReconciler

type DeploymentWatcher 

type DeploymentWatcher interface {
	// watch namespace-scoped deployments
	Watch(namespace string, opts clients.WatchOpts) (<-chan DeploymentList, <-chan error, error)
}

type KubeNamespace 

type KubeNamespace struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_namespace.KubeNamespace
}

func NewKubeNamespace 

func NewKubeNamespace(namespace, name string) *KubeNamespace

func (*KubeNamespace) Clone 

func (r *KubeNamespace) Clone() resources.Resource

func (*KubeNamespace) GroupVersionKind added in v0.10.4 

func (r *KubeNamespace) GroupVersionKind() schema.GroupVersionKind

func (*KubeNamespace) Hash 

func (r *KubeNamespace) Hash() uint64

type KubeNamespaceClient 

type KubeNamespaceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*KubeNamespace, error)
	Write(resource *KubeNamespace, opts clients.WriteOpts) (*KubeNamespace, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (KubeNamespaceList, error)
	KubeNamespaceWatcher
}

func NewKubeNamespaceClient 

func NewKubeNamespaceClient(rcFactory factory.ResourceClientFactory) (KubeNamespaceClient, error)

func NewKubeNamespaceClientWithBase 

func NewKubeNamespaceClientWithBase(rc clients.ResourceClient) KubeNamespaceClient

func NewKubeNamespaceClientWithToken 

func NewKubeNamespaceClientWithToken(rcFactory factory.ResourceClientFactory, token string) (KubeNamespaceClient, error)

type KubeNamespaceList 

type KubeNamespaceList []*KubeNamespace

func (KubeNamespaceList) AsInterfaces 

func (list KubeNamespaceList) AsInterfaces() []interface{}

func (KubeNamespaceList) AsResources 

func (list KubeNamespaceList) AsResources() resources.ResourceList

func (KubeNamespaceList) Clone 

func (list KubeNamespaceList) Clone() KubeNamespaceList

func (KubeNamespaceList) Each 

func (list KubeNamespaceList) Each(f func(element *KubeNamespace))

func (KubeNamespaceList) EachResource 

func (list KubeNamespaceList) EachResource(f func(element resources.Resource))

func (KubeNamespaceList) Find 

func (list KubeNamespaceList) Find(namespace, name string) (*KubeNamespace, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (KubeNamespaceList) Names 

func (list KubeNamespaceList) Names() []string

func (KubeNamespaceList) NamespacesDotNames 

func (list KubeNamespaceList) NamespacesDotNames() []string

func (KubeNamespaceList) Sort 

func (list KubeNamespaceList) Sort() KubeNamespaceList

type KubeNamespaceReconciler 

type KubeNamespaceReconciler interface {
	Reconcile(namespace string, desiredResources KubeNamespaceList, transition TransitionKubeNamespaceFunc, opts clients.ListOpts) error
}

func NewKubeNamespaceReconciler 

func NewKubeNamespaceReconciler(client KubeNamespaceClient) KubeNamespaceReconciler

type KubeNamespaceWatcher 

type KubeNamespaceWatcher interface {
	// watch namespace-scoped kubenamespaces
	Watch(namespace string, opts clients.WatchOpts) (<-chan KubeNamespaceList, <-chan error, error)
}

type Pod 

type Pod struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_pod.Pod
}

func NewPod 

func NewPod(namespace, name string) *Pod

func (*Pod) Clone 

func (r *Pod) Clone() resources.Resource

func (*Pod) GroupVersionKind added in v0.10.4 

func (r *Pod) GroupVersionKind() schema.GroupVersionKind

func (*Pod) Hash 

func (r *Pod) Hash() uint64

type PodClient 

type PodClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*Pod, error)
	Write(resource *Pod, opts clients.WriteOpts) (*Pod, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (PodList, error)
	PodWatcher
}

func NewPodClient 

func NewPodClient(rcFactory factory.ResourceClientFactory) (PodClient, error)

func NewPodClientWithBase 

func NewPodClientWithBase(rc clients.ResourceClient) PodClient

func NewPodClientWithToken 

func NewPodClientWithToken(rcFactory factory.ResourceClientFactory, token string) (PodClient, error)

type PodList 

type PodList []*Pod

func (PodList) AsInterfaces 

func (list PodList) AsInterfaces() []interface{}

func (PodList) AsResources 

func (list PodList) AsResources() resources.ResourceList

func (PodList) Clone 

func (list PodList) Clone() PodList

func (PodList) Each 

func (list PodList) Each(f func(element *Pod))

func (PodList) EachResource 

func (list PodList) EachResource(f func(element resources.Resource))

func (PodList) Find 

func (list PodList) Find(namespace, name string) (*Pod, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (PodList) Names 

func (list PodList) Names() []string

func (PodList) NamespacesDotNames 

func (list PodList) NamespacesDotNames() []string

func (PodList) Sort 

func (list PodList) Sort() PodList

type PodReconciler 

type PodReconciler interface {
	Reconcile(namespace string, desiredResources PodList, transition TransitionPodFunc, opts clients.ListOpts) error
}

func NewPodReconciler 

func NewPodReconciler(client PodClient) PodReconciler

type PodWatcher 

type PodWatcher interface {
	// watch namespace-scoped pods
	Watch(namespace string, opts clients.WatchOpts) (<-chan PodList, <-chan error, error)
}

type Service 

type Service struct {
	github_com_solo_io_solo_kit_api_external_kubernetes_service.Service
}

func NewService 

func NewService(namespace, name string) *Service

func (*Service) Clone 

func (r *Service) Clone() resources.Resource

func (*Service) GroupVersionKind added in v0.10.4 

func (r *Service) GroupVersionKind() schema.GroupVersionKind

func (*Service) Hash 

func (r *Service) Hash() uint64

type ServiceClient 

type ServiceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*Service, error)
	Write(resource *Service, opts clients.WriteOpts) (*Service, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (ServiceList, error)
	ServiceWatcher
}

func NewServiceClient 

func NewServiceClient(rcFactory factory.ResourceClientFactory) (ServiceClient, error)

func NewServiceClientWithBase 

func NewServiceClientWithBase(rc clients.ResourceClient) ServiceClient

func NewServiceClientWithToken 

func NewServiceClientWithToken(rcFactory factory.ResourceClientFactory, token string) (ServiceClient, error)

type ServiceList 

type ServiceList []*Service

func (ServiceList) AsInterfaces 

func (list ServiceList) AsInterfaces() []interface{}

func (ServiceList) AsResources 

func (list ServiceList) AsResources() resources.ResourceList

func (ServiceList) Clone 

func (list ServiceList) Clone() ServiceList

func (ServiceList) Each 

func (list ServiceList) Each(f func(element *Service))

func (ServiceList) EachResource 

func (list ServiceList) EachResource(f func(element resources.Resource))

func (ServiceList) Find 

func (list ServiceList) Find(namespace, name string) (*Service, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (ServiceList) Names 

func (list ServiceList) Names() []string

func (ServiceList) NamespacesDotNames 

func (list ServiceList) NamespacesDotNames() []string

func (ServiceList) Sort 

func (list ServiceList) Sort() ServiceList

type ServiceReconciler 

type ServiceReconciler interface {
	Reconcile(namespace string, desiredResources ServiceList, transition TransitionServiceFunc, opts clients.ListOpts) error
}

func NewServiceReconciler 

func NewServiceReconciler(client ServiceClient) ServiceReconciler

type ServiceWatcher 

type ServiceWatcher interface {
	// watch namespace-scoped services
	Watch(namespace string, opts clients.WatchOpts) (<-chan ServiceList, <-chan error, error)
}

type TransitionConfigMapFunc 

type TransitionConfigMapFunc func(original, desired *ConfigMap) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionCustomResourceDefinitionFunc 

type TransitionCustomResourceDefinitionFunc func(original, desired *CustomResourceDefinition) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionDeploymentFunc 

type TransitionDeploymentFunc func(original, desired *Deployment) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionKubeNamespaceFunc 

type TransitionKubeNamespaceFunc func(original, desired *KubeNamespace) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionPodFunc 

type TransitionPodFunc func(original, desired *Pod) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionServiceFunc 

type TransitionServiceFunc func(original, desired *Service) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.