...
1
16
17 package rest
18
19 import (
20 "testing"
21
22 "k8s.io/apimachinery/pkg/api/errors"
23 genericapirequest "k8s.io/apiserver/pkg/endpoints/request"
24 "k8s.io/apiserver/pkg/registry/generic"
25 genericregistry "k8s.io/apiserver/pkg/registry/generic/registry"
26 api "k8s.io/kubernetes/pkg/apis/core"
27 "k8s.io/kubernetes/pkg/registry/registrytest"
28 )
29
30 func TestPodLogValidates(t *testing.T) {
31 config, server := registrytest.NewEtcdStorage(t, "")
32 defer server.Terminate(t)
33 s, destroyFunc, err := generic.NewRawStorage(config, nil, nil, "")
34 if err != nil {
35 t.Fatalf("Unexpected error: %v", err)
36 }
37 defer destroyFunc()
38 store := &genericregistry.Store{
39 Storage: genericregistry.DryRunnableStorage{Storage: s},
40 }
41 logRest := &LogREST{Store: store, KubeletConn: nil}
42
43 negativeOne := int64(-1)
44 testCases := []*api.PodLogOptions{
45 {SinceSeconds: &negativeOne},
46 {TailLines: &negativeOne},
47 }
48
49 for _, tc := range testCases {
50 _, err := logRest.Get(genericapirequest.NewDefaultContext(), "test", tc)
51 if !errors.IsInvalid(err) {
52 t.Fatalf("Unexpected error: %v", err)
53 }
54 }
55 }
56
View as plain text