zipper_test.go 863 B

12345678910111213141516171819202122232425262728293031323334
  1. package yomo
  2. import (
  3. "context"
  4. "testing"
  5. "time"
  6. "github.com/stretchr/testify/assert"
  7. "github.com/yomorun/yomo/core"
  8. "github.com/yomorun/yomo/core/router"
  9. "github.com/yomorun/yomo/core/ylog"
  10. "github.com/yomorun/yomo/pkg/config"
  11. )
  12. func TestZipperRun(t *testing.T) {
  13. zipper, err := NewZipper(
  14. "zipper",
  15. map[string]config.Mesh{},
  16. // WithAuth("token", "<CREDENTIAL>"),
  17. WithUpstreamOption(core.ClientOption(WithCredential("token:<CREDENTIAL>"))),
  18. WithZipperLogger(ylog.Default()),
  19. WithRouter(router.Default()),
  20. WithConnector(core.NewConnector(context.TODO())),
  21. WithVersionNegotiateFunc(core.DefaultVersionNegotiateFunc),
  22. WithZipperQuicConfig(core.DefaultQuicConfig),
  23. WithZipperTLSConfig(nil),
  24. )
  25. assert.Nil(t, err)
  26. time.Sleep(time.Second)
  27. assert.NotNil(t, zipper)
  28. err = zipper.Close()
  29. time.Sleep(time.Second)
  30. assert.Nil(t, err)
  31. }