wal_helper_test.go 437 B

12345678910111213141516171819202122
  1. package helper
  2. import (
  3. "testing"
  4. "github.com/stretchr/testify/assert"
  5. "github.com/milvus-io/milvus/pkg/streaming/util/types"
  6. "github.com/milvus-io/milvus/pkg/streaming/walimpls"
  7. )
  8. func TestWALHelper(t *testing.T) {
  9. h := NewWALHelper(&walimpls.OpenOption{
  10. Channel: types.PChannelInfo{
  11. Name: "test",
  12. Term: 1,
  13. },
  14. })
  15. assert.NotNil(t, h.Channel())
  16. assert.Equal(t, h.Channel().Name, "test")
  17. assert.NotNil(t, h.Log())
  18. }