manager

Imports

• go.uber.org/zap
• google.golang.org/grpc
• google.golang.org/grpc/credentials/insecure
• go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc
• golang.org/x/sync/errgroup
• go.etcd.io/etcd/client/v3
• github.com/milvus-io/milvus/internal/util/sessionutil
• github.com/milvus-io/milvus/pkg/log
• github.com/milvus-io/milvus/pkg/tracer
• github.com/milvus-io/milvus/pkg/util/lifetime
• github.com/milvus-io/milvus/pkg/util/paramtable
• github.com/milvus-io/milvus/pkg/util/typeutil
• github.com/milvus-io/milvus/pkg/util/interceptor
• github.com/milvus-io/milvus/pkg/streaming/util/types
• github.com/milvus-io/milvus/internal/util/streamingutil/status
• github.com/milvus-io/milvus/internal/util/streamingutil/service/contextutil
• github.com/milvus-io/milvus/internal/util/streamingutil/service/balancer/picker
• github.com/milvus-io/milvus/internal/util/streamingutil/service/discoverer
• github.com/milvus-io/milvus/internal/util/streamingutil/service/interceptor
• github.com/milvus-io/milvus/internal/util/streamingutil/service/lazygrpc
• github.com/milvus-io/milvus/internal/util/streamingutil/service/resolver
• github.com/milvus-io/milvus/pkg/streaming/proto/streamingpb

Standard library imports

• context
• encoding/json
• sync
• time