k8s

Documentation

Index

• func NewStore(client kube_client.Client, namespace string) (config_store.ConfigStore, error)
• type KubernetesMetaAdapter
  • func (m *KubernetesMetaAdapter) GetCreationTime() time.Time
  • func (m *KubernetesMetaAdapter) GetMesh() string
  • func (m *KubernetesMetaAdapter) GetModificationTime() time.Time
  • func (m *KubernetesMetaAdapter) GetNameExtensions() core_model.ResourceNameExtensions
  • func (m *KubernetesMetaAdapter) GetVersion() string
• type KubernetesStore
  • func (s *KubernetesStore) Create(ctx context.Context, r *config_model.ConfigResource, ...) error
  • func (s *KubernetesStore) Delete(ctx context.Context, r *config_model.ConfigResource, ...) error
  • func (s *KubernetesStore) Get(ctx context.Context, r *config_model.ConfigResource, ...) error
  • func (s *KubernetesStore) List(ctx context.Context, rs *config_model.ConfigResourceList, ...) error
  • func (s *KubernetesStore) Update(ctx context.Context, r *config_model.ConfigResource, ...) error

Functions

func NewStore

func NewStore(client kube_client.Client, namespace string) (config_store.ConfigStore, error)

Types

type KubernetesMetaAdapter

type KubernetesMetaAdapter struct {
	kube_meta.ObjectMeta
}

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) GetNameExtensions

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

func (*KubernetesMetaAdapter) GetVersion

func (m *KubernetesMetaAdapter) GetVersion() string

type KubernetesStore

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

func (*KubernetesStore) Create

func (s *KubernetesStore) Create(ctx context.Context, r *config_model.ConfigResource, fs ...core_store.CreateOptionsFunc) error

func (*KubernetesStore) Delete

func (s *KubernetesStore) Delete(ctx context.Context, r *config_model.ConfigResource, fs ...core_store.DeleteOptionsFunc) error

func (*KubernetesStore) Get

func (s *KubernetesStore) Get(ctx context.Context, r *config_model.ConfigResource, fs ...core_store.GetOptionsFunc) error

func (*KubernetesStore) List

func (s *KubernetesStore) List(ctx context.Context, rs *config_model.ConfigResourceList, fs ...core_store.ListOptionsFunc) error

func (*KubernetesStore) Update

func (s *KubernetesStore) Update(ctx context.Context, r *config_model.ConfigResource, fs ...core_store.UpdateOptionsFunc) error