From 63007032e44fd354b8bdecc41b9ab75d8adf847c Mon Sep 17 00:00:00 2001 From: mcrakhman Date: Thu, 29 Dec 2022 18:27:27 +0100 Subject: [PATCH] Remove unused function in confconnector --- common/commonspace/confconnector/confconnector.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/common/commonspace/confconnector/confconnector.go b/common/commonspace/confconnector/confconnector.go index b2fffbc2..a9ef63eb 100644 --- a/common/commonspace/confconnector/confconnector.go +++ b/common/commonspace/confconnector/confconnector.go @@ -25,7 +25,6 @@ func NewConfConnector(conf nodeconf.Configuration, pool pool.Pool) ConfConnector } func (s *confConnector) Configuration() nodeconf.Configuration { - // TODO: think about rewriting this, because these deps should not be exposed return s.conf } @@ -34,19 +33,18 @@ func (s *confConnector) Pool() pool.Pool { } func (s *confConnector) GetResponsiblePeers(ctx context.Context, spaceId string) ([]peer.Peer, error) { - return s.connectOneOrMany(ctx, spaceId, nil, s.pool.Get, s.pool.GetOneOf) + return s.connectOneOrMany(ctx, spaceId, nil, s.pool.Get) } func (s *confConnector) DialInactiveResponsiblePeers(ctx context.Context, spaceId string, activeNodeIds []string) ([]peer.Peer, error) { - return s.connectOneOrMany(ctx, spaceId, activeNodeIds, s.pool.Dial, s.pool.DialOneOf) + return s.connectOneOrMany(ctx, spaceId, activeNodeIds, s.pool.Dial) } func (s *confConnector) connectOneOrMany( ctx context.Context, spaceId string, activeNodeIds []string, - connectOne func(context.Context, string) (peer.Peer, error), - connectOneOf func(context.Context, []string) (peer.Peer, error)) (peers []peer.Peer, err error) { + connectOne func(context.Context, string) (peer.Peer, error)) (peers []peer.Peer, err error) { var ( inactiveNodeIds []string allNodes = s.conf.NodeIds(spaceId)