diff --git a/pkg/releasetesting/environment_test.go b/pkg/releasetesting/environment_test.go index d9377b0f3..826dfbaf7 100644 --- a/pkg/releasetesting/environment_test.go +++ b/pkg/releasetesting/environment_test.go @@ -89,6 +89,14 @@ func TestDeleteTestPodsFailingDelete(t *testing.T) { } } +func TestGetTestPodLogs(t *testing.T) { + mockTestSuite := testSuiteFixture([]string{manifestWithTestSuccessHook}) + mockTestEnv := newMockTestingEnvironment() + mockTestEnv.KubeClient = newGetLogKubeClient() + + mockTestEnv.GetLogs(mockTestSuite.TestManifests) +} + func TestStreamMessage(t *testing.T) { mockTestEnv := newMockTestingEnvironment() @@ -181,3 +189,13 @@ func newCreateFailingKubeClient() *createFailingKubeClient { func (p *createFailingKubeClient) Create(ns string, r io.Reader, t int64, shouldWait bool) error { return errors.New("We ran out of budget and couldn't create finding-nemo") } + +type getLogKubeClient struct { + tillerEnv.PrintingKubeClient +} + +func newGetLogKubeClient() *getLogKubeClient { + return &getLogKubeClient{ + PrintingKubeClient: tillerEnv.PrintingKubeClient{Out: ioutil.Discard}, + } +} diff --git a/pkg/tiller/environment/environment_test.go b/pkg/tiller/environment/environment_test.go index 962ff4d93..f8f87b6aa 100644 --- a/pkg/tiller/environment/environment_test.go +++ b/pkg/tiller/environment/environment_test.go @@ -78,6 +78,10 @@ func (k *mockKubeClient) WaitAndGetCompletedPodStatus(namespace string, reader i return "", nil } +func (k *mockKubeClient) GetPodLogs(name, namespace string) (string, error) { + return "", nil +} + func (k *mockKubeClient) WaitUntilCRDEstablished(reader io.Reader, timeout time.Duration) error { return nil } diff --git a/pkg/tiller/release_server_test.go b/pkg/tiller/release_server_test.go index 227af6cfc..056fba646 100644 --- a/pkg/tiller/release_server_test.go +++ b/pkg/tiller/release_server_test.go @@ -679,6 +679,9 @@ func (kc *mockHooksKubeClient) Validate(ns string, reader io.Reader) error { func (kc *mockHooksKubeClient) WaitAndGetCompletedPodPhase(namespace string, reader io.Reader, timeout time.Duration) (v1.PodPhase, error) { return v1.PodUnknown, nil } +func (kc *mockHooksKubeClient) GetPodLogs(name, namespace string) (string, error) { + return "", nil +} func (kc *mockHooksKubeClient) WaitUntilCRDEstablished(reader io.Reader, timeout time.Duration) error { return nil