summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDaniel Nephin <dnephin@docker.com>2017-12-22 16:18:34 -0500
committerDaniel Nephin <dnephin@docker.com>2018-03-16 10:54:54 -0400
commitef01dea8935932486f03a37069720987e805dce6 (patch)
tree8ae307494ffa3f3fcd12392b3ec011f8e3fef26c
parent073963e3b770efbdf8bd4b4f92d46b2c62eaf434 (diff)
downloaddocker-ef01dea8935932486f03a37069720987e805dce6.tar.gz
Cleanup some assertions
Signed-off-by: Daniel Nephin <dnephin@docker.com>
-rw-r--r--daemon/logger/awslogs/cloudwatchlogs.go2
-rw-r--r--daemon/logger/awslogs/cloudwatchlogs_test.go8
-rw-r--r--pkg/term/proxy_test.go13
3 files changed, 8 insertions, 15 deletions
diff --git a/daemon/logger/awslogs/cloudwatchlogs.go b/daemon/logger/awslogs/cloudwatchlogs.go
index 835379b3b4..d6312b660a 100644
--- a/daemon/logger/awslogs/cloudwatchlogs.go
+++ b/daemon/logger/awslogs/cloudwatchlogs.go
@@ -69,6 +69,8 @@ type logStream struct {
sequenceToken *string
}
+var _ logger.SizedLogger = &logStream{}
+
type api interface {
CreateLogGroup(*cloudwatchlogs.CreateLogGroupInput) (*cloudwatchlogs.CreateLogGroupOutput, error)
CreateLogStream(*cloudwatchlogs.CreateLogStreamInput) (*cloudwatchlogs.CreateLogStreamOutput, error)
diff --git a/daemon/logger/awslogs/cloudwatchlogs_test.go b/daemon/logger/awslogs/cloudwatchlogs_test.go
index 080157b2ea..99d0f907f8 100644
--- a/daemon/logger/awslogs/cloudwatchlogs_test.go
+++ b/daemon/logger/awslogs/cloudwatchlogs_test.go
@@ -1143,11 +1143,6 @@ func TestCreateTagSuccess(t *testing.T) {
}
}
-func TestIsSizedLogger(t *testing.T) {
- awslogs := &logStream{}
- assert.Implements(t, (*logger.SizedLogger)(nil), awslogs, "awslogs should implement SizedLogger")
-}
-
func BenchmarkUnwrapEvents(b *testing.B) {
events := make([]wrappedEvent, maximumLogEventsPerPut)
for i := 0; i < maximumLogEventsPerPut; i++ {
@@ -1157,11 +1152,10 @@ func BenchmarkUnwrapEvents(b *testing.B) {
}
}
- as := assert.New(b)
b.ResetTimer()
for i := 0; i < b.N; i++ {
res := unwrapEvents(events)
- as.Len(res, maximumLogEventsPerPut)
+ assert.Len(b, res, maximumLogEventsPerPut)
}
}
diff --git a/pkg/term/proxy_test.go b/pkg/term/proxy_test.go
index ff40c1beff..01be1d55be 100644
--- a/pkg/term/proxy_test.go
+++ b/pkg/term/proxy_test.go
@@ -3,9 +3,9 @@ package term // import "github.com/docker/docker/pkg/term"
import (
"bytes"
"fmt"
- "reflect"
"testing"
+ "github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
)
@@ -25,7 +25,8 @@ func TestEscapeProxyRead(t *testing.T) {
nr, err = reader.Read(buf)
require.Error(t, err, "Should throw error when no keys are to read")
require.EqualValues(t, nr, 0, "nr should be zero")
- require.Condition(t, func() (success bool) { return len(keys) == 0 && len(buf) == 0 }, "keys & the read buffer size should be zero")
+ assert.Len(t, keys, 0)
+ assert.Len(t, buf, 0)
escapeKeys, _ = ToBytes("ctrl-x,ctrl-@")
keys, _ = ToBytes("DEL")
@@ -41,9 +42,7 @@ func TestEscapeProxyRead(t *testing.T) {
reader = NewEscapeProxy(bytes.NewReader(keys), escapeKeys)
buf = make([]byte, len(keys))
nr, err = reader.Read(buf)
- require.Condition(t, func() (success bool) {
- return reflect.TypeOf(err).Name() == "EscapeError"
- }, err)
+ require.EqualError(t, err, "read escape sequence")
require.EqualValues(t, nr, 0, "nr should be equal to 0")
require.Equal(t, keys, buf, "keys & the read buffer should be equal")
@@ -56,9 +55,7 @@ func TestEscapeProxyRead(t *testing.T) {
require.EqualValues(t, nr, 0, "nr should be equal to 0")
require.Equal(t, keys[0:1], buf, "keys & the read buffer should be equal")
nr, err = reader.Read(buf)
- require.Condition(t, func() (success bool) {
- return reflect.TypeOf(err).Name() == "EscapeError"
- }, err)
+ require.EqualError(t, err, "read escape sequence")
require.EqualValues(t, nr, 0, "nr should be equal to 0")
require.Equal(t, keys[1:], buf, "keys & the read buffer should be equal")