Function TestTransferEcho

integration/client/transfer_test.go:30–43

(t *testing.T)

)

func TestTransferEcho(t *testing.T) {
	client, err := newClient(t, address)
	if err != nil {
		t.Fatal(err)
	}
	defer client.Close()

	ctx, cancel := testContext(t)
	defer cancel()
	t.Run("ImportExportEchoBig", newImportExportEcho(ctx, client, bytes.Repeat([]byte("somecontent"), 17*1024)))
	t.Run("ImportExportEchoSmall", newImportExportEcho(ctx, client, []byte("somecontent")))
	t.Run("ImportExportEchoEmpty", newImportExportEcho(ctx, client, []byte("")))

}

func newImportExportEcho(ctx context.Context, client *containerd.Client, expected []byte) func(*testing.T) {
	return func(t *testing.T) {