Imports
- github.com/apache/pulsar-client-go/pulsar
- github.com/cockroachdb/errors
- github.com/golang/protobuf/proto
- github.com/milvus-io/milvus-proto/go-api/commonpb
- github.com/milvus-io/milvus-proto/go-api/msgpb
- github.com/milvus-io/milvus-proto/go-api/schemapb
- github.com/streamnative/pulsarctl/pkg/cli
- github.com/streamnative/pulsarctl/pkg/pulsar/utils
- github.com/stretchr/testify/mock
- go.opentelemetry.io/otel
- go.opentelemetry.io/otel/attribute
- go.opentelemetry.io/otel/propagation
- go.opentelemetry.io/otel/trace
- go.uber.org/zap
Imports in module “github.com/milvus-io/milvus/pkg”
- github.com/milvus-io/milvus/pkg/log
- github.com/milvus-io/milvus/pkg/mq/msgstream/mqwrapper
- github.com/milvus-io/milvus/pkg/mq/msgstream/mqwrapper/kafka
- github.com/milvus-io/milvus/pkg/mq/msgstream/mqwrapper/nmq
- github.com/milvus-io/milvus/pkg/mq/msgstream/mqwrapper/pulsar
- github.com/milvus-io/milvus/pkg/util/commonpbutil
- github.com/milvus-io/milvus/pkg/util/funcutil
- github.com/milvus-io/milvus/pkg/util/paramtable
- github.com/milvus-io/milvus/pkg/util/retry
- github.com/milvus-io/milvus/pkg/util/typeutil