const (
	MaxGetConnTimeout = 10 * time.Second
)

var (
	// ErrClusterClosed returned when requested on a closed cluster.
	ErrClusterClosed = xerrors.Wrap(fmt.Errorf("cluster closed"))

	// ErrClusterEmpty returned when no connections left in cluster.
	ErrClusterEmpty = xerrors.Wrap(fmt.Errorf("cluster empty"))
)

type Cluster interface {
	closer.Closer
	Getter
	Inserter
	Remover
	Explorer
	sync.Locker
	conn.Pessimizer
}

type Endpoint interface {
	NodeID() uint32
}

type Explorer interface {
	SetExplorer(repeater repeater.Repeater)
	Force()
}

type Getter interface {
	// Get gets conn from cluster
	Get(ctx context.Context) (cc conn.Conn, err error)
}

type Inserter interface {
	// Insert inserts endpoint to cluster
	Insert(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption)
}

type InserterRemoverExplorerLocker interface {
	Inserter
	Remover
	Explorer
	sync.Locker
}

type Remover interface {
	// Remove removes endpoint from cluster
	Remove(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption)
}