12345678910111213141516171819202122 |
- package helper
- import (
- "testing"
- "github.com/stretchr/testify/assert"
- "github.com/milvus-io/milvus/pkg/streaming/util/types"
- "github.com/milvus-io/milvus/pkg/streaming/walimpls"
- )
- func TestWALHelper(t *testing.T) {
- h := NewWALHelper(&walimpls.OpenOption{
- Channel: types.PChannelInfo{
- Name: "test",
- Term: 1,
- },
- })
- assert.NotNil(t, h.Channel())
- assert.Equal(t, h.Channel().Name, "test")
- assert.NotNil(t, h.Log())
- }
|