public ChannelManager()

in src/main/java/org/apache/skywalking/banyandb/v1/client/grpc/channel/ChannelManager.java [67:83]

• 14 lines of code
• 1 McCabe index (conditional complexity)

    public ChannelManager(ChannelManagerSettings settings, ChannelFactory channelFactory, ScheduledExecutorService executor) throws IOException {
        this.settings = settings;
        this.channelFactory = channelFactory;
        this.executor = executor;

        NameResolverRegistry.getDefaultRegistry().register(new DnsNameResolverProvider());

        entryRef.set(new Entry(channelFactory.create()));
        authority = entryRef.get().channel.authority();

        this.executor.scheduleAtFixedRate(
                this::refreshSafely,
                settings.refreshInterval(),
                settings.refreshInterval(),
                TimeUnit.SECONDS
        );
    }