package etcd import ( kapi "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/fields" "k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/registry/generic" etcdgeneric "k8s.io/kubernetes/pkg/registry/generic/etcd" "k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/storage" "github.com/openshift/origin/pkg/user/api" "github.com/openshift/origin/pkg/user/registry/identity" "github.com/openshift/origin/pkg/util" ) // REST implements a RESTStorage for identites against etcd type REST struct { etcdgeneric.Etcd } const EtcdPrefix = "/useridentities" // NewREST returns a RESTStorage object that will work against identites func NewREST(s storage.Interface) *REST { store := &etcdgeneric.Etcd{ NewFunc: func() runtime.Object { return &api.Identity{} }, NewListFunc: func() runtime.Object { return &api.IdentityList{} }, KeyRootFunc: func(ctx kapi.Context) string { return EtcdPrefix }, KeyFunc: func(ctx kapi.Context, name string) (string, error) { return util.NoNamespaceKeyFunc(ctx, EtcdPrefix, name) }, ObjectNameFunc: func(obj runtime.Object) (string, error) { return obj.(*api.Identity).Name, nil }, PredicateFunc: func(label labels.Selector, field fields.Selector) generic.Matcher { return identity.MatchIdentity(label, field) }, EndpointName: "identities", Storage: s, } store.CreateStrategy = identity.Strategy store.UpdateStrategy = identity.Strategy return &REST{*store} }