istio: Index | Files

package crd

import ""

Package crd provides the store interface to config resources stored as kubernetes custom resource definitions (CRDs).


Package Files

init.go store.go


const (

    // ConfigAPIGroup is the API group for the config CRDs.
    ConfigAPIGroup = ""
    // ConfigAPIVersion is the API version for the config CRDs.
    ConfigAPIVersion = "v1alpha2"

func NewStore Uses

func NewStore(u *url.URL, gv *schema.GroupVersion, _ *creds.Options, ck []string) (store.Backend, error)

NewStore creates a new Store instance.

func Register Uses

func Register(builders map[string]store.Builder)

Register registers this module as a StoreBackend. Do not use 'init()' for automatic registration; linker will drop the whole module because it looks unused.

func ToBackEndResource Uses

func ToBackEndResource(uns *unstructured.Unstructured) *store.BackEndResource

ToBackEndResource converts an unstructured k8s resource into a mixer backend resource.

type Store Uses

type Store struct {
    // contains filtered or unexported fields

Store offers store.StoreBackend interface through kubernetes custom resource definitions.

func (*Store) Get Uses

func (s *Store) Get(key store.Key) (*store.BackEndResource, error)

Get implements store.Backend interface.

func (*Store) Init Uses

func (s *Store) Init(kinds []string) error

Init implements store.StoreBackend interface.

func (*Store) List Uses

func (s *Store) List() map[store.Key]*store.BackEndResource

List implements store.Backend interface.

func (*Store) OnAdd Uses

func (s *Store) OnAdd(obj interface{})

OnAdd implements cache.ResourceEventHandler interface.

func (*Store) OnDelete Uses

func (s *Store) OnDelete(obj interface{})

OnDelete implements cache.ResourceEventHandler interface.

func (*Store) OnUpdate Uses

func (s *Store) OnUpdate(oldObj, newObj interface{})

OnUpdate implements cache.ResourceEventHandler interface.

func (*Store) Stop Uses

func (s *Store) Stop()

Stop implements store.Backend interface.

func (*Store) WaitForSynced Uses

func (s *Store) WaitForSynced(timeout time.Duration) error

WaitForSynced implements store.WaitForSynced interface

func (*Store) Watch Uses

func (s *Store) Watch() (<-chan store.BackendEvent, error)

Watch implements store.Backend interface.

Package crd imports 20 packages (graph) and is imported by 6 packages. Updated 2019-11-14. Refresh now. Tools for package owners.