rancher/norman
1
0
Fork 0
mirror of https://github.com/rancher/norman.git synced 2025-09-16 07:09:44 +00:00
Code Issues Releases Wiki Activity

Add more debug logging

Browse Source
This commit is contained in:
Darren Shepherd
2018-04-04 03:07:07 -07:00
parent 50ffce9804
commit 4d46cbab5b
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
objectclient/object_client.go
View File

@@ -103,6 +103,7 @@ func (p *ObjectClient) Create(o runtime.Object) (runtime.Object, error) {
} }
} }
result := p.Factory.Object() result := p.Factory.Object()
logrus.Debugf("REST CREATE %s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, ns, p.resource.Name)
err := p.restClient.Post(). err := p.restClient.Post().
Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version). Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version).
NamespaceIfScoped(ns, p.resource.Namespaced). NamespaceIfScoped(ns, p.resource.Namespaced).
@@ -126,6 +127,7 @@ func (p *ObjectClient) GetNamespaced(namespace, name string, opts metav1.GetOpti
Name(name). Name(name).
Do(). Do().
Into(result) Into(result)
logrus.Debugf("REST GET %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, namespace, p.resource.Name, name)
return result, err return result, err
} }
@@ -140,6 +142,7 @@ func (p *ObjectClient) Get(name string, opts metav1.GetOptions) (runtime.Object,
Name(name). Name(name).
Do(). Do().
Into(result) Into(result)
logrus.Debugf("REST GET %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, p.ns, p.resource.Name, name)
return result, err return result, err
} }
@@ -152,7 +155,7 @@ func (p *ObjectClient) Update(name string, o runtime.Object) (runtime.Object, er
if len(name) == 0 { if len(name) == 0 {
return result, errors.New("object missing name") return result, errors.New("object missing name")
} }
logrus.Debugf("UPDATE %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, ns, p.resource.Name, name) logrus.Debugf("REST UPDATE %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, ns, p.resource.Name, name)
err := p.restClient.Put(). err := p.restClient.Put().
Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version). Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version).
NamespaceIfScoped(ns, p.resource.Namespaced). NamespaceIfScoped(ns, p.resource.Namespaced).
@@ -170,6 +173,7 @@ func (p *ObjectClient) DeleteNamespaced(namespace, name string, opts *metav1.Del
if namespace != "" { if namespace != "" {
req = req.Namespace(namespace) req = req.Namespace(namespace)
} }
logrus.Debugf("REST DELETE %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, namespace, p.resource.Name, name)
return req.Resource(p.resource.Name). return req.Resource(p.resource.Name).
Name(name). Name(name).
Body(opts). Body(opts).
@@ -178,6 +182,7 @@ func (p *ObjectClient) DeleteNamespaced(namespace, name string, opts *metav1.Del
} }
func (p *ObjectClient) Delete(name string, opts *metav1.DeleteOptions) error { func (p *ObjectClient) Delete(name string, opts *metav1.DeleteOptions) error {
logrus.Debugf("REST DELETE %s/%s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, p.ns, p.resource.Name, name)
return p.restClient.Delete(). return p.restClient.Delete().
Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version). Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version).
NamespaceIfScoped(p.ns, p.resource.Namespaced). NamespaceIfScoped(p.ns, p.resource.Namespaced).
@@ -190,6 +195,7 @@ func (p *ObjectClient) Delete(name string, opts *metav1.DeleteOptions) error {
func (p *ObjectClient) List(opts metav1.ListOptions) (runtime.Object, error) { func (p *ObjectClient) List(opts metav1.ListOptions) (runtime.Object, error) {
result := p.Factory.List() result := p.Factory.List()
logrus.Debugf("REST LIST %s/%s/%s/%s/%s", p.getAPIPrefix(), p.gvk.Group, p.gvk.Version, p.ns, p.resource.Name)
return result, p.restClient.Get(). return result, p.restClient.Get().
Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version). Prefix(p.getAPIPrefix(), p.gvk.Group, p.gvk.Version).
NamespaceIfScoped(p.ns, p.resource.Namespaced). NamespaceIfScoped(p.ns, p.resource.Namespaced).

4
store/proxy/proxy_store.go
View File

@@ -117,7 +117,7 @@ func (p *Store) getUser(apiContext *types.APIContext) string {
func (p *Store) doAuthed(apiContext *types.APIContext, request *rest.Request) rest.Result { func (p *Store) doAuthed(apiContext *types.APIContext, request *rest.Request) rest.Result {
start := time.Now() start := time.Now()
defer func() { defer func() {
logrus.Debug("GET:", time.Now().Sub(start), p.resourcePlural) logrus.Debug("GET: ", time.Now().Sub(start), p.resourcePlural)
}() }()
for _, header := range authHeaders { for _, header := range authHeaders {
@@ -166,7 +166,7 @@ func (p *Store) List(apiContext *types.APIContext, schema *types.Schema, opt *ty
resultList := &unstructured.UnstructuredList{} resultList := &unstructured.UnstructuredList{}
start := time.Now() start := time.Now()
err = req.Do().Into(resultList) err = req.Do().Into(resultList)
logrus.Debug("LIST:", time.Now().Sub(start), p.resourcePlural) logrus.Debug("LIST: ", time.Now().Sub(start), p.resourcePlural)
if err != nil { if err != nil {
return nil, err return nil, err
} }