k8s

package

v1.8.1 Latest Latest Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kumahq/kuma

Documentation ¶

Index ¶

func NewCachingConverter(expirationTime time.Duration) k8s_common.Converter
func NewSimpleConverter() k8s_common.Converter
func NewStore(client kube_client.Client, scheme *kube_runtime.Scheme, ...) (store.ResourceStore, error)
type KubeFactory
- func NewSimpleKubeFactory() KubeFactory
type KubernetesMetaAdapter
type KubernetesStore
type SimpleConverter
type SimpleKubeFactory
- func (f *SimpleKubeFactory) NewList(rl core_model.ResourceList) (k8s_model.KubernetesList, error)
- func (f *SimpleKubeFactory) NewObject(r core_model.Resource) (k8s_model.KubernetesObject, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewCachingConverter ¶

func NewCachingConverter(expirationTime time.Duration) k8s_common.Converter

func NewSimpleConverter ¶

func NewSimpleConverter() k8s_common.Converter

func NewStore ¶

func NewStore(client kube_client.Client, scheme *kube_runtime.Scheme, converter k8s_common.Converter) (store.ResourceStore, error)

Types ¶

type KubeFactory ¶

type KubeFactory interface {
	NewObject(r core_model.Resource) (k8s_model.KubernetesObject, error)
	NewList(rl core_model.ResourceList) (k8s_model.KubernetesList, error)
}

func NewSimpleKubeFactory ¶

func NewSimpleKubeFactory() KubeFactory

type KubernetesMetaAdapter ¶

type KubernetesMetaAdapter struct {
	kube_meta.ObjectMeta
	Mesh string
}

func (*KubernetesMetaAdapter) GetCreationTime ¶

func (m *KubernetesMetaAdapter) GetCreationTime() time.Time

func (*KubernetesMetaAdapter) GetMesh ¶

func (m *KubernetesMetaAdapter) GetMesh() string

func (*KubernetesMetaAdapter) GetModificationTime ¶

func (m *KubernetesMetaAdapter) GetModificationTime() time.Time

func (*KubernetesMetaAdapter) GetName ¶

func (m *KubernetesMetaAdapter) GetName() string

func (*KubernetesMetaAdapter) GetNameExtensions ¶

func (m *KubernetesMetaAdapter) GetNameExtensions() core_model.ResourceNameExtensions

func (*KubernetesMetaAdapter) GetVersion ¶

func (m *KubernetesMetaAdapter) GetVersion() string

type KubernetesStore ¶

type KubernetesStore struct {
	Client    kube_client.Client
	Converter k8s_common.Converter
	Scheme    *kube_runtime.Scheme
}

func (*KubernetesStore) Create ¶

func (s *KubernetesStore) Create(ctx context.Context, r core_model.Resource, fs ...store.CreateOptionsFunc) error

func (*KubernetesStore) Delete ¶

func (s *KubernetesStore) Delete(ctx context.Context, r core_model.Resource, fs ...store.DeleteOptionsFunc) error

func (*KubernetesStore) Get ¶

func (s *KubernetesStore) Get(ctx context.Context, r core_model.Resource, fs ...store.GetOptionsFunc) error

func (*KubernetesStore) List ¶

func (s *KubernetesStore) List(ctx context.Context, rs core_model.ResourceList, fs ...store.ListOptionsFunc) error

func (*KubernetesStore) Update ¶

func (s *KubernetesStore) Update(ctx context.Context, r core_model.Resource, fs ...store.UpdateOptionsFunc) error

type SimpleConverter ¶

type SimpleConverter struct {
	KubeFactory KubeFactory
}

func (*SimpleConverter) ToCoreList ¶

func (c *SimpleConverter) ToCoreList(in k8s_model.KubernetesList, out core_model.ResourceList, predicate k8s_common.ConverterPredicate) error

func (*SimpleConverter) ToCoreResource ¶

func (c *SimpleConverter) ToCoreResource(obj k8s_model.KubernetesObject, out core_model.Resource) error

func (*SimpleConverter) ToKubernetesList ¶

func (c *SimpleConverter) ToKubernetesList(rl core_model.ResourceList) (k8s_model.KubernetesList, error)

func (*SimpleConverter) ToKubernetesObject ¶

func (c *SimpleConverter) ToKubernetesObject(r core_model.Resource) (k8s_model.KubernetesObject, error)

type SimpleKubeFactory ¶

type SimpleKubeFactory struct {
	KubeTypes k8s_registry.TypeRegistry
}

func (*SimpleKubeFactory) NewList ¶

func (f *SimpleKubeFactory) NewList(rl core_model.ResourceList) (k8s_model.KubernetesList, error)

func (*SimpleKubeFactory) NewObject ¶

func (f *SimpleKubeFactory) NewObject(r core_model.Resource) (k8s_model.KubernetesObject, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
events
native module
api/v1alpha1 Package v1alpha1 contains API Schema definitions for the mesh v1alpha1 API group +groupName=kuma.io	Package v1alpha1 contains API Schema definitions for the mesh v1alpha1 API group +groupName=kuma.io
pkg/model
pkg/registry
test/api/sample/v1alpha1 Package v1alpha1 contains API Schema definitions for the mesh v1alpha1 API group +groupName=sample.test.kuma.io	Package v1alpha1 contains API Schema definitions for the mesh v1alpha1 API group +groupName=sample.test.kuma.io

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL