YQ Connector: prepare code base for S3 integration

1. Кодовая база Коннектора переписана с помощью Go дженериков так, чтобы добавление нового источника данных (в частности S3 + csv) максимально переиспользовало имеющийся код (чтобы сохранялась логика нарезания на блоки данных, учёт трафика и пр.)
2. API Connector расширено для работы с S3, но ещё пока не протестировано.

1 files changed, 32 insertions, 0 deletions

diff --git a/vendor/github.com/aws/aws-sdk-go-v2/internal/sdk/time_test.go b/vendor/github.com/aws/aws-sdk-go-v2/internal/sdk/time_test.go
new file mode 100644
index 0000000000..aabcd55918
--- /dev/null
+++ b/vendor/github.com/aws/aws-sdk-go-v2/internal/sdk/time_test.go
@@ -0,0 +1,32 @@
+package sdk
+
+import (
+	"context"
+	"strings"
+	"testing"
+	"time"
+)
+
+func TestSleepWithContext(t *testing.T) {
+	ctx, cancelFn := context.WithCancel(context.Background())
+	defer cancelFn()
+
+	err := sleepWithContext(ctx, 1*time.Millisecond)
+	if err != nil {
+		t.Errorf("expect context to not be canceled, got %v", err)
+	}
+}
+
+func TestSleepWithContext_Canceled(t *testing.T) {
+	ctx, cancelFn := context.WithCancel(context.Background())
+	cancelFn()
+
+	err := sleepWithContext(ctx, 10*time.Second)
+	if err == nil {
+		t.Fatalf("expect error, did not get one")
+	}
+
+	if e, a := "context canceled", err.Error(); !strings.Contains(a, e) {
+		t.Errorf("expect %v error, got %v", e, a)
+	}
+}